Kafka 이벤트 점검

성공 응답보다 이벤트 도착 로그를 끝까지 본다

Users Service의 HTTP 응답은 생산자 처리까지만 확인한다. Kafka 절의 핵심은 브로커를 거친 user_created 이벤트가 consumer에 도착하는지다.

1

컨테이너

docker-compose ps

Kafka와 Zookeeper가 먼저 정상 실행 상태여야 한다.

2

Producer

client.emit

사용자 생성 후 Users Service 콘솔에 발행 직전 로그가 남는다.

3

Broker

메시지는 user_created 토픽에 저장되고 consumer group에 전달된다.

4

Consumer

@EventPattern

Notifications Service가 환영 이메일 처리 로그를 출력한다.

응답과 이벤트 분리

HTTP 201이 떠도 consumer 로그가 없으면 비동기 처리는 아직 검증되지 않았다.

토픽 이름

emit의 문자열과 EventPattern의 문자열을 같은 값으로 유지한다.

소비자 시작 순서

consumer가 떠 있는 상태에서 API를 호출하면 전달 로그를 바로 비교하기 쉽다.