핵심 요약
무신사 MASS 정산 시스템은 Kafka로 원천 데이터를 수신하는 이벤트 기반 영역과 Spring Batch/Argo Workflow로 마감을 책임지는 배치 영역의 하이브리드 구조를 채택해, 멱등성(upsert)과 재처리 가능성을 통해 장애 이후에도 동일한 결과를 보장합니다.
구현 방법
- Kafka로 원천 데이터 수신 및 멱등 저장
- Spring Batch로 일/월 정산 집계, 마감, 리포트 생성
- Argo Workflow로 배치 실행 제어 및 Job Parameter 전달
- MySQL을 정산 결과의 Source of Truth로 사용
- DLT 모니터링 및 재처리용 롤백/재마킹 로직
주요 결과
- DLT 발생 비율 0.001% 미만
- 재처리 시 이전 실행에 의존하지 않고 정산 대상 전체를 재수행
- 멱등성 업스트(upsert)으로 중복 없이 동일한 결과 확보
