var express = require('express'),
    app = express(),
    kafka = require('kafka-node'),
    Producer = kafka.Producer,
    client = new kafka.Client('localhost:2181/'),
    producer = new Producer(client),
    bodyParser = require('body-parser');

// create application/json parser
var jsonParser = bodyParser.json()

app.post('/kafka', jsonParser, function (req, res) {
    console.log('From outside:');
    console.log(req.body);
    payloads = [
        { topic: 'node_kafka_test', messages: req.body}
    ];
    producer.on('ready', function () {
        producer.send(payloads, function (err, data) {
            console.log('From inside:');
            console.log(data);
        });
    });
});

app.listen(3000, function () {
  console.log('Example app listening on port 3000!');
});