Kubernetes集群内Spring Boot无法访问同集群Kafka Broker问题咨询

API 探路者

2026-8-27

问题根因

核心故障点是Kafka Broker的监听器配置错误。
Kafka客户端的连接逻辑是：首次连接配置的bootstrap.servers地址后，会从Broker返回的元数据中拿到Broker配置的advertised.listeners地址，后续所有元数据查询、消息收发请求都会直接访问这个地址。你当前使用的wurstmeister/kafka镜像仅配置了KAFKA_ADVERTISED_HOST_NAME和KAFKA_ADVERTISED_PORT变量，没有显式指定监听器协议与完整的访问地址，导致Broker返回给客户端的访问地址不可达，最终触发请求超时。
另外现有配置中还存在两个隐患：

Kafka Service未显式指定端口协议，存在流量转发异常风险
Spring Boot应用的容器端口与Service配置的targetPort不匹配，后续访问业务接口会出问题

修复步骤

调整Kafka Deployment的环境变量配置
删除原有KAFKA_PORT、KAFKA_ADVERTISED_PORT、KAFKA_ADVERTISED_HOST_NAME三个环境变量，替换为显式的监听器配置，避免镜像隐式拼接配置出错：

containers:
- env:
  - name: KAFKA_BROKER_ID
    value: "1"
  - name: KAFKA_ZOOKEEPER_CONNECT
    value: zookeeper-service.mynamespace-k8s.svc.cluster.local:2181
  - name: KAFKA_LISTENERS
    value: PLAINTEXT://0.0.0.0:9092
  - name: KAFKA_ADVERTISED_LISTENERS
    value: PLAINTEXT://kafka-service.mynamespace-k8s.svc.cluster.local:9092
  - name: KAFKA_INTER_BROKER_LISTENER_NAME
    value: PLAINTEXT
  - name: ALLOW_PLAINTEXT_LISTENER
    value: "yes"
  image: wurstmeister/kafka
  imagePullPolicy: IfNotPresent
  name: kafka-broker
  ports:
  - containerPort: 9092

这里使用K8s集群内服务的完整FQDN地址，避免跨命名空间、DNS搜索域配置不同导致的解析失败。

补全Kafka Service的端口配置
给Kafka Service显式指定端口协议与名称，保证流量转发正常：

apiVersion: v1
kind: Service
metadata:
  labels:
    app: kafka-broker
  name: kafka-service
  namespace: mynamespace-k8s
spec:
  type: ClusterIP
  ports:
  - name: kafka-port
    port: 9092
    targetPort: 9092
    protocol: TCP
  selector:
    app: kafka-broker

集群内服务访问默认用ClusterIP类型即可，不需要额外暴露NodePort。

验证配置生效

先滚动重启Zookeeper、Kafka的工作负载，等待两个Pod完全进入Running状态
进入Spring Boot应用所在的Pod，执行nc -zv kafka-service.mynamespace-k8s.svc.cluster.local 9092验证网络层连通性，返回succeeded即为连通正常
连通性验证通过后，重启Spring Boot应用即可正常创建Topic、发送消息

额外注意事项

对齐Spring Boot应用的端口配置：当前应用容器暴露的是8081端口，但Service配置的targetPort是8080，二者不匹配会导致业务接口无法通过Service访问，需要把两个端口改成一致。
后续如果需要从K8s集群外部访问Kafka，需要额外配置对外的监听器，不要修改集群内使用的PLAINTEXT监听器配置，避免集群内访问异常。
不建议依赖wurstmeister/kafka镜像的KAFKA_ADVERTISED_HOST_NAME、KAFKA_ADVERTISED_PORT这类简化配置变量，直接显式配置KAFKA_LISTENERS和KAFKA_ADVERTISED_LISTENERS是最稳妥的方式，不会出现隐式拼接错误。

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