Производитель Kafka BrokerNotAvaliableError в Javascript - PullRequest
0 голосов
/ 04 августа 2020

Я пытаюсь отправить запрос кафки по kafka-node на NodeJS. Ниже мой код, и когда я отправляю запрос, появляется ошибка BrokerNotAvailableError: Broker not available. И кажется, что продюсера нет, так как сообщения не напечатано. Я пробовал сервер kafka python и хорошо. Я что-то упускаю? Спасибо

Код:

var kafka = require('kafka-node');
var producer_client = new kafka.Client(producer_kafka_server);
var producer = new kafka.Producer(producer_client);
producer.on('ready', function(){
    condole.log('kafka producer is ready...') //not message is printed
})

var payloads = [{ topic: producer_topic, messages: message, partitions: 0, attributes: 0 }, ];
                producer.send(payloads, function (err, data) {
                    if (err != null)
                        logger.error(err);
                });
...