执行zookeeper-shell.sh命令后出现EndOfStreamException问题求助

问题背景 #

刚上手Zookeeper和Kafka，执行以下Zookeeper Shell命令时，反复碰到EndOfStreamException异常：

• ./bin/zookeeper-shell.sh localhost:2181 ls /brokers/ids
• ./bin/zookeeper-shell.sh localhost:2181 get /brokers/ids/{id}

目前Kafka Broker还能正常响应，未出现故障，但想提前解决避免问题扩大。环境为单集群：1个Zookeeper节点 + 3个Kafka Broker。

相关截图 #

• Zookeeper命令执行界面：
• Zookeeper日志详情：

排查修复步骤 #

1. 确认Zookeeper服务状态 #

先检查ZK是否正常运行：

• 执行 ./bin/zkServer.sh status，确认输出为Mode: standalone且服务处于运行状态。
• 如果服务异常，先重启ZK：./bin/zkServer.sh restart，之后再执行Shell命令测试。

2. 检查端口与网络连通性 #

• 用 netstat -tulpn | grep 2181 确认2181端口被ZK进程监听。
• 用 telnet localhost 2181 测试连接，能看到ZK欢迎信息说明网络没问题；连接失败的话，检查防火墙是否拦截2181端口，或者有没有其他进程占用该端口。

3. 修复Zookeeper数据文件（常见原因） #

EndOfStreamException大多和ZK数据文件损坏有关，处理步骤：

1. 停止ZK服务：./bin/zkServer.sh stop
2. 找到zoo.cfg里的dataDir路径，备份该目录下的version-2文件夹（防止数据丢失）
3. 删除version-2下的log.*和snapshot.*文件
4. 重启ZK服务，然后重启所有Kafka Broker，让Broker重新向ZK注册元数据

4. 验证版本兼容性 #

确保ZK和Kafka版本匹配（比如Kafka 2.8.x对应ZK 3.5.x/3.6.x），版本不兼容会导致通信异常。如果版本不匹配，升级或降级到官方推荐的兼容版本。

5. 调整会话超时参数 #

修改ZK和Kafka的超时配置：

• 在ZK的zoo.cfg中：

  tickTime=3000
  initLimit=10
  syncLimit=5
  

• 在Kafka的server.properties中：

  zookeeper.session.timeout.ms=30000
  

• 重启ZK和所有Kafka Broker后测试。

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