이 게시물은 45분 배치에서 준실시간 Kafka 통합 전환 사례를 공유합니다.

핵심 문제

• 프로시저 기반 강결합과 전체 재계산으로 최대 45분 지연 발생
• 상품·쿠폰·증정·프로모션 등 다수 도메인 데이터의 서로 다른 생명주기와 실시간성 요구
• 레거시와의 공존으로 안전한 병행 전환 필요

해결 접근

• 데이터 특성에 따른 하이브리드 처리(이벤트 기반과 배치 기반 병행)
• Redis Pub/Sub로 배치-스트리밍 동시성 제어 및 폴링 비용 절감
• Aggregation Topic과 상품ID 파티셔닝으로 상품 단위 처리 순서 보장
• 멱등성(중복 제거·UPSERT) 보장 및 Shadow Table로 정합성 검증