Kafka Streams 윈도우 도입기 - 컬리 기술 블로그

쿠리리 SCM 제품 개발팀은 배치 기반 정산 처리를 이벤트 드리븐 Kafka 아키텍처로 전환했다.

Kafka Streams의 tumbling window, grace period, suppression을 활용해 상품코드별 재고 거래를 5분 단위로 집계했다.

이제 각 윈도우의 최종 결과만 한 번씩 저장해 중복 업데이트와 DB 부하를 줄인다.

이 방식은 폭주하는 운영 데이터를 경계가 있는 실시간 스트림 집계로 바꿔 정산 처리에 활용할 수 있게 한다.