bug fix

Author: Javedmv

manifest/deployments/kafka.yaml

@@ -15,28 +15,38 @@ spec:
         app: kafka
     spec:
       containers:
-        - name: kafka
-          image: bitnami/kafka:latest
-          ports:
-            - containerPort: 9092
-              name: plaintext
-          env:
-            - name: KAFKA_CFG_ZOOKEEPER_CONNECT
-              value: "zookeeper:2181"
-            - name: ALLOW_PLAINTEXT_LISTENER
-              value: "yes"
-            - name: KAFKA_CFG_LISTENERS
-              value: "PLAINTEXT://:9092"
-            - name: KAFKA_CFG_ADVERTISED_LISTENERS
-              value: "PLAINTEXT://kafka:9092"
-            - name: KAFKA_CFG_LISTENER_SECURITY_PROTOCOL_MAP
-              value: "PLAINTEXT:PLAINTEXT"
-            - name: KAFKA_CFG_INTER_BROKER_LISTENER_NAME
-              value: "PLAINTEXT"
-            - name: KAFKA_CFG_OFFSETS_TOPIC_REPLICATION_FACTOR
-              value: "1"
-            - name: KAFKA_CFG_AUTO_CREATE_TOPICS_ENABLE
-              value: "true"
+      - name: kafka
+        image: bitnami/kafka:latest
+        ports:
+        - containerPort: 9092
+          name: plaintext
+        - containerPort: 9093
+          name: controller
+        env:
+        - name: ALLOW_PLAINTEXT_LISTENER
+          value: "yes"
+        - name: KAFKA_CFG_BROKER_ID
+          value: "1"
+        - name: KAFKA_CFG_NODE_ID
+          value: "1"  
+        - name: KAFKA_CFG_PROCESS_ROLES
+          value: "broker,controller"
+        - name: KAFKA_CFG_CONTROLLER_QUORUM_VOTERS
+          value: "1@kafka:9093"
+        - name: KAFKA_CFG_LISTENERS
+          value: "PLAINTEXT://:9092,CONTROLLER://:9093"
+        - name: KAFKA_CFG_ADVERTISED_LISTENERS
+          value: "PLAINTEXT://kafka:9092"
+        - name: KAFKA_CFG_LISTENER_SECURITY_PROTOCOL_MAP
+          value: "CONTROLLER:PLAINTEXT,PLAINTEXT:PLAINTEXT"
+        - name: KAFKA_CFG_CONTROLLER_LISTENER_NAMES
+          value: "CONTROLLER"
+        - name: KAFKA_CFG_INTER_BROKER_LISTENER_NAME
+          value: "PLAINTEXT"
+        - name: KAFKA_CFG_OFFSETS_TOPIC_REPLICATION_FACTOR
+          value: "1"
+        - name: KAFKA_CFG_AUTO_CREATE_TOPICS_ENABLE
+          value: "true"
 ---
 apiVersion: v1
 kind: Service
@@ -46,8 +56,11 @@ metadata:
     app: kafka
 spec:
   ports:
-    - port: 9092
-      targetPort: 9092
-      name: plaintext
+  - port: 9092
+    targetPort: 9092
+    name: plaintext
+  - port: 9093
+    targetPort: 9093
+    name: controller
   selector:
-    app: kafka
+    app: kafka

manifest/deployments/zookeeper.yaml

@@ -15,27 +15,14 @@ spec:
         app: zookeeper
     spec:
       containers:
-        - name: zookeeper
-          image: bitnami/zookeeper:latest
-          ports:
-            - containerPort: 2181
-          env:
-            - name: ZOOKEEPER_CLIENT_PORT
-              value: "2181"
-            - name: ZOOKEEPER_TICK_TIME
-              value: "2000"
-            - name: ALLOW_ANONYMOUS_LOGIN
-              value: "yes"
----
-apiVersion: v1
-kind: Service
-metadata:
-  name: zookeeper
-  labels:
-    app: zookeeper
-spec:
-  ports:
-    - port: 2181
-      targetPort: 2181
-  selector:
-    app: zookeeper
+      - name: zookeeper
+        image: bitnami/zookeeper:latest
+        ports:
+        - containerPort: 2181
+        env:
+        - name: ZOOKEEPER_CLIENT_PORT
+          value: "2181"
+        - name: ZOOKEEPER_TICK_TIME
+          value: "2000"
+        - name: ALLOW_ANONYMOUS_LOGIN
+          value: "yes"  # This line enables anonymous login

payment-srv/src/application/useCases/enrollStudentInCourseUseCase.ts

@@ -1,4 +1,3 @@
-import { producer } from "../../infrastructure/kafka";
 import { sendEnrollPaidUserProducer } from "../../infrastructure/kafka/producers";
 import { IDependencies } from "../interfaces/IDependencies";
 
@@ -8,7 +7,7 @@ export const enrollStudentInCourseUseCase = (dependencies: IDependencies) => {
         execute: async (userId: string, courseId: string) => {
             try {
                 const response = await enrollStudentInCourse(userId,courseId)
-                console.log("Enrolling student in course.... usecase", userId, courseId, 'and getting response :',response);
+                console.log("Enrolling student in course.... usecase","userID:=", userId,"COURSE ID =", courseId, 'and getting response :',response);
                 if(response){
                     await sendEnrollPaidUserProducer(userId,courseId,"course-srv-topic");
                     await sendEnrollPaidUserProducer(userId,courseId,"chat-srv-topic");

payment-srv/src/index.ts

@@ -7,7 +7,7 @@ import { producer } from './infrastructure/kafka';
     try {
         Server;
 
-        await Promise.all([connectDB(),producer.connect(), runConsumer()])
+        await Promise.all([connectDB(), runConsumer()])
         // TODO: disconnected the consumer reconnect it when needed
         .then(() => {
             console.log("kafka consumer is running")

payment-srv/src/presentation/controllers/createSessionController.ts

@@ -69,8 +69,8 @@ export const createSessionController = (dependencies: IDependencies) => {
                         quantity: 1,
                     },
                 ],
-                success_url: `${process.env.FRONTEND_URL}/payment/success/courseId=${course._id}`,
-                cancel_url: `${process.env.FRONTEND_URL}/payment/failed/courseId=${course._id}`,
+                success_url: `${process.env.FRONTEND_URL}/payment/success/courseId=${course?._id}`,
+                cancel_url: `${process.env.FRONTEND_URL}/payment/failed/courseId=${course?._id}`,
             });
 
             // **Update the session's metadata with the session ID**