Не удалось подключиться к посевному брокеру с помощью kafkajs

Question

Я пытаюсь использовать kafkajsчтобы создать потребителя кафки. Однако я уже получаю ошибку при подключении к кафке:

"[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"
      ]
})

Answer 2

Вы пытались использовать ' вместо того " для URL вашего брокера?