Vaibhav Bansal vaibhav93

vaibhav93 / consumer.js

Created June 8, 2018 20:41 — forked from shubhi1407/consumer.js

	var Kafka = require('node-rdkafka');
	var producer = require('./producer');

	var consumer = new Kafka.KafkaConsumer({
	//'debug': 'all',
	'metadata.broker.list': 'gc-mskafka1002.pp-devqa-ms-thirdparty.us-central1.gcp.dev.paypalinc.com:9092',
	'group.id': 'node-rdkafka-consumer-flow-example',
	'enable.auto.commit': false,
	'socket.keepalive.enable': true,
	'reconnect.backoff.jitter.ms': 500