Kubernetes中Strimzi部署Kafka无法连接ZooKeeper求助

1. 验证ZK服务的内部可达性 #

• 用busybox测试Kafka Pod所在网络能否访问ZK：

  kubectl run -it --rm busybox --image=busybox:1.35 -- telnet <zk-headless-service-name> 2181
  # 或者用nc
  kubectl run -it --rm busybox --image=busybox:1.35 -- nc -zv <zk-headless-service-name> 2181
  

• 检查ZK headless Service的Endpoints是否正常：

  kubectl describe svc <zk-headless-service-name>
  

  确认Endpoints里列出了所有ZK Pod的IP和2181端口。

2. 核对Kafka的ZK连接配置 #

• 查看Kafka Pod的配置文件（或环境变量）里的zookeeper.connect参数，Strimzi生成的标准格式应该是：

  <zk-cluster-name>-zookeeper-headless.<namespace>.svc.cluster.local:2181
  

  确保集群名、namespace没有拼写错误，多节点ZK的话要包含所有节点地址（比如zk-0.zk-headless:2181,zk-1.zk-headless:2181,zk-2.zk-headless:2181）。

3. 检查ZK集群的运行状态 #

• 查看ZK Pod日志，确认节点已完成初始化：

  kubectl logs <zk-pod-name> -c zookeeper
  

  搜索leader established（主节点）或become follower（从节点）的日志，确保ZK不是卡在初始化阶段。
• 检查ZK数据目录权限：

  kubectl exec <zk-pod-name> -c zookeeper -- ls -ld /var/lib/zookeeper/data
  

  确认运行ZK的用户对该目录有读写权限。

4. 检查Kafka Pod的资源与环境变量 #

• 查看Kafka Pod的资源限制，避免资源不足导致启动超时：

  kubectl describe pod <kafka-pod-name>
  

  重点看Resources字段的limits和requests，如果CPU/内存分配过低，适当调高。
• 检查Kafka的环境变量，比如STRIMZI_ZOOKEEPER_CONNECT，确认其值与预期一致：

  kubectl exec <kafka-pod-name> -c kafka -- env | grep ZOOKEEPER
  

5. 排查网络策略与节点防火墙 #

• 检查集群是否有网络策略限制Kafka访问ZK：

  kubectl get networkpolicies
  

  确保存在允许Kafka namespace访问ZK 2181端口的规则，或者暂时禁用网络策略测试。
• 确认Kafka和ZK所在节点之间的2181端口没有被节点防火墙拦截。

6. 触发Strimzi重新生成Kafka资源 #

如果以上排查都没问题，尝试删除Kafka StatefulSet让Operator重建：

kubectl delete statefulset <kafka-statefulset-name>

等待Operator重新创建Pod，排除配置缓存问题。

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