From 5362060ad21d4ad6eb30c628cbac5f5cf1c9a643 Mon Sep 17 00:00:00 2001
From: Vaibhav Bhuva <vaibhav.bhuva@tarento.com>
Date: Fri, 12 Nov 2021 11:47:04 +0530
Subject: [PATCH] Issue #SB-23374 fix : Added dock kafka host
---
src/envVariables.js | 1 +
src/helpers/kafkaUtil.js | 2 +-
src/service/kafkaQumlConsumerService.js | 4 ++--
3 files changed, 4 insertions(+), 3 deletions(-)
diff --git a/src/envVariables.js b/src/envVariables.js
index f87bf72..b6211be 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 9bcad9b..9e7381e 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 34a5951..282d55e 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",
};
--
GitLab