ayn*_*iam 5 node.js apache-kafka
我正在使用kafka-node npm模块,0.2.27版本。
我发现producer.on('ready',fn(){})永远都不会打电话。
在检查了生产者对象时,观察到如下
{ ready: true,
client:
{ connectionString: '10.196.160.100.:2181,10.196.160.150:2181,10.196.160.151:2181',
clientId: 'dev',
zkOptions: { sessionTimeOut: 10000, spinDelay: 1000, retries: 10 },
brokers:
{ 'custom-kafka.mine.com:9092': [Object],
'custom-storm.mine.com:9092': [Object] },
longpollingBrokers: {},
topicMetadata: {},
topicPartitions: {},
correlationId: 0,
cbqueue: {},
brokerMetadata: { '0': [Object], '1': [Object] },
ready: true,
zk: { client: [Object], _events: [Object], inited: true },
_events: { ready: [Object], error: [Object], close: [Object] } },
requireAcks: 1,
ackTimeoutMs: 100,
_events: {} }
Run Code Online (Sandbox Code Playgroud)
无需等待事件(“就绪”),我只需检查一下if(producer.ready),就能稍稍超时将其发布到kafka。
理想情况下,应该触发事件。
我不确定我是否采用正确的方法。
对此方向的任何指针将不胜感激。
提前致谢
尝试以下代码:
var kafka = require('kafka-node'),
Producer = kafka.Producer,
client = new kafka.Client('192.168.50.252:2181'),
producer = new Producer(client),
payloads = [
{
topic: 'test topic',
messages: ['test message']
}
];
client.on('ready', function (){
console.log('client ready');
})
client.on('error', function (err){
console.log('client error: ' + err);
})
producer.on('ready', function () {
producer.send(payloads, function (err, data) {
console.log('send: ' + data);
process.exit();
});
});
producer.on('error', function (err) {
console.log('error: ' + err);
process.exit();
});
Run Code Online (Sandbox Code Playgroud)
| 归档时间: |
|
| 查看次数: |
3486 次 |
| 最近记录: |