From c281cd0d38b05a6cb17aea34df20e4d9ddff141d Mon Sep 17 00:00:00 2001
From: "khb6997@gmail.com" <khb6997@gmail.com>
Date: Sat, 31 Aug 2024 22:27:57 +0900
Subject: [PATCH] =?UTF-8?q?=EC=A6=89=EC=8B=9C=20=EC=BB=A4=EB=B0=8B?=
 =?UTF-8?q?=EC=9D=84=20=EC=9C=84=ED=95=9C=20=EC=8A=A4=ED=94=84=EB=A7=81=20?=
 =?UTF-8?q?=EC=B9=B4=ED=94=84=EC=B9=B4=20=EC=98=B5=EC=85=98=20=EC=88=98?=
 =?UTF-8?q?=EC=A0=95?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../kong/paymentservice/common/config/KafkaConsumerConfig.java  | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/payment-service/src/main/java/me/kong/paymentservice/common/config/KafkaConsumerConfig.java b/payment-service/src/main/java/me/kong/paymentservice/common/config/KafkaConsumerConfig.java
index d58321b..b88d02a 100644
--- a/payment-service/src/main/java/me/kong/paymentservice/common/config/KafkaConsumerConfig.java
+++ b/payment-service/src/main/java/me/kong/paymentservice/common/config/KafkaConsumerConfig.java
@@ -64,7 +64,7 @@ public ConsumerFactory<String, GroupMemberIncreaseRequestDto> groupIncreaseConsu
     public ConcurrentKafkaListenerContainerFactory<String, GroupMemberIncreaseRequestDto> groupIncreaseKafkaListenerContainerFactory() {
         ConcurrentKafkaListenerContainerFactory<String, GroupMemberIncreaseRequestDto> factory = new ConcurrentKafkaListenerContainerFactory<>();
         factory.setConsumerFactory(groupIncreaseConsumerFactory());
-        factory.getContainerProperties().setAckMode(ContainerProperties.AckMode.MANUAL);
+        factory.getContainerProperties().setAckMode(ContainerProperties.AckMode.MANUAL_IMMEDIATE);
 
         return factory;
     }