Spring Boot kafka 消费者，未触发的两个侦听器之一答案

【问题标题】：Spring boot kafka consumer, one of two listeners not triggeredSpring Boot kafka 消费者，未触发的两个侦听器之一
【发布时间】：2020-11-06 07:10:12
【问题描述】：

我有两个spring boot项目A和B。我已经下载了apache kafka并启动了zooleeper和kafka。

在 A 和 B 中，我只有一个消费者组。在消费类中：

@KafkaListener(topics = "test", groupId = "test")
public void consume(String message) {
    logger.info(String.format("Message received -> %s", message));
}

这是我在项目 A 和 B 的消费者类中的代码。

当我尝试发布主题为“test”的消息时。消息在项目 A 中被消耗。我能够在记录器“收到消息”中获得输出。而在项目 B 中，我无法在记录器中获得输出。但是当我尝试用终端监控消费的消息时，消息被消费了。问题是项目B中的consume函数不工作。

有人可以帮忙吗？

【问题讨论】：

您确定项目B中的consume功能不起作用吗？可能是日志记录不起作用或日志文件不是您正在检查的文件？
不，它不起作用。如果消费者函数中实现了任何其他功能，则它不起作用。

标签： java spring-boot apache-kafka kafka-consumer-api

【解决方案1】：

首先，你停止项目A，运行项目B，看看它是否可以消费消息。
其次，检查您在项目 B 上为 Kafka 消费者配置的 bean，并为 Bean listener 设置另一个名称示例：

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

我们试试

【讨论】：