diff --git a/src/helpers/kafkaUtil.js b/src/helpers/kafkaUtil.js
index 2287704..98091d0 100644
--- 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(