kafka-node环境下producer的ready事件没有触发是什么原因

Question

创建了一个producer，触发ready事件后执行send发送消息，发送几条消息后，ready事件不再被触发，后续消息无法发送。请问是哪里出了问题？
代码如下：
producer.on('ready', function(err, result) {
console.log('kafka_server.send:ready ' + message);
console.log('err = ' + err);
console.log('result = ' + result);
console.log(err || result);
producer.send(payloads, function(err, data) {
console.log('producer.send:' + err)
if (err === null)
server_manager.tcc_server.netlog.info('Kafka send msg [%s] ok!', data.toString());
else
server_manager.tcc_server.netlog.info('Kafka send msg error : - %s', err);
});
});

Answer 1

http://blog.csdn.net/liangdong2014/article/details/53230072