03.ConsumerMetric상세

Consumer 동작 방식

1. Consumer Thredad 에서 poll() 호출.

2. Fetcher Queue에 데이터가 있는지 확인. → 없는 경우 Fetcher에서 Fetch 요청.

3. Fetch 결과 수신

4. 결과값 수신

poll을 과도하게 많이 늘리는 경우 → Consumer가 죽었다고 판단할 수 있다. → Consumer의 in/out으로 인해 파티션 rebalancing이 발생할 수 있다.

Consumer 내부 구간

• Consumer 내부에서 처리하는 상태 확인

Consumer 전송 구간

• Consumer에서 Broker로 데이터 전송 및 수신 성능 확인

Coordinator 구간

• Group Coordinator와 Consumer 간 연결 상태

Consumer Rebalance

• 새롭게 Consumer Group으로 참여한 consumer 들은 Group Coordinator를 통해 partition 할당