diff --git a/.env b/.env
index 991a031..105d671 100644
--- a/.env
+++ b/.env
@@ -1,3 +1,4 @@
 WRENCHJOB_PORT=3000
 WRENCHJOB_POSTGRE_URL='postgresql://wrenchboard:wrenchboard@10.20.30.60:5432/wrenchboard'
-WRENCHJOB_KAFKA_SERVER='10.10.10.120:9092'
+WRENCHJOB_KAFKA_BROKER01='10.10.10.120:9092'
+
diff --git a/app/kconfig.js b/app/kconfig.js
index 89c576f..7d92f2e 100644
--- a/app/kconfig.js
+++ b/app/kconfig.js
@@ -15,12 +15,14 @@ const kafka =  new Kafka({
 class KafkaConfig {
 
     constructor() {
+        console.log("kafkaBroker1  ******** ", kafkaBroker1);
         this.producer = kafka.producer();
         this.consumer = kafka.consumer({ groupId: "test-group" });
     }
 
     async produce(topic, messages) {
         try {
+            console.log("kafkaBroker1 ######### ", kafkaBroker1);
             await this.producer.connect();
             await this.producer.send({
                 topic: topic,