var kafka = require('../kafka-node')

var consumer = new kafka.Consumer({
	host:'localhost',
	port:9092,
	topic:'test',
	pollInterval: 1000
})

consumer.connect()
consumer.on('message', function(message) {
	console.log('Consumed message:', message, '\n')
})

var kafka = require('../kafka-node')

var consumer = new kafka.Consumer({
	host:'localhost',
	port:9092,
	topic:'test'
})

consumer.connect()
consumer.on('message', function(message) {
	console.log('Consumed message:', message, '\n')
})

Remove the pollInterval from the example - use the default 2000
Remove the pollInterval from the example - use the default 2000
