vaibhav93

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