Skip to content

Commit 18365f7

Browse files
authored
Merge pull request #22 from LGCNS-FINAL-LGCMS/LB-107/LevelTest
hotfix : 카프카 Acknowledgment 설정
2 parents e238270 + 972acbf commit 18365f7

File tree

1 file changed

+3
-1
lines changed

1 file changed

+3
-1
lines changed

src/main/java/com/lgcms/leveltest/event/consumer/CategoryConsumer.java

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -8,6 +8,7 @@
88
import lombok.RequiredArgsConstructor;
99
import lombok.extern.slf4j.Slf4j;
1010
import org.springframework.kafka.annotation.KafkaListener;
11+
import org.springframework.kafka.support.Acknowledgment;
1112
import org.springframework.stereotype.Service;
1213

1314
@Slf4j
@@ -19,8 +20,9 @@ public class CategoryConsumer {
1920
private final EmailService emailService;
2021

2122
@KafkaListener(topics = "CATEGORY")
22-
public void handleCategoryEvent(KafkaEvent<?> event) {
23+
public void handleCategoryEvent(KafkaEvent<?> event, Acknowledgment ack) {
2324
try {
25+
ack.acknowledge();
2426
log.info("카테고리 이벤트 수신: eventId={}, eventType={}",
2527
event.getEventId(), event.getEventType());
2628

0 commit comments

Comments
 (0)