forked from firebase007/kafka_producer_consumer_tutorial
-
Notifications
You must be signed in to change notification settings - Fork 0
/
consumer.js
33 lines (31 loc) · 764 Bytes
/
consumer.js
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
const kafka = require('kafka-node');
const config = require('./config');
try {
const Consumer = kafka.Consumer;
const client = new kafka.KafkaClient({idleConnection: 24 * 60 * 60 * 1000, kafkaHost: config.KafkaHost});
let consumer = new Consumer(
client,
[{ topic: config.KafkaTopic, partition: 0 }],
{
autoCommit: true,
fetchMaxWaitMs: 1000,
fetchMaxBytes: 1024 * 1024,
encoding: 'utf8',
// fromOffset: false
}
);
consumer.on('message', async function(message) {
console.log(
'kafka ',
JSON.parse(message.value)
);
})
consumer.on('error', function(error) {
// handle error
console.log('error', error);
});
}
catch(error) {
// catch error trace
console.log(error);
}