无法使用 kafkajs 连接到种子代理

Question

我正在尝试使用 kafkajs 来创建一个 kafka 消费者。但是，我在连接到 kafka 时已经出现错误：

"[BrokerPool] Failed to connect to seed broker, trying another broker from the list: Closed connection"

这是我使用的代码：

const { Kafka } = require('kafkajs')

const kafka = new Kafka({
  clientId: 'my-app',
  brokers: [
      "abc123f.xyz.cde.net:9094",
      "abc123h.xyz.cde.net:9094",
      "abc123k.xyz.cde.net:9094"
      ]
})

有谁知道为什么会发生此错误或如何解决它？

Answer 1

最后是缺少的ssl: true参数。解决方案如下：

const { Kafka } = require('kafkajs')

const kafka = new Kafka({
  clientId: 'my-app',
  ssl: true,
  brokers: [
      "abc123f.xyz.cde.net:9094",
      "abc123h.xyz.cde.net:9094",
      "abc123k.xyz.cde.net:9094"
      ]
})

无法使用 kafkajs 连接到种子代理

Failed to connect to seed broker with kafkajs

node.js

apache-kafka

kafkajs