Skip to content

Commit 91e7b8c

Browse files
committed
chore: Kafka 프로듀서 멱등성 설정 및 설정 정리
- Kafka 설정에 enable.idempotence=true 및 acks=all 프로듀서 옵션 추가 - OutboxService에서 사용하지 않는 import 제거
1 parent 72d81d9 commit 91e7b8c

2 files changed

Lines changed: 3 additions & 1 deletion

File tree

apps/commerce-api/src/main/java/com/loopers/domain/event/OutboxService.java

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,5 @@
11
package com.loopers.domain.event;
22

3-
import com.fasterxml.jackson.core.JsonProcessingException;
43
import com.fasterxml.jackson.databind.ObjectMapper;
54
import com.loopers.infrastructure.event.OutboxRepository;
65
import lombok.RequiredArgsConstructor;

modules/kafka/src/main/resources/kafka.yml

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -15,6 +15,9 @@ spring:
1515
key-serializer: org.apache.kafka.common.serialization.StringSerializer
1616
value-serializer: org.springframework.kafka.support.serializer.JsonSerializer
1717
retries: 3
18+
acks: all
19+
properties:
20+
enable.idempotence: true
1821
consumer:
1922
group-id: loopers-default-consumer
2023
key-deserializer: org.apache.kafka.common.serialization.StringDeserializer

0 commit comments

Comments
 (0)