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

기존 올리브영의 품절 여부 조회 방식은 Oracle DB 함수를 직접 호출하는 구조로, 대규모 트래픽 발생 시 DB 부하와 서비스 지연이 발생하는 문제가 있었습니다.

이를 해결하기 위해 **Event-Driven Architecture(EDA)**를 도입하여 DB 의존성을 제거하고 서비스 간 결합도를 낮췄습니다. **OGG(Oracle GoldenGate)**를 통해 변경 데이터를 캡처하고, AWS MSK와 Kafka Streams를 활용해 실시간 데이터 파이프라인을 구축했습니다.

새로운 아키텍처의 주요 특징은 다음과 같습니다.

• 실시간성 확보: 재고 변경 이벤트 발생 시 즉시 이벤트를 발행하여 OpenSearch에 반영함으로써 데이터 정합성 문제를 개선했습니다.
• 확장성 및 유연성: 새로운 서비스가 필요할 경우 이벤트를 구독하는 것만으로 손쉽게 확장이 가능합니다.
• Kafka Streams 활용: Exactly-once 처리를 보장하며, Streams DSL과 Processor API를 통해 복잡한 로직을 효율적으로 구현합니다.