SvelteKit应用连接Kubernetes集群Kafka无响应，如何测试连接？

一、先排查网络连通性 #

• 在SvelteKit运行的环境（本地开发就用本地终端，部署在K8s里就进入应用Pod）用telnet或nc测试Kafka broker的端口是否能通：

  # 替换为你的Kafka broker外部地址和端口（通常是9092或NodePort/LoadBalancer端口）
  telnet <kafka-broker-ip/hostname> <port>
  # 或者用nc更直观
  nc -zv <kafka-broker-ip/hostname> <port>
  

  如果连不上，直接是网络问题：要么是K8s的Kafka没正确暴露外部访问，要么是防火墙、网络策略挡了流量，先把这层打通。
• 本地开发的话，务必确认Kafka集群配置了外部监听器，监听器地址是集群的公网IP/域名，不是内部Service名——本地解析不了K8s内部的Service地址。

二、用Kafka官方工具直接验证 #

• 本地装了Kafka客户端的话，用kafka-console-producer.sh和kafka-console-consumer.sh在应用环境测试收发：

  # 生产消息，替换broker地址和你的主题名
  kafka-console-producer.sh --broker-list <kafka-broker-ip:port> --topic <your-target-topic>
  # 输入消息回车发送
  
  # 消费消息，同样替换参数
  kafka-console-consumer.sh --bootstrap-server <kafka-broker-ip:port> --topic <your-target-topic> --from-beginning
  

  如果工具也连不上，说明问题不在SvelteKit代码，是Kafka集群的配置或网络问题；如果工具能正常收发，再回头查代码。

三、代码层面的细节排查 #

• 核对kafka.js里的brokers配置：必须是Kafka对外暴露的地址，不能用K8s内部的Service名称（本地访问不到）。
• 主题名字严格检查：Kafka主题名大小写敏感，别拼错、别多空格。
• 开启Kafka客户端的debug日志（以kafkajs为例）：能看到连接过程的详细日志，判断是连不上broker，还是找不到主题：

  const { Kafka, logLevel } = require('kafkajs')
  
  const kafka = new Kafka({
    clientId: 'sveltekit-app',
    brokers: ['<kafka-broker-ip:port>'],
    logLevel: logLevel.DEBUG // 开启debug级日志
  })
  

四、如果应用部署在K8s集群内 #

• 进入应用Pod执行nslookup <kafka-service-name>，确认能解析到Kafka Service的IP，排除DNS问题。
• 检查K8s的NetworkPolicy：有没有规则阻止应用Pod访问Kafka的Service端口，有的话要放开。
• 查看Kafka broker的Pod日志，有没有拒绝连接、主题不存在之类的错误信息。

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