event stream

Apache Kafka와 이벤트 기반 아키텍처의 책임 경계

Kafka 이벤트 아키텍처는 producer와 consumer를 느슨하게 잇지만, topic 설계와 중복 처리 기준이 없으면 상태가 더 쉽게 흔들립니다.

Topic

토픽 계약

이벤트 이름, schema, partition key가 소비자 확장과 순서 보장 기준을 결정합니다.

Consumer

소비 처리

consumer group, offset commit, idempotency를 handler 책임 안에서 확인합니다.

Recovery

재처리 경로

poison message, DLQ, 재생 시나리오가 운영 절차로 남아야 합니다.

schema

이벤트 필드 추가와 제거가 하위 호환인지 확인합니다.

order

같은 aggregate의 이벤트가 같은 partition key를 쓰는지 봅니다.

lag

consumer lag와 실패 이벤트를 알림 기준으로 연결합니다.