var kafka = require('kafka-node');


var Consumer = kafka.Consumer;
var client = new kafka.Client(config.kafka.connectionString);

    var consumer = new Consumer(client, topics)
        .on('message', function (message) {
            console.log(message);
        }).on('error', function (err) {
            console.log('consumer: ' + err);
        });

    var Producer = kafka.Producer;
    var producer = new Producer(client, {requireAcks: 1});

 producer.on('ready', function () {
        var payloads = [
            {topic: 'lol_rawData', messages: 'hi', partition: 0},
            {topic: 'dota2_rawData', messages: dota2, partition: 0}
        ];

            producer.send(payloads, function (err, data) {
                console.log(data);
            });


    });