Untitled

Topic : 카프카 내에서 전송되는 메세지가 저장되는 장소로 논리적인 개념

Producer : 메세지를 생성하여 카프카의 토픽으로 메시지를 보내는 애플리케이션

Consumer : Topic의 메세지를 가져와 소비하는 애플리케이션

ConsumerGroup : Topic의 메세지를 사용하기 위해 협력하는 Consumer집합

→ 컨슈머그룹은 토픽의 메세지를 분산 병렬 처리함

프로듀서와 컨슈머의 기본 동작 방식

커밋로그

추가만 가능하고 변경이 불가능한 데이터 스트럭쳐. 데이터는 항상 로그 끝에 추가되고 변경되지 않음

오프셋

커밋로그에서 이벤트의 위치 아래 예시 (0~10)

Untitled

Untitled

프로듀서와 컨슈머는 서로 알지못한다 (통신하지 않음)