핵심 요약
올리브영이 Kafka Streams를 활용한 EDA 기반 품절 관리로 Oracle 함수 의존을 제거하고 실시간 재고 처리를 구현해 품절 정보 반영 속도와 시스템 안정성을 높였습니다.
구현 방법
- CDC를 통해 재고 변경 이벤트를 Kafka로 즉시 발행
- Kafka Streams로 실시간 가공 후 SoldOut 토픽에 발행하고 OpenSearch에 저장
- 아키텍처 구성 요소: OGG(Oracle GoldenGate), AWS MSK, Kafka Streams, OpenSearch
주요 결과
- Oracle 함수 호출이 2.34B에서 237M으로 약 86% 감소
- 대규모 트래픽 기간에도 안정적인 서비스 제공



