тестирование Springboog Kafka @sendTo с SpringBoot

Question

Я использую аннотацию @SendTo("example") для отправки сообщений в тему, но я не знаю, как это проверить. Я открываю производителя консоли

bin/kafka-console-producer.sh --broker-list localhost:9092 --topic example

в консоли, кажется, работает, но я не получаю никакого сообщения в производителе

gid: trace= span= [kafka-producer-network-thread | producer-1] org.apache.kafka.clients.Metadata Cluster ID: uX-1vV4bSFup6t_Sh_LNCg

Answer 1

почему бы вам не попробовать какой-либо инструмент с открытым исходным кодом GUI, например инструмент kafka , который значительно облегчает жизнь, когда в качестве примера использования используются локальная отладка и тестирование.

Answer 2

в консоли, кажется, работает, но я не получаю никакого сообщения от производителя

Запомните:

• Производитель только создает (отправляет) сообщения
• Потребитель только потребляет (получает) сообщения

Если вы уже отправляете сообщения на определенный топи c с использованием аннотации @SendTo, вы можете проверить завершенность, используя утилиту kafka-console-consumer.sh, подписанную на ту же example topi c:

kafka/bin/kafka-console-consumer.sh \
--bootstrap-server localhost:9092 --topic example --from-beginning

Если вы отправляете сообщения через производителя (программно, используя аннотацию @SendTo), вы сможете увидеть их в консоли.