KafkaJS连接Kafka Broker失败报错，寻求解决方法

刚看完你的问题，这几个报错其实都是围绕DNS解析失败衍生出来的，咱们一步步来解决：

你代码里写的brokers: ['kafka1:9092', 'kafka2:9092']，但你的本地机器根本找不到这两个主机名对应的IP地址，这是连接失败的根源。根据你的Kafka部署场景，选对应的解决方法：

• 本地单机跑Kafka：直接把broker地址改成localhost:9092（Kafka默认端口），修改后配置如下：

  const kafka = new Kafka({
    clientId: 'my-app',
    brokers: ['localhost:9092'], // 替换成正确的本地地址
    logLevel: logLevel.ERROR,
  });
  

• Kafka在Docker容器里运行：
  • 方案一：用容器的实际IP代替主机名，你可以通过docker inspect <你的Kafka容器ID>命令查到容器IP，然后填进去；
  • 方案二：修改本地hosts文件，把kafka1/kafka2映射到宿主机器IP（或者容器IP）：
    • Windows路径：C:\Windows\System32\drivers\etc\hosts
    • Linux/macOS路径：/etc/hosts
      添加两行内容：

    127.0.0.1 kafka1
    127.0.0.1 kafka2
    

• Kafka是远程集群：先在你的机器上ping一下kafka1/kafka2，如果ping不通，找运维确认网络权限、DNS服务器配置是否正确，或者直接换成集群的内网/公网IP地址。

解决DNS问题后，还可以调整配置减少连接超时的概率：

const kafka = new Kafka({
  clientId: 'my-app',
  brokers: ['localhost:9092'], // 已修正的地址
  logLevel: logLevel.ERROR,
  connectionTimeout: 30000, // 把超时时间从默认10秒改成30秒
  retry: {
    initialRetryTime: 100,
    retries: 5 // 保留默认重试次数，也可以根据实际情况增加
  }
});

你的代码没有异常捕获逻辑，一旦连接或发送失败就会抛出未处理的Promise拒绝。给run()函数加上完整的错误处理：

const run = async () => {
  const producer = kafka.producer();
  try {
    await producer.connect();
    console.log('生产者连接成功');
    
    await producer.send({
      topic: 'test-topic',
      messages: [{ value: 'Hello KafkaJS user!' }],
    });
    console.log('消息发送成功');
  } catch (error) {
    console.error('操作失败:', error);
  } finally {
    // 无论成功失败，都确保断开连接
    await producer.disconnect();
    console.log('生产者已断开连接');
  }
};

// 捕获顶层的Promise异常
run().catch(error => console.error('程序执行出错:', error));

• 先确认Kafka服务正常：用Kafka自带的命令行工具检查topic是否存在（替换成你的broker地址）：

  kafka-topics.sh --list --bootstrap-server localhost:9092
  

  如果test-topic不存在，要么手动创建它，要么在初始化生产者时开启自动创建topic（生产环境不建议这么做）：

  const producer = kafka.producer({ allowAutoTopicCreation: true });
  

• 检查防火墙：确认你的机器和Kafka集群之间的9092端口没有被防火墙、安全组拦截。

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