如何在Node.js应用中获取Kubernetes ClusterIP服务的IP地址？

首先明确：Kubernetes集群内部通过DNS解析Service名称来访问服务，kafka-srv:9092是标准的访问方式，CoreDNS会自动将其解析为Service的ClusterIP。你无需手动替换为IP，直接使用该名称即可正常连接。如果确实需要获取Service的实际IP，可通过以下几种方式：

1. 利用Kubernetes自动注入的环境变量 #

Kubernetes会自动给每个Pod注入集群内所有Service的环境变量，格式为{SERVICE_NAME}_SERVICE_HOST（对应IP）和{SERVICE_NAME}_SERVICE_PORT（对应端口）。

对于你的kafka-srv，无需手动设置环境变量，直接在代码中使用：

this.kafka = new Kafka({
    clientId: "kafka-app",
    brokers: [`${process.env.KAFKA_SRV_SERVICE_HOST}:${process.env.KAFKA_SRV_SERVICE_PORT}`]
});

注：环境变量名称会将Service名称的小写字母转为大写，连字符转为下划线。

2. 通过kubectl命令手动查询（调试用） #

如果只是调试需要查看Service的IP，执行以下命令：

kubectl get service kafka-srv -o jsonpath='{.spec.clusterIP}'

该命令会直接输出kafka-srv的ClusterIP，但此IP不会自动同步到Pod环境变量，仅用于临时查看。

3. 调用Kubernetes API获取（不推荐） #

若需在代码中动态获取，可通过Kubernetes API查询，但需为Pod配置相应权限：

1. 创建具有Service读取权限的ServiceAccount
2. 绑定对应的ClusterRole/Role
3. 在Pod的spec.serviceAccountName中指定该账号
4. 在Node.js代码中调用API接口：https://kubernetes.default.svc/api/v1/namespaces/{你的命名空间}/services/kafka-srv，从返回的JSON中提取spec.clusterIP字段

这种方式复杂度高，仅适用于特殊场景，日常使用DNS名称即可满足需求。

排查连接问题 #

如果使用kafka-srv:9092无法连接，需检查：

• Kafka Pod的标签是否与Service的selector完全匹配
• Kafka容器是否在9092端口正常监听
• Pod与Service是否处于同一命名空间（不同命名空间需使用全限定域名：kafka-srv.{命名空间}.svc.cluster.local:9092）

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