-
Notifications
You must be signed in to change notification settings - Fork 9
/
kafka_producer.js
37 lines (30 loc) · 1.02 KB
/
kafka_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
35
36
37
var kafka = require('kafka-node'),
HighLevelProducer = kafka.HighLevelProducer,
client = new kafka.Client(),
producer = new HighLevelProducer(client);
module.exports = function(chatServer) {
producer.on('ready', function () {
chatServer.on('sendMessage', function (message) {
var messageString = JSON.stringify(message);
console.log('Sending message ' + messageString );
var kafkaMessage = {
topic: 'chatmessages',
messages : messageString
};
producer.send([kafkaMessage], function (err, data) {
if(err) {
console.log('Error sending data ' + err);
}
});
});
});
return {
close : function() {
console.log('Shutting down producer');
console.log('Shutting down producer client');
client.close(function() {
console.log('Producer client closed');
});
}
};
};