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

Question

Я пытаюсь использовать kafkajs для создания потребителя кафки. Тем не менее, я уже получаю сообщение об ошибке при подключении к 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"
      ]
})

Answer 2

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