OpenTelemetry Kafka 메트릭 참조

kafka.brokers

클러스터 내 브로커의 총 개수

게이지(int)

kafka.topic.partitions

토픽의 파티션 수

합계(정수)

주제

kafka.topic.min_insync_replicas

토픽의 최소 동기화 복제본 수

게이지(int)

주제

kafka.topic.replication_factor

토픽의 복제 인자

게이지(int)

주제

kafka.partition.replicas_in_sync

파티션에 대한 동기화된 복제본 수

합계(정수)

주제, 파티션

kafka.partition.replicas_in_sync.total

토픽에 대해 모든 파티션에 걸쳐 집계된 동기화된 복제본의 총 개수

합계(정수)

주제

kafka.consumer_group.members

소비자 그룹의 구성원 수

합계(정수)

그룹

kafka.consumer_group.offset

토픽 분할 시 소비자 그룹의 현재 오프셋

게이지(int)

그룹, 토픽, 파티션

kafka.consumer_group.offset_sum

토픽의 파티션별 소비자 그룹 오프셋 합계

게이지(int)

그룹, 주제

kafka.consumer_group.lag

주제 분할 시 소비자 그룹의 현재 대략적인 지연

게이지(int)

그룹, 토픽, 파티션

kafka.consumer_group.lag_sum

토픽의 모든 파티션에 걸친 소비자 그룹 지연의 현재 대략적인 합계

게이지(int)

그룹, 주제

kafka.partition.offline

클러스터에서 오프라인 상태인 파티션 수

계량기

kafka.leader.election.rate

지도자 선거 집계

카운터

kafka.unclean.election.rate

부정선거로 인한 지도자 선출 건수 증가 추세는 브로커 실패를 나타냅니다.

카운터

kafka.cluster.topic.count

클러스터에 있는 전체 토픽 수

계량기

kafka.cluster.partition.count

클러스터의 전체 파티션 수

계량기

kafka.broker.fenced.count

클러스터 내 울타리형 브로커의 수

계량기

kafka.partition.non_preferred_leader

리더가 선호 리더가 아닌 토픽 파티션의 수

계량기

kafka.message.count

브로커가 수신한 메시지 수

카운터

kafka.request.count

브로커가 수신한 requests 수

카운터

kafka.request.failed

실패한 requests수

카운터

kafka.request.time.total

requests 처리에 소요된 총 시간(밀리초)

카운터

kafka.request.time.avg

평균 요청 처리 시간(밀리초)

계량기

kafka.request.time.50p

50번째 백분위수 요청 시간(밀리초)

계량기

kafka.request.time.99p

99번째 백분위수 요청 시간(밀리초)

계량기

kafka.network.io

브로커가 초당 수신 또는 전송한 바이트 수(방향 속성: 수신/송신 포함)

카운터

kafka.purgatory.size

처리 대기 중인 requests 수 (생산 및 가져오기 작업)

계량기

kafka.partition.count

브로커의 파티션 수

계량기

kafka.partition.under_replicated

이 브로커에서 복제가 덜 된 파티션의 수

계량기

kafka.isr.operation.count

동기화된 복제본 작업(축소 또는 확장)

카운터

kafka.lag.max

팔로워와 리더 복제본 간의 최대 지연 시간

계량기

kafka.controller.active.count

이 브로커가 활성 컨트롤러인지 여부(0 또는 1)

계량기

kafka.logs.flush.count

로그 플러시 횟수

카운터

kafka.logs.flush.time.50p

로그 플러시 시간 - 50번째 백분위수(ms)

계량기

kafka.logs.flush.time.99p

로그 플러시 시간 - 99번째 백분위수(ms)

계량기

kafka.partition.under_min_isr

동기화된 복제본 수가 최소값보다 적은 파티션 수

계량기

kafka.broker.uptime

브로커 업타임(ms)

계량기

kafka.broker.leader.count

이 브로커가 리더인 파티션 수

계량기

kafka.prod.msg.count

주제별 수신 메시지 수

카운터

주제

kafka.topic.io

토픽별 수신 또는 전송된 바이트 수

카운터

주제, 방향(안쪽/바깥쪽)

jvm.memory.heap.used

현재 힙 메모리 사용량(바이트)

계량기

jvm.memory.heap.max

최대 힙 메모리 사용 가능량(바이트)

계량기

jvm.memory.heap.committed

커밋된 힙 메모리(바이트)

계량기

jvm.gc.collections.count

지금까지 발생한 가비지 컬렉션의 총 횟수

카운터

jvm.gc.collections.elapsed

대략적인 누적 수집 소요 시간(밀리초)

카운터

jvm.thread.count

총 실 가닥 수 (카프카의 일반적인 범위는 100-300개입니다)

계량기

jvm.system.cpu.load_1m

시스템 부하 평균(1분) - CPU 개수보다 크면 변경됩니다.

계량기

jvm.cpu.count

사용 가능한 프로세서 수

계량기

jvm.cpu.recent_utilization

최근 JVM 프로세스의 CPU 사용률(0.0-1.0)

계량기

jvm.system.cpu.utilization

최근 전체 시스템 CPU 사용률 (0.0-1.0)

계량기

jvm.file_descriptor.count

열려 있는 파일 디스크립터 수 - ulimit의 80%보다 크면 변경

계량기

jvm.class.count

현재 로드된 클래스 수

계량기

jvm.memory.pool.used

세대별(G1 Old Gen, Eden, Survivor) 메모리 풀 사용량(바이트)

계량기

jvm.memory.pool.max

최대 메모리 풀 크기(바이트)

계량기

jvm.memory.pool.used_after_last_gc

마지막 GC 이후에 사용된 메모리 - 유지된 메모리 기준(바이트)을 표시합니다.

계량기