Kubernetes部署Kafka时Controller 0与Broker连接失败问题排查求助

结合你的错误日志和配置文件来看，问题主要出在内部监听地址的配置逻辑以及Pod端口的声明上，我整理了几个关键修复点：

1. 完善Pod的端口声明 #

你的Pod定义里仅声明了9092端口，但Kafka容器同时监听了29092（对应LISTENER_INTERNAL）。虽然containerPort不是强制配置项，但明确声明可以让Kubernetes网络层正确识别容器的端口映射关系，避免Service转发异常。修改Pod的ports部分：

ports:
- containerPort: 9092
- containerPort: 29092

2. 调整内部Advertised Listener地址 #

你当前的KAFKA_ADVERTISED_LISTENERS把内部监听地址设为kafka-service:29092，这会导致Controller（也就是Broker自身进程）尝试通过Service来连接自己。在单Broker场景下，这种跨Service的本地通信很容易因为网络转发延迟、DNS解析链路问题触发Socket超时。

把内部监听的advertised地址改成localhost:29092，让Controller直接通过本地回环连接Broker，绕开Service的转发环节：

- name: KAFKA_ADVERTISED_LISTENERS
  value: "LISTENER_INTERNAL://localhost:29092,LISTENER_EXTERNAL://kafka-service:9092"

3. 可选的网络连通性验证 #

如果修改后仍有问题，可以进入Pod内部做两步排查：

• 执行 telnet localhost 29092 或 nc -zv localhost 29092，确认容器内部能正常访问29092端口
• 执行 nslookup kafka-service，确认Service的DNS解析正常；如果解析失败，需要检查Kubernetes CoreDNS的运行状态

修复逻辑说明 #

当Kafka Broker同时承担Controller角色时，它需要和自身的Broker进程建立连接。原配置让它通过Service的ClusterIP访问自己，增加了不必要的网络跳转；改用localhost直接连接后，消除了中间转发环节，能有效避免超时问题。

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