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

创建了一个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);
});
});

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