/*
* node-rdkafka - Node.js wrapper for RdKafka C/C++ library
*
* Copyright (c) 2016 Blizzard Entertainment
*
* This software may be modified and distributed under the terms
* of the MIT license. See the LICENSE.txt file for details.
*/
var Kafka = require('../');
var producer = new Kafka.Producer({
'metadata.broker.list': 'localhost:9092',
'client.id': 'hey',
'compression.codec': 'snappy'
});
producer.connect()
.on('ready', function(i, metadata) {
console.log(i);
console.log(metadata);
})
.on('event.error', function(err) {
console.log(err);
});