kafka clientId corrected

Author: Javedmv

chat-service/src/infrastructure/kafka/index.ts

@@ -8,7 +8,7 @@ import { Kafka, Producer, Partitioners, Consumer } from "kafkajs";
 
 // production
 const kafka = new Kafka({
-    clientId: "auth-service",
+    clientId: "chat-service",
     brokers: ["kafka:9092"],
     requestTimeout: 30000,
 })

course-srv/src/infrastructure/kafka/index.ts

@@ -8,7 +8,7 @@ import { Consumer, Kafka, Partitioners, Producer } from 'kafkajs';
 
 // production
 const kafka = new Kafka({
-    clientId: "auth-service",
+    clientId: "course-service",
     brokers: ["kafka:9092"],
     requestTimeout: 30000,
 })

notification-service/src/infrastructure/kafka/index.ts

@@ -8,7 +8,7 @@ import {Kafka , Producer, Consumer, Partitioners} from "kafkajs";
 
 // production
 const kafka = new Kafka({
-    clientId: "auth-service",
+    clientId: "notificaiton-service",
     brokers: ["kafka:9092"],
     requestTimeout: 30000,
 })

payment-srv/src/infrastructure/kafka/index.ts

@@ -8,7 +8,7 @@ import { Consumer, Kafka, Partitioners, Producer } from 'kafkajs';
 
 // production
 const kafka = new Kafka({
-    clientId: "auth-service",
+    clientId: "payment-service",
     brokers: ["kafka:9092"],
     requestTimeout: 30000,
 })