Consumer Lag 이란
Consumer Lag 이란?Kafka를 운영하면서 시스템 성능과 데이터 처리 효율을 평가하는데 중요한 지표 중 하나입니다.Consumer Group이 메시지를 처리하는 속도가 메시지를 Pub 하는 속도보다 느릴 때 발생하는 지연을 나타냅니다. Consumer Lag 계산Latest OffsetKafka 브로커에 현재 저장된 가장 최신 메시지의 Latest Offset.Current OffsetConsumer가 마지막으로 처리한 메시지의 Commit Offset.Lag = Latest Offset - Commit Offset Consumer Lag이 발생하는 이유Consumer 처리 속도각 서버에 자원이 부족하거나 비즈니스 처리 로직에 병목이 있는 경우Producer 트래픽 급증Partition ..
