Tag: 生产者 消费者

卡夫卡节点，消费者总是有旧信息

即时通讯使用模块kafka节点https://github.com/SOHU-Co/kafka-node 每次当我重新启动消费者，他们得到所有的旧消息，即时通讯使用循环系统（负载平衡） 你有什么想法我怎么能声明到服务器，我消费了一条消息，他不再给我重新启动消费者时，我呢？ 在我的代码或configuration服务器的一些错误？ 任何想法 ？ 生产者代码 var kafka = require('kafka-node'); var HighLevelProducer = kafka.HighLevelProducer; var Client = kafka.Client; var client = new Client('xxx.xxx.xxx.xxx:2181,xxx.xxx.xxx.xxx:2181,xxx.xxx.xxx.xxx:2181,xxx.xxx.xxx.xxx:2181,xxx.xxx.xxx.xxx:2181', 'consumer' + process.pid); var argv = require('optimist').argv; var topic = argv.topic || 'test_12345'; var producer = new HighLevelProducer(client); var time = process.hrtime(); var message, diff,i=0; producer.on('ready', function () { setInterval(function(){ var […]