chore: update

account-service/src/main/java/com/drinkool/services/ManagerService.java

@@ -28,7 +28,7 @@ public class ManagerService {
 
 		newManager.signup(input.name, input.phone, input.password);
 
-		CompletionStage<Void> ack = managerEmitter.send(
+		managerEmitter.send(
 			new ManagerCreate() {
 				{
 					id = newManager.id;
@@ -40,7 +40,6 @@ public class ManagerService {
 		return Response.status(Response.Status.CREATED)
 			.header(InternalValue.userId, newManager.id.toString())
 			.header(InternalValue.role, Role.Manager)
-			.entity(ack)
 			.build();
 	}
 

account-service/src/main/resources/application.properties

@@ -29,8 +29,7 @@ quarkus.native.remote-container-build=true
 quarkus.native.additional-build-args=--initialize-at-run-time=com.password4j.AlgorithmFinder,--future-defaults=all
 quarkus.native.resources.includes=com/google/i18n/phonenumbers/data/**/*
 
-# Kafka
-quarkus.kafka.bootstrap-servers=${KAFKA_SERVICE_SERVICE_HOST:host.docker.internal}:9092 
+# Kafka=${KAFKA_SERVICE_SERVICE_HOST:host.docker.internal}:9092
 
 ## Create restaurant topic
 mp.messaging.outgoing.manager-out.connector=smallrye-kafka

eatery-service/src/main/resources/application.properties

@@ -27,7 +27,7 @@ quarkus.native.remote-container-build=true
 quarkus.native.additional-build-args=--future-defaults=all
 
 # Kafka
-quarkus.kafka.bootstrap-server=${KAFKA_SERVICE_SERVICE_HOST:host.docker.internal}:9092
+mp.messaging.connector.smallrye-kafka.bootstrap.servers=${KAFKA_SERVICE_SERVICE_HOST:host.docker.internal}:9092
 
 ## Create restaurant topic
 mp.messaging.incoming.manager-in.connector=smallrye-kafka

k8s/kafka.yaml

@@ -34,11 +34,20 @@ spec:
               value: "broker,controller"
             - name: KAFKA_LISTENERS
               value: "PLAINTEXT://:9092,CONTROLLER://:9093"
+            # Sửa lại thành tên Service đầy đủ để đảm bảo thông suốt
             - name: KAFKA_ADVERTISED_LISTENERS
               value: "PLAINTEXT://kafka-service:9092"
+            # Đổi localhost thành tên service hoặc dùng 0.0.0.0
             - name: KAFKA_CONTROLLER_QUORUM_VOTERS
-              value: "1@localhost:9093"
+              value: "1@kafka-service:9093"
             - name: KAFKA_CONTROLLER_LISTENER_NAMES
               value: "CONTROLLER"
             - name: KAFKA_LISTENER_SECURITY_PROTOCOL_MAP
-              value: "CONTROLLER:PLAINTEXT,PLAINTEXT:PLAINTEXT"
+              value: "CONTROLLER:PLAINTEXT,PLAINTEXT:PLAINTEXT"
+            # THÊM 2 DÒNG NÀY ĐỂ CHẠY 1 NODE ỔN ĐỊNH
+            - name: KAFKA_OFFSETS_TOPIC_REPLICATION_FACTOR
+              value: "1"
+            - name: KAFKA_TRANSACTION_STATE_LOG_REPLICATION_FACTOR
+              value: "1"
+            - name: KAFKA_TRANSACTION_STATE_LOG_MIN_ISR
+              value: "1"