我正试图发送Kafka的请求 kafka-node
在 NodeJS
. 下面是我的代码,它提供了一个 BrokerNotAvailableError: Broker not available
发送请求时出错。而且好像制作人没有开机,因为没有留言。我用python试过kafka服务器,很好。我错过什么了吗?谢谢
代码:
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);
});
暂无答案!
目前还没有任何答案,快来回答吧!