npm kafka-node
const kafka = require('kafka-node')
client1 = new kafka.KafkaClient({kafkaHost: '192.168.0.217:9092'}),
offset1 = new kafka.Offset(client1);
Consumer = kafka.Consumer
var list1 =[]
var obj = {}
offset1.fetch([
{ topic: 'sign_exception', partition: 0, time: Date.now(), maxNum: 1 }
], function (err, data) {
// data
console.log(data)
// { 't': { '0': [999] } }
consumer = new Consumer(
client1,
[
{ topic: 'sign_exception', partition: 0,offset: data.sign_exception['0']+1, },
],
{
autoCommit: false,
fromOffset: true,
}
);
consumer.on('message', function (message) {
list1.push(message)
});
consumer.on('error', function (err) {
console.log(err)
})
});
//数据返回前端
app.get("/news1",function(req,res){
res.send(list1);
})
