diff --git a/account-service/src/main/java/com/drinkool/services/ManagerService.java b/account-service/src/main/java/com/drinkool/services/ManagerService.java
index b769792..901c6ea 100644
--- a/account-service/src/main/java/com/drinkool/services/ManagerService.java
+++ b/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();
 	}
 
diff --git a/account-service/src/main/resources/application.properties b/account-service/src/main/resources/application.properties
index 0cea237..02c3ab3 100644
--- a/account-service/src/main/resources/application.properties
+++ b/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
diff --git a/eatery-service/src/main/resources/application.properties b/eatery-service/src/main/resources/application.properties
index 7f2fc0b..a5dd9a6 100644
--- a/eatery-service/src/main/resources/application.properties
+++ b/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
diff --git a/k8s/kafka.yaml b/k8s/kafka.yaml
index 6cc58bd..252a9dc 100644
--- a/k8s/kafka.yaml
+++ b/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"
\ No newline at end of file
+              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"
\ No newline at end of file