diff --git a/src/envVariables.js b/src/envVariables.js index f87bf727d4041962f3fdf753682dbc28de8b3745..b6211be3cb858ef7da7bcb1de06f36e0a79c67ca 100644 --- a/src/envVariables.js +++ b/src/envVariables.js @@ -11,6 +11,7 @@ const envVariables = { CONTENT_SERVICE_URL: process.env.content_service_url || 'https://dock.sunbirded.org/action/', OPENSABER_SERVICE_URL: process.env.opensaber_service_url || 'https://dock.sunbirded.org/content/reg', SUNBIRD_KAFKA_HOST: process.env.sunbird_kafka_host, + DOCK_KAFKA_HOST: process.env.dock_kafka_host, DOCK_REDIS_HOST: process.env.dock_redis_host, DOCK_REDIS_PORT: process.env.dock_redis_port || 6379, SUNBIRD_AUTO_CREATION_TOPIC: process.env.sunbird_auto_creation_topic, diff --git a/src/helpers/kafkaUtil.js b/src/helpers/kafkaUtil.js index 9bcad9bdde8af6daab8a1f16a4df4a0b7d47ebdf..9e7381ee028d26be127ef75efd6967ee91e074c4 100644 --- a/src/helpers/kafkaUtil.js +++ b/src/helpers/kafkaUtil.js @@ -4,7 +4,7 @@ var logger = require('sb_logger_util_v2') const envVariables = require("../envVariables"); const client = new kafka.KafkaClient({ - kafkaHost: envVariables.SUNBIRD_KAFKA_HOST, + kafkaHost: envVariables.DOCK_KAFKA_HOST, maxAsyncRequests: 100 }) diff --git a/src/service/kafkaQumlConsumerService.js b/src/service/kafkaQumlConsumerService.js index 34a5951e5381f75f4eac287f82b5eb6252ec2c6f..282d55e04b6d07545be5350ed74d607d4b372d0f 100644 --- a/src/service/kafkaQumlConsumerService.js +++ b/src/service/kafkaQumlConsumerService.js @@ -34,7 +34,7 @@ const qumlConsumer = () => { Consumer = kafka.Consumer; ConsumerGroup = kafka.ConsumerGroup; client = new kafka.KafkaClient({ - kafkaHost: envVariables.SUNBIRD_KAFKA_HOST, + kafkaHost: envVariables.DOCK_KAFKA_HOST, }); payload = [ { @@ -44,7 +44,7 @@ const qumlConsumer = () => { ]; var options = { - kafkaHost: envVariables.SUNBIRD_KAFKA_HOST, + kafkaHost: envVariables.DOCK_KAFKA_HOST, groupId: envVariables.SUNBIRD_KAFKA_BULKUPLOAD_CONSUMER_GROUP_ID, fromOffset: "latest", };