즉시 커밋을 위한 스프링 카프카 옵션 수정

f-lab-edu · Aug 31, 2024 · c281cd0 · c281cd0
1 parent d4c0ee8
commit c281cd0
Showing 1 changed file with 1 addition and 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
@@ -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;
     }