NEST · KAFKA
Kafka 알림 이벤트 전달 경로
주문·결제 같은 도메인 이벤트를 토픽에 발행하면 알림 서비스는 소비자 그룹으로 받아 채널별 메시지 전송을 분리합니다.
전달 흐름
event
domain event
OrderPaid 이벤트 생성
producer
토픽에 메시지 발행
consumer
알림 서비스가 그룹 단위로 소비
channel send
메일, 푸시, SMS로 전송
domain event
→
producer
→
consumer
→
channel send
consumer lag 점검
점검
멱등성
같은 이벤트를 두 번 받아도 중복 발송을 막습니다.
재시도
일시 실패는 retry, 영구 실패는 DLQ로 보냅니다.
순서
사용자 또는 주문 기준 partition key를 정합니다.
관측
lag, 실패율, 처리 시간을 지표로 봅니다.