Kafka消费者无法连接ZooKeeper超时问题求助

嘿，我来帮你梳理下这个问题！你遇到的ZkTimeoutException在kafka_2.9.2-0.8.1.1这个老版本里挺常见，先从最容易踩的坑开始排查：

1. 首先纠正消费者命令的端口错误 #

你执行的消费者命令里，--zookeeper参数填了localhost:9092，但这个端口是Kafka Broker的监听端口，ZooKeeper的默认端口是2181！这是最常见的低级错误，先把命令改成：

./kafka-console-consumer.sh --zookeeper localhost:2181 --topic test --from-beginning

先试试这个，大概率能解决问题。

2. 如果改端口后还是超时，检查ZooKeeper的连通性 #

• 先确认ZooKeeper的实际监听端口：打开ZK的配置文件zoo.cfg，查看clientPort配置项，确认是不是2181（如果改了就用对应的端口）。
• 用工具测试端口连通性：

  # 用telnet测试
  telnet localhost 2181
  # 或者用nc（如果安装了的话）
  nc -zv localhost 2181
  

  如果连接失败，说明ZK虽然进程在跑，但端口没正常监听，可能是ZK配置错误或者启动异常，查看ZK的日志文件找问题。

3. 验证ZooKeeper服务是否正常 #

用ZK自带的客户端工具连接测试：

./zkCli.sh -server localhost:2181

如果能成功进入ZK命令行，执行ls /能看到节点列表，说明ZK服务是正常的；如果连接失败，那就是ZK本身的问题，得先把ZK修好。

4. 调整消费者的ZK超时配置 #

这个老版本的Kafka消费者默认ZK会话超时是6000ms，要是你的ZK响应较慢，可能需要调大超时时间：

• 创建一个consumer.properties文件，加入：

  zookeeper.session.timeout.ms=10000
  

• 然后用这个配置启动消费者：

  ./kafka-console-consumer.sh --zookeeper localhost:2181 --topic test --from-beginning --consumer.config consumer.properties
  

5. 检查你的Topic配置是否合法 #

你提到创建了“无分区和副本因子的topic”，这其实是不符合Kafka规则的——Kafka的Topic必须至少有1个分区和1个副本因子。如果你的创建命令是类似--partitions 0 --replication-factor 0，那这个Topic其实是无效的，可能会导致消费者异常。建议重新创建Topic：

./kafka-topics.sh --create --zookeeper localhost:2181 --topic test --partitions 1 --replication-factor 1

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