使用SpringBoot测试springboog kafka @sendTo

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

在控制台中似乎可以正常工作，但是在生产者中我没有收到任何消息

记住此：

• [生产者仅生产（发送）消息
• 仅消费者 消费（接收）消息

如果您已经使用@SendTo注释生成了针对某个主题的消息，则可以使用订阅同一kafka-console-consumer.sh主题的kafka-console-consumer.sh实用工具来测试其完善性：

example

如果您通过生产者正确地发送消息（通过编程使用

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

注释），则应该能够在控制台中看到它们。

Answer 2

您为什么不尝试使用任何开源GUI工具，例如@SendTo当用例是本地调试和测试时，会使工作变得更轻松。