我正在尝试使用 Reactor Kafka 的 KafkaSender 向两个不同的 kafka 主题发送消息。
我所说的两个不同的 kafka 主题是指：集群 kafka-first-broker.com:9092 中有一个名为“first_topic”的主题，然后，在另一个集群中，有另一个名为“another_topic”的主题，与上面的不一样，名为 kafka-another-broker-not-the-same-as-above.com:9093
但是，似乎sendReactor Kafka 的方法仅支持一个目的地
我尝试使用发送方法发送以逗号分隔的列表（两个主题）
SenderRecord.create(new ProducerRecord<>("first_topic,another_topic", null, mymessage), mymessage)
我原本期望将其发送到两个不同的主题，但它只能发送到一个。
如何利用 Reactor Kafka KafkaSender API 将消息发送到位于两个不同 Kafka 集群中的两个不同主题？
发送者之间只共享一个 ProducerConfig。每个 ProducerConfig 只代表一个集群
首先，您需要构建两者的新实例。