javascript中的kafka producer brokernotavaliableerror

7xllpg7q  于 2021-06-04  发布在  Kafka
关注(0)|答案(0)|浏览(265)

我正试图发送Kafka的请求 kafka-nodeNodeJS . 下面是我的代码,它提供了一个 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);
                });

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题