使用 Spring Boot 测试 Spring Boot kafka @sendTo答案

【问题标题】：testing springboog kafka @sendTo with SpringBoot使用 Spring Boot 测试 Spring Boot kafka @sendTo
【发布时间】：2020-07-21 19:29:32
【问题描述】：

我正在使用@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

【问题讨论】：

【解决方案1】：

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

记住这一点：

如果您已经使用@SendTo 注解为某个主题生成消息，则可以使用订阅相同example 主题的kafka-console-consumer.sh 实用程序来测试是否完善：

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

如果您通过生产者正确发送消息（以编程方式使用@SendTo 注释），您应该能够在控制台中看到它们。

【讨论】：

【解决方案2】：

为什么不尝试任何开源 GUI 工具，例如 kafka tool 当用例是本地调试和测试时，生活会变得更轻松。

【讨论】：