Kafkabrokerpod无法连接到Zookeeper

1. 检查 Kafka broker pod 中的 Zookeeper 地址是否正确，并确保和 Zookeeper 中的 hostname 或 IP 地址一致。 示例代码：

   env:

   • name: KAFKA_ZOOKEEPER_CONNECT value: "zk-0.zookeeper:2181,zk-1.zookeeper:2181,zk-2.zookeeper:2181"

2. 如果 Zookeeper 使用的是 SSL 连接，则需要在 Kafka broker 中启用 SSL 配置。在 Kafka broker pod 中的 configmap 中添加以下配置： 示例代码：

   ssl.truststore.location=/etc/certs/cert.jks ssl.truststore.password=password ssl.keystore.location=/etc/certs/cert.jks ssl.keystore.password=password ssl.key.password=password security.protocol=SSL ssl.enabled.protocols=TLSv1.2,TLSv1.1,TLSv1

3. 如果 Kafka broker pod 和 Zookeeper 在不同的 Kubernetes 集群中，则需要使用 Kubernetes Service 配置中的 externalIPs 属性将 Kafka broker pod 暴露给 Zookeeper。 示例代码：

apiVersion: v1 kind: Service metadata: name: kafka-broker spec: selector: app: kafka ports: - name: kafka-plain port: 9092 targetPort: 9092 externalIPs: - 10.10.10.1 - 10.10.10.2

4. 最后，检查 Kafka broker pod 和 Zookeeper 是否使用相同的版本，如果版本不同会导致无法连接。 示例代码：

Zookeeper Version: 3.6.2 Kafka Broker Version: 2.7.0

在确认以上步骤都正确无误之后，Kafka broker pod 应该能够成功连接到 Zookeeper 了。