chore 🔧: Changes for kubernetes

Author: ad1822

1-order-service/src/kafka/inventory-failed-consumer.ts

@@ -1,9 +1,13 @@
+import dotenv from 'dotenv';
 import { Consumer, Kafka } from 'kafkajs';
 import pool from '../db.js';
+dotenv.config();
 
 const kafka: Kafka = new Kafka({
   clientId: 'order-inventory-failed-consumer',
-  brokers: ['kafka:9092'],
+  brokers: [
+    process.env.KAFKA_BOOTSTRAP_SERVERS || 'kafka.kafka.svc.cluster.local:9092',
+  ],
 });
 
 export const consumer: Consumer = kafka.consumer({

1-order-service/src/kafka/payment-consumer.ts

@@ -1,9 +1,13 @@
+import dotenv from 'dotenv';
 import { Consumer, Kafka } from 'kafkajs';
 import pool from '../db.js';
+dotenv.config();
 
 const kafka = new Kafka({
   clientId: 'order-service-payment-consumer',
-  brokers: ['kafka:9092'],
+  brokers: [
+    process.env.KAFKA_BOOTSTRAP_SERVERS || 'kafka.kafka.svc.cluster.local:9092',
+  ],
 });
 
 export const consumer: Consumer = kafka.consumer({

1-order-service/src/kafka/producer.ts

@@ -1,8 +1,12 @@
+import dotenv from 'dotenv';
 import { Kafka, Producer } from 'kafkajs';
+dotenv.config();
 
 const kafka: Kafka = new Kafka({
   clientId: 'order-service-order-created-producer',
-  brokers: ['kafka:9092'],
+  brokers: [
+    process.env.KAFKA_BOOTSTRAP_SERVERS || 'kafka.kafka.svc.cluster.local:9092',
+  ],
 });
 
 export const producer: Producer = kafka.producer();

1-order-service/src/kafka/topic.ts

@@ -1,8 +1,12 @@
+import dotenv from 'dotenv';
 import { Admin, Kafka } from 'kafkajs';
+dotenv.config();
 
 const kafka: Kafka = new Kafka({
   clientId: 'order-service',
-  brokers: ['kafka:9092'],
+  brokers: [
+    process.env.KAFKA_BOOTSTRAP_SERVERS || 'kafka.kafka.svc.cluster.local:9092',
+  ],
 });
 
 export async function createTopics(topics: string[]): Promise<void> {

2-inventory-service/src/kafka/order-consumer.ts

@@ -7,7 +7,9 @@ dotenv.config();
 // Kafka setup
 const kafka = new Kafka({
   clientId: 'inventory-service',
-  brokers: ['kafka:9092'],
+  brokers: [
+    process.env.KAFKA_BOOTSTRAP_SERVERS || 'kafka.kafka.svc.cluster.local:9092',
+  ],
 });
 
 const consumer = kafka.consumer({ groupId: 'inventory-group' });

2-inventory-service/src/kafka/topic.ts

@@ -2,7 +2,9 @@ import { Admin, Kafka } from 'kafkajs';
 
 const kafka: Kafka = new Kafka({
   clientId: 'inventory-service',
-  brokers: ['kafka:9092'],
+  brokers: [
+    process.env.KAFKA_BOOTSTRAP_SERVERS || 'kafka.kafka.svc.cluster.local:9092',
+  ],
 });
 
 export async function createTopics(topics: string[]): Promise<void> {

3-payment-service/src/kafka/inventory-consumer.ts

@@ -3,7 +3,9 @@ import { producer } from './producer.js';
 
 const kafka = new Kafka({
   clientId: 'order-service-inventory-consumer',
-  brokers: ['kafka:9092'],
+  brokers: [
+    process.env.KAFKA_BOOTSTRAP_SERVERS || 'kafka.kafka.svc.cluster.local:9092',
+  ],
 });
 
 const consumer = kafka.consumer({ groupId: 'order-inventory-group' });

3-payment-service/src/kafka/payment-consumer.ts

@@ -7,7 +7,9 @@ dotenv.config();
 
 const kafka = new Kafka({
   clientId: 'payment-service-payment-generated-consumer',
-  brokers: ['kafka:9092'],
+  brokers: [
+    process.env.KAFKA_BOOTSTRAP_SERVERS || 'kafka.kafka.svc.cluster.local:9092',
+  ],
 });
 
 export const consumer: Consumer = kafka.consumer({

3-payment-service/src/kafka/producer.ts

@@ -2,7 +2,9 @@ import { Kafka, Producer } from 'kafkajs';
 
 const kafka: Kafka = new Kafka({
   clientId: 'payment-service-payment-created-producer',
-  brokers: ['kafka:9092'],
+  brokers: [
+    process.env.KAFKA_BOOTSTRAP_SERVERS || 'kafka.kafka.svc.cluster.local:9092',
+  ],
 });
 
 export const producer: Producer = kafka.producer();

3-payment-service/src/kafka/topic.ts

@@ -2,7 +2,9 @@ import { Admin, Kafka } from 'kafkajs';
 
 const kafka: Kafka = new Kafka({
   clientId: 'payment-service',
-  brokers: ['kafka:9092'],
+  brokers: [
+    process.env.KAFKA_BOOTSTRAP_SERVERS || 'kafka.kafka.svc.cluster.local:9092',
+  ],
 });
 
 export async function createTopics(topics: string[]): Promise<void> {