spring引导kafka使用者,两个侦听器之一未触发

rmbxnbpk  于 2021-06-04  发布在  Kafka
关注(0)|答案(1)|浏览(338)

我有两个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中的消费函数不起作用。
有人能帮忙吗?

rkue9o1l

rkue9o1l1#

首先,停止项目a,运行项目b,看看结果是否可以使用消息。
其次,检查为项目b上的kafka consummer配置的bean,并为其设置另一个名称 Bean listener 例子:

@Bean("anotherName")
    public ConcurrentKafkaListenerContainerFactory...{}

让我们试试

相关问题