Apache Kafka Producer连接Broker异常回退至localhost求助

核心原因：Broker返回的连接地址覆盖了初始配置 #

librdkafka的工作逻辑是：客户端先连接你指定的bootstrap服务器，成功后Broker会返回自己的advertised.listeners配置地址，后续客户端会使用这个地址进行通信。如果Broker的advertised.listeners设为localhost:29092，不管你初始指定的bootstrap地址是什么，客户端都会转而连接localhost，这就是你遇到的问题。

解决步骤 #

1. 检查并修正Kafka Broker的配置 #

打开Broker的server.properties文件，找到advertised.listeners配置项：

• 如果该项被注释，或者值为PLAINTEXT://localhost:29092，修改为对外可访问的地址：

  advertised.listeners=PLAINTEXT://192.168.68.111:29092
  

• 确保listeners配置和advertised.listeners匹配（比如都是PLAINTEXT协议，端口一致）
• 修改后重启Kafka Broker服务

2. 排查代码中的配置覆盖问题 #

检查你的C++代码：

• 确认初始化KafkaProducer后，没有后续代码修改bootstrap.servers配置
• 检查是否通过其他方式（比如读取配置文件、环境变量）覆盖了初始设置

3. 验证环境变量干扰 #

运行程序前，检查是否存在KAFKA_BOOTSTRAP_SERVERS环境变量：

• 在Linux/macOS下执行echo $KAFKA_BOOTSTRAP_SERVERS，如果输出是localhost:29092，执行unset KAFKA_BOOTSTRAP_SERVERS清除该变量
• 在Windows下检查系统环境变量，删除或修改该变量的值

4. 验证Broker配置有效性 #

用Kafka自带工具测试Broker的可访问性：

kafka-topics.sh --list --bootstrap-server 192.168.68.111:29092

如果能正常列出Topic，说明Broker的advertised.listeners配置正确；如果报错，回到第一步重新检查配置。

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