Kafka Exporter初始化失败：无法解析Kafka Broker主机名求助

问题现象 #

部署Kafka Exporter后Pod启动失败，日志显示无法解析Kafka Broker的主机名：

C:\kafka>kubectl logs kafka-exporter-745f574c74-tzfn4
I0127 12:39:08.113890 1 kafka_exporter.go:792] 启动kafka_exporter（版本=1.6.0，分支=master，修订版本=9d9cd654ca57e4f153d0d0b00ce36069b6a677c1）
F0127 12:39:08.890639 1 kafka_exporter.go:893] 初始化Kafka客户端错误：kafka: 客户端已无可用代理可连接：dial tcp: 在10.96.0.10:53上查找kafka.osm.svc.cluster.local：无此主机

提供的配置文件 #

kafka-exporter-deployment.yaml #

apiVersion: apps/v1
kind: Deployment
metadata:
name: kafka-exporter
namespace: default
spec:
replicas: 1
selector:
matchLabels:
app: kafka-exporter
template:
metadata:
labels:
app: kafka-exporter
spec:
containers:
- name: kafka-exporter
image: danielqsj/kafka-exporter:latest
imagePullPolicy: IfNotPresent
args:
- --kafka.server=kafka.osm.svc.cluster.local:9092
- --web.listen-address=:9092
ports:
- containerPort: 9308
env:
- name: KAFKA_EXPORTER_KAFKA_CONNECT
value: kafka-broker-644794f4ff-8gmxb:9092
- name: KAFKA_EXPORTER_TOPIC_WHITELIST
value: samptopic

Kafka-exporter-service.yaml #

apiVersion: v1
kind: Service
metadata:
name: kafka-exporter
namespace: default
spec:
selector:
app: kafka-exporter
ports:

name: http
port: 9308
targetPort: 9308
type: NodePort

排查和修复步骤 #

• 验证Kafka Service的DNS可用性

  1. 确认Kafka所在的osm命名空间中存在名为kafka的Service：

     kubectl get svc -n osm
     

     若找不到该Service，说明Kafka的Service未正确创建或名称/命名空间有误，需先修正Kafka的Service配置。
  2. 在集群内测试Pod中验证DNS解析：

     # 临时启动busybox Pod执行解析测试
     kubectl run -it --rm busybox --image=busybox:1.28 -- nslookup kafka.osm.svc.cluster.local
     

     若解析失败，检查集群DNS服务（如CoreDNS）是否正常运行，或Kafka Service的Endpoints是否关联了可用Pod。

• 解决配置参数冲突
  部署文件同时使用了--kafka.server命令行参数和KAFKA_EXPORTER_KAFKA_CONNECT环境变量，两者均用于指定Kafka地址，存在优先级冲突（命令行参数优先级更高）。且环境变量中使用的是Kafka Pod的临时主机名，Pod重启后会失效，不适合长期使用。
  修正方案：保留一种配置方式，推荐使用Kafka的Service地址。例如修改部署文件的args部分，确保监听端口与容器端口一致，并删除冲突的环境变量：

  args:
    - --kafka.server=kafka.osm.svc.cluster.local:9092
    - --web.listen-address=:9308
  env:
    - name: KAFKA_EXPORTER_TOPIC_WHITELIST
      value: samptopic
  

• 修正端口配置错误
  当前部署文件中--web.listen-address=:9092指定的监听端口与容器端口9308不匹配，且9092是Kafka默认端口，易引发冲突。需将监听端口改为9308（Kafka Exporter默认端口），与容器端口保持一致。

• 修复Service文件格式错误
  Service文件的ports部分缺少列表项标识符-，导致配置无效。修正后的ports部分应为：

  ports:
    - name: http
      port: 9308
      targetPort: 9308
  

验证修复 #

修改配置后重新部署：

kubectl apply -f kafka-exporter-deployment.yaml
kubectl apply -f kafka-exporter-service.yaml

查看Pod日志确认是否正常启动：

kubectl logs -l app=kafka-exporter

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