KAFKA CHECK

HTTP 성공보다 이벤트 도착 로그를 끝까지 확인한다

Users Service의 201 응답은 producer 처리까지만 뜻한다. Kafka 검증은 broker를 지나 consumer 로그까지 이어져야 끝난다.

01 Container Kafka와 Zookeeper가 먼저 running 상태인지 확인한다.
02 Producer 사용자 생성 직후 user_created 발행 로그를 남긴다.
03 Broker topic 토픽 이름이 emit과 @EventPattern에서 같은지 본다.
04 Consumer Notifications Service가 환영 이메일 처리 로그를 출력한다.
부족한 확인

HTTP 201만 보고 끝내면 broker 전달과 consumer 처리를 놓친다.

완료 기준

producer 로그, topic 이름, consumer 로그가 같은 이벤트로 이어진다.

체크 포인트 확인할 증거 놓치면 생기는 문제
토픽 이름 emit 문자열과 @EventPattern 문자열이 동일하다. 메시지는 발행돼도 consumer가 받지 못한다.
소비자 시작 순서 consumer가 떠 있는 상태에서 API를 호출한다. 실패 원인이 코드인지 실행 순서인지 흐려진다.
로그 상관관계 같은 userId 또는 correlation id가 양쪽 로그에 남는다. 재시도와 중복 처리 여부를 추적하기 어렵다.