Fix: Issues with kafka borkers

samagra-comms · Mar 28, 2022 · 30768c9 · 30768c9
1 parent f5093bc
commit 30768c9
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/src/helpers/kafkaUtil.js b/src/helpers/kafkaUtil.js
@@ -10,6 +10,7 @@ if (process.env.ENV === "dev") {
 } else {
   let brokers = process.env.KAFKA_HOST;
   if (process.env.KAFKA_HOST.includes(process.env.KAFKA_PORT)) {
+    broker = brokers.split(",");
     console.log("Kafka brokers have PORT");
   } else {
     brokers = process.env.KAFKA_HOST.split(",").map(