Я пытаюсь отправить запрос кафки по 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);
});