用SpringBoot测试SpringBoot @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实用程序来测试完成过程：

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

如果您通过producer (以编程方式使用@SendTo注释)发送消息，您应该能够在控制台中看到它们。

Answer 2

当用例是本地调试和测试时，为什么不尝试像卡夫卡工具这样的开源GUI工具来让生活变得更容易呢？