Kubernetes中Kafka无法识别ZooKeeper主机名启动失败求助

你在AWS Kubernetes上部署JHipster生成的微服务集群时，遇到了Kafka启动失败的问题，核心原因是Kafka无法解析ZooKeeper的主机名。我来帮你一步步排查和解决：

1. 先确认ZooKeeper的基础运行状态 #

首先得确保ZooKeeper本身是正常运行且可被K8s内部访问的：

• 检查ZooKeeper Pod是否处于Running状态：

  kubectl get pods -n duppoc | grep zookeeper
  

• 确认对应的Kubernetes Service已创建：

  kubectl get svc -n duppoc | grep zookeeper
  

• 进入Kafka Pod内部，测试ZooKeeper主机名的DNS解析是否正常：

  kubectl exec -it chargecodes-kafka-5799d8f99b-wnqhc -n duppoc -- nslookup chargecodes-zookeeper
  

  （这里的chargecodes-zookeeper是JHipster默认生成的ZooKeeper服务名，如果你的服务命名不同，替换成实际名称即可）

如果解析失败，说明K8s内部DNS服务有异常，或者ZooKeeper服务未正确创建，先解决这个基础问题。

2. 验证Kafka配置中的ZooKeeper连接地址 #

接下来检查Kafka的核心配置，确认ZooKeeper的连接地址是否正确：

• 查看Kafka的server.properties配置文件：

  kubectl exec -it chargecodes-kafka-5799d8f99b-wnqhc -n duppoc -- cat /opt/kafka/config/server.properties
  

• 找到zookeeper.connect配置项，确认值是否为chargecodes-zookeeper:2181（即你的ZooKeeper服务名+默认端口2181）。如果这里是硬编码的IP或者错误的主机名，你需要修改JHipster生成的Kafka部署YAML文件，重新部署。

另外，JHipster通常会用环境变量注入这个配置，你可以检查Kafka Pod的环境变量：

kubectl exec -it chargecodes-kafka-5799d8f99b-wnqhc -n duppoc -- env | grep ZOOKEEPER

确保ZOOKEEPER_SERVICE_NAME的值是正确的ZooKeeper服务名。

3. 检查网络与安全组限制 #

在AWS EKS环境中，网络和安全组规则也可能导致通信失败：

• 检查EKS Node组的安全组，是否允许Kafka Pod所在节点与ZooKeeper Pod所在节点之间的2181端口通信。
• 查看Kubernetes的NetworkPolicy，是否有规则限制了Kafka和ZooKeeper之间的流量：

  kubectl get networkpolicies -n duppoc
  

  如果存在相关的NetworkPolicy，确保它允许Kafka到ZooKeeper的出站流量，以及ZooKeeper对Kafka的入站流量。

4. 重启相关资源 #

如果以上配置和网络都没问题，尝试重启ZooKeeper和Kafka Pod：

• 重启ZooKeeper Pod：

  kubectl delete pod <zookeeper-pod-name> -n duppoc
  

• 重启Kafka Pod：

  kubectl delete pod chargecodes-kafka-5799d8f99b-wnqhc -n duppoc
  

K8s会自动重新创建Pod，此时应该能正常解析ZooKeeper主机名并启动。

你提供的异常信息：

pjadda$ kubectl attach -it chargecodes-kafka-5799d8f99b-wnqhc -n duppoc Unable to use a TTY - contai...

这个提示是因为Kafka Pod可能已经处于CrashLoopBackOff状态，无法分配TTY，所以建议用kubectl exec代替attach来进入容器排查，也就是我上面用到的命令。

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