A kafka client in nodejs.

kafkaClient.js

'use strict';

const uuidv4 = require('uuid/v4');

const kafka = require('kafka-node'),
  Producer = kafka.Producer,
  client = new kafka.KafkaClient({kafkaHost: 'KAFKA_HOST_HERE'}),
  producer = new Producer(client);

producer.on("ready", function () {
    console.log("Kafka Producer is connected and ready.");
});

module.exports = function kafkaClient(scheduling, cb) {
    
    let _guid = uuidv4();
    
    producer.send([{topic: 'KAFKA_TOPIC_HERE', key: _guid, messages: scheduling}], function (err, data){
        if (err){
            console.log('error kafka: ', err);
            return cb(err, null);
        } else {
            return cb(null, data);
        }
    });
};