本地K8s部署Kafka后，Offset Explorer连接失败求助

排查方向及解决步骤 #

1. 确认Kafka端口暴露逻辑 #

• 检查Kafka Service的端口类型：如果用NodePort，执行kubectl get svc <kafka-service-name>，验证PORT(S)列的NodePort值是否为30092；如果用Ingress，注意普通HTTP Ingress不支持TCP转发，需确认Ingress控制器（如NGINX）是否配置了TCP ingress规则，否则无法转发Kafka的TCP流量。
• 若端口暴露错误，修改Service配置：将Kafka容器的监听端口映射为正确的NodePort，或补全Ingress的TCP转发规则。

2. 修正Kafka的advertised.listeners配置 #

这是外部客户端连接失败的核心原因之一：

• Kafka的advertised.listeners必须返回外部客户端可访问的地址，若仅配置集群内部地址（如kafka-svc:9092），Offset Explorer拿到后无法建立有效连接，会触发EOFException。
• 修改Kafka Deployment的环境变量或配置文件，添加外部可访问的listener：

  listeners=PLAINTEXT://0.0.0.0:9092,PLAINTEXT_HOST://0.0.0.0:9093
  advertised.listeners=PLAINTEXT://kafka-svc:9092,PLAINTEXT_HOST://localhost:30092
  listener.security.protocol.map=PLAINTEXT:PLAINTEXT,PLAINTEXT_HOST:PLAINTEXT
  

• 同步更新Kafka Service，将容器的9093端口暴露为NodePort 30092。

3. 测试本地端口连通性 #

• 先在本地执行nc -zv localhost 30092或telnet localhost 30092，验证端口是否能正常连通：
  • 若连不通，检查本地防火墙是否拦截该端口，或K8s节点的端口转发规则是否生效；
  • 若能连通但仍报错，进入Kafka Pod内部执行kafka-topics.sh --list --bootstrap-server localhost:9092，确认集群内部运行正常，排除Kafka服务本身的问题。

4. 检查Offset Explorer连接配置 #

• 确认bootstrap server填写localhost:30092，且未勾选SSL选项（除非你已配置Kafka SSL加密）；
• 协议选择PLAINTEXT，与Kafka的listener配置保持一致。

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