// https://github.com/SOHU-Co/kafka-node/
// https://www.npmjs.org/package/kafka-node

var kafka = require('kafka-node');
var HighLevelProducer = kafka.HighLevelProducer;
var Client = kafka.Client;
var client = new Client('localhost:2181');
var argv = require('optimist').argv;
var topic = argv.topic || 'mytopic';
var count = 3, rets = 0;
var producer = new HighLevelProducer(client);

producer.on('ready', function () {
    send('hello 1');
    setTimeout(function () {
        send('world 2');
        send('world 3');
    }, 2000);
});

function send(message) {
    producer.send([
        {topic: topic, messages: [message] }
    ], function (err, data) {
        if (err) console.log(arguments);
        if (++rets === count) process.exit();
    });
}