kafka-node环境下，producer的ready的事件不执行

Question

使用nodeJS搭建的服务，通过接口获取数据，然后将数据发送到kafka中，但是producer的ready的事件不执行，程序也没有报错

这个时kafka模块

var kafka = require('kafka-node');  

var Producer=kafka.Producer;

var KeyedMessage = kafka.KeyedMessage;  

var client =new kafka.Client('139.129.231.31:9092');  

var topic='realtime_data';

var producer = new Producer(client, {  

    requireAcks: 1  

}); 

var kafkaWeather={

    kafkaProducer:function(args){

        producer.on('ready', function() {  

            console.log('kafka')

            args = {  

                dataId: 31,  

                dataValue: 34,  

                dataTime: new Date()

              };

            producer.send([{  

                topic: topic,  

                partition:1,  

                messages: [JSON.stringify(args)],  

                attributes: 0  

            }], function(err, result) {  

                console.log(err || result);  

                process.exit();  

            });   

        });  

    }

}

module.exports=kafkaWeather

再server中使用

程序没有报错，kafka中的ready也没有执行，是什么原因？求指教~~~

Answer 1

new client的参数应该填zookeeper的 你写成kafka的了