Kafka Streams 기반 EDA 구축 사례: 올리브영 품절 시스템 현대화 프로젝트

기존 품절 시스템의 문제점 및 개선 목표

• 올리브영은 기존 Oracle DB에 직접 의존하는 품절 시스템으로 인해 응답 속도 저하, DB 부하 및 서비스 품질 영향 문제를 겪었으며, 특히 올영세일 같은 대규모 트래픽 시 심화.
• 단일 장애 지점 문제와 높은 결합도를 해소하고 실시간 데이터 처리 및 확장성 확보를 목표로 개선 추진. Kafka Streams 기반 EDA 도입 및 아키텍처
• OGG, AWS MSK, Kafka Streams를 활용한 **Event-Driven Architecture(EDA)**를 도입하여 DB 의존성을 제거하고 실시간 재고 이벤트 파이프라인을 구축.
• CDC를 통해 재고 변경 이벤트를 Kafka Topic으로 발행하고, Kafka Streams가 실시간으로 처리하여 OpenSearch에 품절 정보를 저장.
• Kafka Streams는 낮은 지연, 높은 처리 속도, Exactly-once 처리 보장, Streams DSL을 통한 간결한 구현이 특징. 개선 결과 및 향후 계획
• 개선 후 Oracle 함수 호출량 86% 감소를 달성하여 올영세일 기간에도 안정적인 서비스를 제공.
• Kafka Streams는 실시간성과 단순성을 모두 갖춰 시스템 안정성과 효율성을 높이는 핵심 역할 수행.
• 향후 Kafka Streams의 다양한 비즈니스 적용을 계획 중.