Kafka Streams 윈도우 도입기

컬리 SCM 프로덕트 개발팀은 재고 정산 처리에 배치 방식 대신 Kafka 기반의 이벤트 처리 방식을 도입했습니다. 이는 준실시간 정산 처리와 서비스 확장성 향상을 목표로 합니다.

특히, 주문 마감 및 새벽 도착 보장이라는 비즈니스 특성상 특정 시간대에 몰리는 스파이크성 트래픽을 안정적으로 집계하기 위해 Kafka Streams의 윈도우 기능을 도입했습니다. 주요 요구사항은 5분 단위 원천 데이터를 Kafka로 발행하고, 스파이크성 데이터는 상품 코드 기준으로 일정 시간 간격으로 집계하며, 그 외 데이터는 즉시 정산 테이블에 반영하는 것입니다.

이를 통해 데이터 집중 시 DB 부하를 줄이고 효율적인 정산 처리를 가능하게 합니다.