giving group id to group consumer

Author: Sachin Maheshwari

config/default.js

@@ -9,6 +9,11 @@ module.exports = {
   },
   RETRY_COUNTER: 3,
   KAFKA_REPOST_COUNT: 5,
+  KAFKA_URL: process.env.KAFKA_URL,
+  KAFKA_GROUP_ID: process.env.KAFKA_GROUP_ID || 'ifx-pg-consumer',
+  KAFKA_CLIENT_CERT: process.env.KAFKA_CLIENT_CERT ? process.env.KAFKA_CLIENT_CERT.replace('\\n', '\n') : null,
+  KAFKA_CLIENT_CERT_KEY: process.env.KAFKA_CLIENT_CERT_KEY ?
+    process.env.KAFKA_CLIENT_CERT_KEY.replace('\\n', '\n') : null,
   topic_error: {
     NAME: 'db.ifxpgmigrate.error',
     PARTITION: 0,

src/consumer.js

@@ -3,7 +3,16 @@ const Promise = require('bluebird');
 const config = require('config');
 const logger = require('./common/logger');
 const healthcheck = require('topcoder-healthcheck-dropin');
-const consumer = new Kafka.GroupConsumer();
+const options = {
+  groupId: config.KAFKA_GROUP_ID,
+  connectionString: config.KAFKA_URL,
+  ssl: {
+    cert: config.KAFKA_CLIENT_CERT,
+    key: config.KAFKA_CLIENT_CERT_KEY
+  }
+};
+
+const consumer = new Kafka.GroupConsumer(options);
 const {
   create_consumer_app_log,
   consumerpg_success_log,