Nest.js

Apache Kafka와 이벤트 기반 아키텍처

Kafka 기반 마이크로서비스는 토픽, 파티션, 컨슈머 그룹, 커밋 지점을 함께 설계해야 이벤트 재처리와 순서 보장을 설명할 수 있습니다.

이벤트 순서, 재처리 가능성, 컨슈머 장애 복구를 기준으로 Kafka 기반 아키텍처를 설계합니다.

Apache Kafka와 이벤트 기반 흐름

1

이벤트 기반 아키텍처 (EDA)와 Kafka

EDA는 직접 호출 대신 이벤트를 발행하고 구독해 시스템을 느슨하게 연결합니다.

2

NestJS에서 Kafka 설정 및 구현

NestJS는 @nestjs/microservices 패키지를 통해 Kafka 전송 계층을 지원합니다.

3

컨테이너 환경 실행 검증

docker-compose up -d 후 broker와 Zookeeper 상태를 ps로 확인합니다.

4

Kafka 사용자 이벤트 서비스 구축

토픽 파티션은 이벤트 키 기준으로 순서를 유지하면서 컨슈머 그룹 단위로 처리량을 확장합니다.