Как использовать API Reactor Kafka KafkaSender для отправки сообщений в две разные темы (расположенные в двух разных кла ⇐ JAVA

[Anonymous]

Я пытаюсь отправить сообщения в две разные темы Kafka, используя KafkaSender Reactor Kafka.
Под двумя разными темами Kafka я имею в виду:
Есть тема под названием "first_topic" в кластере kafka-first-broker.com:9092
Затем есть еще одна тема под названием "another_topic" в другом кластере, не такая, как указано выше, под названием kafka-another-broker-not-the-same-as-above.com:9093
Однако кажется, что метод send реактора kafka поддерживает только один пункт назначения
Я попробовал использовать метод send со списком разделённых запятыми (двух тем)

Код: Выделить всё

SenderRecord.create(new ProducerRecord("first_topic,another_topic", null, mymessage), mymessage)

Я ожидал, что это сообщение будет отправлено в две разные темы, но оно может быть отправлено только в одну.
Как я могу использовать Reactor Kafka KafkaSender API для отправки сообщений в две разные темы, расположенные в двух разных кластерах Kafka?

Подробнее здесь: https://stackoverflow.com/questions/791 ... rent-topic