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的了