使用 Spring Boot 测试 spring boot kafka @sendTo
testing springboog kafka @sendTo with SpringBoot
我正在使用 @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
in the console seems to work, but I don't receive any message in the producer
记住这一点：
- 生产者仅生产（发送）消息
- 消费者仅消费（接收）消息
如果您已经使用 @SendTo 注释为特定主题生成消息，您可以使用订阅相同 example 主题的 kafka-console-consumer.sh 实用程序测试完成情况：
kafka/bin/kafka-console-consumer.sh \
--bootstrap-server localhost:9092 --topic example --from-beginning
如果您通过生产者正确发送消息（使用 @SendTo 注释以编程方式），您应该能够在控制台中看到它们。
为什么不尝试任何开源 GUI 工具，例如 kafka tool
当用例是本地调试和测试时，让生活变得更轻松。
我正在使用 @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
in the console seems to work, but I don't receive any message in the producer
记住这一点：
- 生产者仅生产（发送）消息
- 消费者仅消费（接收）消息
如果您已经使用 @SendTo 注释为特定主题生成消息，您可以使用订阅相同 example 主题的 kafka-console-consumer.sh 实用程序测试完成情况：
kafka/bin/kafka-console-consumer.sh \
--bootstrap-server localhost:9092 --topic example --from-beginning
如果您通过生产者正确发送消息（使用 @SendTo 注释以编程方式），您应该能够在控制台中看到它们。
为什么不尝试任何开源 GUI 工具，例如 kafka tool 当用例是本地调试和测试时，让生活变得更轻松。