如何使用Reactor Kafka KafkaSender API向两个不同的主题（位于两个不同的Kafka集群）发送消息？

Question

我正在尝试使用Reactor Kafka的KafkaSender将消息发送到两个不同的kafka主题。

通过两个不同的卡夫卡主题，我的意思是： 集群 kafka-first-broker.com:9092 中有一个名为“first_topic”的主题 然后，在另一个集群中还有另一个名为“another_topic”的主题，与上面的不一样，名为 kafka-another-broker-not-the-same-as-above.com:9093

但是，reactor kafka 的

send

方法似乎只支持一个目的地

我尝试使用带有逗号分隔列表（两个主题）的发送方法

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

我本来希望将其发送到两个不同的主题，但它只能发送到一个。

如何利用 Reactor Kafka KafkaSender API 将消息发送到位于两个不同 Kafka 集群中的两个不同主题？

Answer 1

发送者之间只有一个共享的 ProducerConfig。

您需要首先构建两者的新实例。