EC2上Kafka连接节点0超时问题排查求助

你的问题核心是Kafka的listeners和advertised.listeners配置不匹配，导致作为Controller的Broker 0无法连接到自己的advertised地址。

具体原因 #

你当前的配置存在矛盾：

• listeners=PLAINTEXT://127.0.0.1:9092：Kafka只监听本地回环网卡的9092端口，只有实例内部通过127.0.0.1才能访问Broker。
• advertised.listeners=PLAINTEXT://34.202.229.148:9092：告诉所有客户端（包括自身Controller）要通过公网IP连接Broker。

但EC2实例内部访问自身公网IP时，流量会先走公网链路返回，且Broker根本没在公网IP对应的网卡上监听9092端口，自然无法建立连接，最终触发超时断开。

解决步骤 #

1. 调整Kafka监听配置
   修改server.properties中的listeners为：

   listeners=PLAINTEXT://0.0.0.0:9092
   

   这样Kafka会监听实例所有网卡的9092端口（包括本地回环、内网IP、公网IP），确保Controller能通过advertised地址连接到自身。

2. 验证内部网络连通性
   在EC2实例内部执行以下命令，测试自身公网IP的9092端口是否可访问：

   nc -zv 34.202.229.148 9092
   

   如果不通，检查：

   • 实例内部防火墙（如iptables）是否允许9092端口入站；
   • EC2安全组是否开放9092端口给实例自身IP（测试阶段可临时开放给0.0.0.0/0，生产环境再收窄范围）。

3. 确认ZooKeeper状态正常
   执行以下命令验证ZooKeeper是否正常运行：

   telnet localhost 2181
   

   能连通说明ZooKeeper无问题，若不通则先重启ZooKeeper服务。

4. 重启Kafka服务
   配置修改完成后，重启Kafka Broker：

   bin/kafka-server-stop.sh
   bin/kafka-server-start.sh config/server.properties
   

额外建议 #

如果你的Kafka仅需实例内部通信（无需外部客户端连接），可直接将advertised.listeners改为PLAINTEXT://localhost:9092，让Controller直接连接本地回环，避免公网IP相关的网络问题。

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