Kafka 토픽 소비 모델

Producer는 토픽에 이벤트를 쌓고, Consumer Group은 파티션을 나누어 읽어 처리량과 순서 보장을 함께 조절합니다.

토픽과 파티션

userId 기준 이벤트 같은 키는 같은 파티션에 쌓여 사용자 단위 순서를 유지합니다.

병렬 소비 다른 키의 이벤트는 별도 파티션에서 동시에 처리할 수 있습니다.

오프셋 저장 소비자는 처리한 위치를 커밋해 재시작 후 이어서 읽습니다.