跨机器连接Kafka Broker至远程ZooKeeper失败求助

1. 验证网络连通性 #

• 在Kafka机器上执行telnet 3.10.180.209 2181或nc -zv 3.10.180.209 2181，确认能正常建立TCP连接。如果不通，说明防火墙/安全组规则未生效：
  • 检查ZooKeeper机器的系统防火墙（如iptables、firewalld），确保2181端口对Kafka机器IP开放，而非仅开放端口但限制来源IP；
  • 若为云服务器，同步检查云服务商安全组的入站规则，确认Kafka机器IP有权访问ZK的2181端口。
• 可在ZK机器上执行tcpdump port 2181抓包，验证Kafka机器的连接请求是否到达ZK节点。

2. 检查ZooKeeper监听配置 #

• 打开ZK的zoo.cfg配置文件，确认listenAddress未绑定到127.0.0.1（否则仅本地可访问），改为0.0.0.0或ZK机器的公网/内网IP；
• 执行zkServer.sh status确认ZK服务正常启动，状态显示为Mode: standalone（单节点）或集群正常状态。

3. 调整Kafka的ZK连接超时参数 #

• 修改Kafka的server.properties，延长连接超时时间（默认6000毫秒可能不足以应对跨机器网络延迟）：

  zookeeper.connection.timeout.ms=10000
  zookeeper.session.timeout.ms=30000
  

• 保存配置后重启Kafka Broker，重试连接。

4. 排查ZooKeeper连接数限制 #

• 查看ZK日志（默认路径为/var/log/zookeeper/或ZK安装目录的logs文件夹），若存在Too many connections报错，调整zoo.cfg中的maxClientCnxns参数（默认60），改为更大值（如100）后重启ZK。

"ZooKeeperClientTimeoutException: Timed out waiting for connection while in state: CONNECTING"的核心原因是Kafka无法与ZK建立TCP连接，或在超时窗口内未完成握手，优先从网络连通性、ZK监听配置、超时参数这几个方向排查。

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