无法从远程主机访问Kafka服务器问题求助

核心问题分析 #

你遇到的问题是Kafka返回给客户端的broker地址为localhost:9092，而非配置的10.10.45.91:9092，导致远程客户端尝试连接本地localhost失败。这通常是Kraft模式下配置未正确加载或元数据未更新导致的。

排查步骤 #

1. 确认配置文件路径是否正确 #

Kafka Kraft模式默认使用config/kraft/server.properties，而非根目录下的server.properties，先检查你修改的是不是这个文件：

ls $KAFKA_HOME/config/kraft/

如果之前修改的是根目录的server.properties，请将配置同步到config/kraft/server.properties中：

listeners=PLAINTEXT://0.0.0.0:9092
advertised.listeners=PLAINTEXT://10.10.45.91:9092

2. 验证配置是否生效 #

在Kafka服务器（10.10.45.91）上执行命令，查看当前broker的实际配置：

kafka-configs.sh --describe --bootstrap-server localhost:9092 --entity-type brokers --entity-name <你的broker-id>

替换<你的broker-id>为实际值（可在server.properties中查看broker.id），如果输出中advertised.listeners不是PLAINTEXT://10.10.45.91:9092，说明配置未加载。

3. 清理Kraft元数据并重启 #

如果之前启动时用的是localhost地址，Kraft会将旧地址存入元数据，修改配置后需要清理元数据目录（默认是/tmp/kraft-combined-logs）：

# 停止Kafka服务
kafka-server-stop.sh

# 删除元数据目录
rm -rf /tmp/kraft-combined-logs

# 重新启动Kafka
kafka-server-start.sh config/kraft/server.properties

4. 客户端测试验证 #

在远程主机（10.10.45.90）重新执行kcat命令：

kcat -L -b 10.10.45.91:9092

如果返回的broker地址显示为10.10.45.91:9092，则配置生效，再测试消费：

kcat -C -t logstash-topic -b 10.10.45.91:9092

额外注意事项 #

• 确保防火墙不仅开放9092端口，还要确认Kafka服务绑定的是0.0.0.0（可通过netstat -tulpn | grep 9092验证）。
• Logstash的Kafka输入配置中，bootstrap_servers要明确指定10.10.45.91:9092，避免依赖自动发现的错误地址。

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