gistfile1.txt

var kafkaHost="kafka.example.com:2181"

var kafka = require('kafka-node'),
    Producer = kafka.Producer,
    Consumer = kafka.Consumer,
    client = new kafka.Client(kafkaHost, "default_topic"),

    consumer = new Consumer(
        client,
        [
            { topic: process.argv[2], partition: 0 }
        ],
        {
            autoCommit: false
        }
    );

consumer.on('message', function (message) {
  console.log(message)
  //value = JSON.parse(message['value'])
  //console.log(value['body']);
});