diff --git a/src/helpers/kafkaUtil.js b/src/helpers/kafkaUtil.js
index 9bcad9bdde8af6daab8a1f16a4df4a0b7d47ebdf..6a64ef2ae323cc40fccee58603665bb67be0c3dd 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: "15.2.1.7:9092",
   maxAsyncRequests: 100
 })
 
diff --git a/src/service/kafkaQumlConsumerService.js b/src/service/kafkaQumlConsumerService.js
index ad76a826ecefc7bf9bceeb705a27af6850204da7..4e49cef5295ca888b597ea3558939cff40e7f4d6 100644
--- a/src/service/kafkaQumlConsumerService.js
+++ b/src/service/kafkaQumlConsumerService.js
@@ -26,7 +26,6 @@ const API_URL = {
   QUESTION_PUBLISH: "/question/v4/publish/",
   QUESTION_UPDATE: "/question/v4/update/",
   QUESTIONSET_ADD: "/questionset/v4/add",
-  
 }
 const rspObj = {};
 
@@ -35,7 +34,7 @@ const qumlConsumer = () => {
     Consumer = kafka.Consumer;
     ConsumerGroup = kafka.ConsumerGroup;
     client = new kafka.KafkaClient({
-      kafkaHost: envVariables.SUNBIRD_KAFKA_HOST,
+      kafkaHost: "15.2.1.7:9092",
     });
     payload = [
       {
@@ -45,7 +44,7 @@ const qumlConsumer = () => {
     ];
 
     var options = {
-      kafkaHost: envVariables.SUNBIRD_KAFKA_HOST,
+      kafkaHost: "15.2.1.7:9092",
       groupId: envVariables.SUNBIRD_KAFKA_BULKUPLOAD_CONSUMER_GROUP_ID,
       fromOffset: "latest",
     };