forked from firebase007/kafka_producer_consumer_tutorial
-
Notifications
You must be signed in to change notification settings - Fork 0
/
producer.js
34 lines (24 loc) · 786 Bytes
/
producer.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
34
const Kafka = require('kafka-node');
const config = require('./config');
const Producer = Kafka.Producer;
const client = new Kafka.KafkaClient({kafkaHost: config.KafkaHost});
const producer = new Producer(client, {requireAcks: 0, partitionerType: 2});
const pushDataToKafka =(dataToPush) => {
try {
let payloadToKafkaTopic = [{topic: config.KafkaTopic, messages: JSON.stringify(dataToPush) }];
console.log(payloadToKafkaTopic);
producer.on('ready', async function() {
producer.send(payloadToKafkaTopic, (err, data) => {
console.log('data: ', data);
});
producer.on('error', function(err) {
// handle error cases here
})
})
}
catch(error) {
console.log(error);
}
};
const jsonData = require('./app_json.js');
pushDataToKafka(jsonData);