Kafka 검증은 API 응답보다 이벤트 도착 경로를 본다

사용자 생성 API가 성공해도 알림 이벤트가 소비자까지 도착했는지는 별도로 확인해야 합니다.

1. Container

Broker 실행

docker-compose ps

정상이면 zookeeper와 kafka가 떠 있습니다.

2. Producer

New user created

HTTP 요청이 이벤트 발행 지점까지 도달했습니다.

3. Topic

offset 증가

이벤트가 브로커 로그에 기록됩니다.

4. Consumer

Welcome email sent

consumer group이 이벤트를 읽고 처리했습니다.

멈춘 위치	확인할 것	다음 조치
Broker	9092 포트, advertised listeners	Docker Compose 설정과 컨테이너 로그 확인
Producer	`KAFKA_SERVICE`, broker 주소, topic 이름	Users Service 연결과 `emit()` 호출 확인
Consumer	`groupId`, `@EventPattern`, payload 구조	Notifications Service 로그와 handler 실행 확인

검증 순서: 컨테이너 → Producer 로그 → Topic 기록 → Consumer 로그 순서로 보면 이벤트가 어디서 멈췄는지 빠르게 좁혀집니다.