如何自动获取Zookeeper Service集群IP配置Kafka Broker？

Kubernetes集群内置DNS服务，Pod可通过服务名称+命名空间+集群域名的方式直接访问对应服务，完全无需依赖会动态变化的Cluster IP。具体操作步骤如下：

• 确认Zookeeper Service的名称与命名空间
  假设你的Zookeeper Service名为zookeeper-service，自定义命名空间为kafka-namespace，则完整的DNS访问格式为：

  zookeeper-service.kafka-namespace.svc.cluster.local
  

  各部分含义：

  • zookeeper-service：你的Zookeeper服务名称
  • kafka-namespace：你修改后的目标命名空间
  • svc.cluster.local：Kubernetes集群默认的服务域名后缀

• 修改Kafka Broker部署文件的环境变量
  将KAFKA_ZOOKEEPER_CONNECT的值替换为上述DNS名称（加上Zookeeper默认端口2181），示例配置片段：

  env:
    - name: KAFKA_ZOOKEEPER_CONNECT
      value: "zookeeper-service.kafka-namespace.svc.cluster.local:2181"
  

• 同命名空间下的简化写法
  如果Kafka与Zookeeper部署在同一个命名空间内，可省略命名空间和集群域名，直接用服务名访问：

  env:
    - name: KAFKA_ZOOKEEPER_CONNECT
      value: "zookeeper-service:2181"
  

配置完成后，每次重建Vagrant虚拟机，Kubernetes都会自动通过DNS解析找到Zookeeper服务的当前Cluster IP，无需手动修改任何配置。

内容的提问来源于stack exchange，提问作者Marc Le Bihan