Início / coding / Perguntas / 79157067
Accepted
PatPanda
Asked: 2024-11-05 05:34:11 +0800 CST

Como usar a API KafkaSender do Reactor Kafka para enviar mensagens para dois tópicos diferentes (situados em dois clusters Kafka diferentes)?

  • 772

Estou tentando enviar mensagens para dois tópicos diferentes do Kafka usando o KafkaSender do Reactor Kafka.

Por dois tópicos diferentes do Kafka, quero dizer: Há um tópico chamado "first_topic" no cluster kafka-first-broker.com:9092 Então, há outro tópico chamado "another_topic", em outro cluster, não o mesmo que o acima, chamado kafka-another-broker-not-the-same-as-above.com:9093

No entanto, parece que o sendmétodo do reator Kafka suporta apenas um destino

Tentei usar o método send com uma lista separada por vírgulas de (dois tópicos)

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

Eu esperava que isso fosse enviado para dois tópicos diferentes, mas só pode ser enviado para um.

Como posso aproveitar a API KafkaSender do Reactor Kafka para enviar mensagens para dois tópicos diferentes situados em dois clusters Kafka diferentes?

java

1 respostas

  1. Best Answer

    Há apenas um ProducerConfig compartilhado entre os remetentes. Há apenas um cluster representado por ProducerConfig

    Você precisará construir uma nova instância de ambos primeiro.

    • 1

relate perguntas