핵심 요약
SSG.COM의 제휴 수집·연동 시스템에서 Kotlin Coroutine 기반 비동기 처리와 Kafka 이벤트 흐름을 도입해 15개 API를 동시 호출하는 아키텍처를 구현하고, 배치-실시간 절충 운영으로 흐름을 개선했습니다.
구현 방법
- Kotlin Coroutine으로 15개 API의 비동기 병렬 호출 구현
- 제휴 수집: 변경 데이터 저장, Spring Batch 대신 Kafka 메시지 발행
- 제휴 상품 연동: 이벤트 수신 후 composite 서비스에서 비동기로 API 조합
- 제휴 composite: 15개 API의 비동기 처리 및 DTO 조립
주요 결과
- 병목 제거와 실시간 흐름에 근접한 처리 구조 확립
- 향후 메시지 큐 도입으로 확장성 및 재처리 전략 확보
