时间戳

首页 > 解决方案 > 使用 SpringBoot 测试 springboog kafka @sendTo

spring-boot - 使用 SpringBoot 测试 springboog kafka @sendTo

问题描述

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

标签： spring-bootapache-kafkakafka-consumer-apispring-kafkakafka-producer-api

解决方案

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

记住这一点：

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

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

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

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

推荐阅读