Spring Boot集成Kafka消费者持续告警：Leader Broker无匹配Listener

我之前也碰到过一模一样的情况！这个警告跟你的Spring Boot代码完全没关系，问题出在Kafka Broker的监听器配置上，咱们来快速解决：

问题根源 #

Kafka Broker启动时，会通过advertised.listeners配置告诉客户端（消费者/生产者）它的连接地址。如果这个地址和客户端实际能访问的地址不匹配，消费者就找不到分区的Leader节点，从而不断输出这个警告。你的生产者能正常发送消息，只是因为初始连接成功了，但后续消费者尝试获取分区Leader信息时就出错了。

解决方案 #

1. 修改Kafka的server.properties配置文件 #

找到你的Kafka安装目录下的config/server.properties文件，修改以下两个配置项：

# 让Broker监听本地的9092端口
listeners=PLAINTEXT://localhost:9092
# 告诉客户端用这个地址连接Broker（必须和客户端能访问的地址一致）
advertised.listeners=PLAINTEXT://localhost:9092

如果你的Kafka部署在远程服务器上，把localhost换成服务器的公网/内网IP即可；如果是Docker容器运行的Kafka，要设置成宿主机的IP或者确保端口映射正确后用localhost。

2. 重启Kafka服务 #

保存配置后，停止并重启Kafka Broker，让新配置生效：

• Windows环境：找到Kafka的启动脚本，先运行kafka-server-stop.bat停止服务，再运行kafka-server-start.bat config/server.properties重启。
• Linux/macOS环境：执行bin/kafka-server-stop.sh，再执行bin/kafka-server-start.sh config/server.properties。

3. 验证修复效果 #

重启完成后：

• 启动你的Spring Boot项目，观察控制台是否还有警告输出，同时调用/kafka/publish接口发送消息，看看消费者能不能正常打印消费日志。
• 用Windows命令行测试消费者：

kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic users --group group_id --from-beginning

如果能正常接收到消息，且没有重复警告，就说明问题解决了！

额外说明 #

你的Spring Boot代码和application.yml配置都是完全正确的，不用做任何修改。这个问题本质是Kafka默认配置在本地开发场景下的适配问题，只要调整Broker的监听器配置就能解决。

内容的提问来源于stack exchange，提问作者tac demo