Commit 0b5170fa authored by Vaibhav's avatar Vaibhav
Browse files

Issue #SB-000 fix: kafka ip change

Showing with 3 additions and 3 deletions
+3 -3
......@@ -4,7 +4,7 @@ var logger = require('sb_logger_util_v2')
const envVariables = require("../envVariables");
const client = new kafka.KafkaClient({
kafkaHost: "15.2.1.7:9092",
kafkaHost: envVariables.SUNBIRD_KAFKA_HOST,
maxAsyncRequests: 100
})
......
......@@ -34,7 +34,7 @@ const qumlConsumer = () => {
Consumer = kafka.Consumer;
ConsumerGroup = kafka.ConsumerGroup;
client = new kafka.KafkaClient({
kafkaHost: "15.2.1.7:9092",
kafkaHost: envVariables.SUNBIRD_KAFKA_HOST,
});
payload = [
{
......@@ -44,7 +44,7 @@ const qumlConsumer = () => {
];
var options = {
kafkaHost: "15.2.1.7:9092",
kafkaHost: envVariables.SUNBIRD_KAFKA_HOST,
groupId: envVariables.SUNBIRD_KAFKA_BULKUPLOAD_CONSUMER_GROUP_ID,
fromOffset: "latest",
};
......
Supports Markdown
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment