이벤트 흐름
user.created, order.paid처럼 도메인 이벤트 이름과 payload version을 명확히 둡니다.
Kafka Eventing
Kafka 중복 재처리 설계
topic, partition key, consumer group, offset commit, DLQ를 함께 보아 NestJS 이벤트 서비스가 장애 후에도 같은 상태로 수렴하게 만듭니다.
파티션 키
userId나 orderId를 key로 선택해 같은 리소스의 이벤트 순서를 유지합니다.
소비자 그룹
같은 group id는 작업을 분산하고 다른 group id는 같은 이벤트를 독립적으로 받습니다.
재처리
처리 실패는 retry topic, DLQ, idempotent handler 기준으로 운영합니다.