我有两个springboot项目a和b。我已经下载了apachekafka并启动了zooleeper和kafka。
在a和b中,我只有一个消费群体。在消费者类别中:
@KafkaListener(topics = "test", groupId = "test")
public void consume(String message) {
logger.info(String.format("Message received -> %s", message));
}
这是我在consumer类中为项目a和b编写的代码。
当我试图发布主题为“test”的消息时。该消息正在项目a中使用。我能够在记录器“消息接收”中获得输出。而在项目b中,我无法在记录器中获得输出。但是,当我尝试用终端监视已消耗的消息时,消息已被消耗。问题是项目b中的消费函数不起作用。
有人能帮忙吗?
1条答案
按热度按时间rkue9o1l1#
首先,停止项目a,运行项目b,看看结果是否可以使用消息。
其次,检查为项目b上的kafka consummer配置的bean,并为其设置另一个名称
Bean listener
例子:让我们试试