18.8. Kafka Connect Cryostats


참고

Kafka Connect에는 소스 커넥터를 위한 생산자 와 싱크 커넥터를 위한 소비자에 대한 배포가 포함되어 있으며 여기에 설명된 내용도 포함됩니다.

Kafka Connect 메트릭

표 18.12. Mbeans matching kafka.connect:type=connect-metrics,client-id=*
속성설명

connection-close-rate

창에서 초당 연결이 닫힙니다.

connection-close-total

창에서 닫은 총 연결 수입니다.

connection-count

현재 활성 연결 수입니다.

connection-creation-rate

창에서 초당 설정된 새 연결입니다.

connection-creation-total

창에 설정된 총 새 연결입니다.

failed-authentication-rate

인증에 실패한 초당 연결입니다.

failed-authentication-total

인증에 실패한 총 연결입니다.

failed-reauthentication-rate

재인증에 실패한 초당 연결입니다.

failed-reauthentication-total

재인증에 실패한 총 연결 수입니다.

incoming-byte-rate

모든 소켓에서 바이트/초를 읽습니다.

incoming-byte-total

모든 소켓에서 읽은 총 바이트 수입니다.

io-ratio

I/O 스레드가 I/O를 수행하는 데 소요된 시간의 분수입니다.

io-time-ns-avg

선택 항목당 I/O 평균 시간( 나노초)입니다.

io-time-ns-total

I/O 스레드가 나노초 내에 I/O를 수행하는 데 소비한 총 시간입니다.

io-wait-ratio

I/O 스레드가 기다리는 데 걸린 시간 중 일부입니다.

io-wait-time-ns-avg

I/O 스레드가 나노초 단위로 읽거나 쓸 준비가 된 소켓을 기다리는 데 소비한 평균 시간입니다.

io-wait-time-ns-total

I/O 스레드가 나노초 내에 대기하는 총 시간입니다.

io-waittime-total

사용되지 않는 I/O 스레드가 나노초 내에 대기한 총 시간입니다. 교체는 io-wait-time-ns-total입니다.

iotime-total

더 이상 사용되지 않는 I/O 스레드가 I/O에서 I/O를 수행하는 데 소비한 총 시간입니다. 교체는 io-time-ns-total입니다.

network-io-rate

초당 모든 연결에 대한 평균 네트워크 작업 수(읽기 또는 쓰기)입니다.

network-io-total

모든 연결에 대한 총 네트워크 작업(읽기 또는 쓰기) 수입니다.

outgoing-byte-rate

모든 서버로 초당 전송되는 평균 발신 바이트 수입니다.

outgoing-byte-total

모든 서버로 전송된 총 발신 바이트 수입니다.

reauthentication-latency-avg

재인증으로 인해 ms의 평균 대기 시간이 관찰되었습니다.

reauthentication-latency-max

재인증으로 인해 ms의 최대 대기 시간이 관찰되었습니다.

request-rate

초당 전송되는 평균 요청 수입니다.

request-size-avg

창에 있는 모든 요청의 평균 크기입니다.

request-size-max

창에 전송된 모든 요청의 최대 크기입니다.

request-total

전송된 총 요청 수입니다.

response-rate

초당 응답이 수신되었습니다.

response-total

총 응답이 제공되었습니다.

선택 등급

I/O 계층에서 초당 새 I/O를 수행하는 횟수입니다.

select-total

I/O 계층에서 새 I/O 수행 여부를 확인하는 총 횟수입니다.

successful-authentication-no-reauth-total

재인증을 지원하지 않는 이전 버전의 pre-2.2.0 SASL 클라이언트에서 성공적으로 인증된 총 연결입니다. 0이 아닌 경우에만 사용할 수 있습니다.

successful-authentication-rate

SASL 또는 SSL을 사용하여 성공적으로 인증된 초당 연결입니다.

successful-authentication-total

SASL 또는 SSL을 사용하여 성공적으로 인증된 총 연결입니다.

successful-reauthentication-rate

SASL을 사용하여 성공적으로 다시 인증한 초당 연결입니다.

successful-reauthentication-total

SASL을 사용하여 성공적으로 재인증된 총 연결입니다.

브로커 연결에 대한 Kafka Connect 지표

표 18.13. Mbeans matching kafka.connect:type=connect-metrics,client-id=*,node-id=*
속성설명

incoming-byte-rate

노드의 초당 수신되는 평균 바이트 수입니다.

incoming-byte-total

노드에 대해 수신된 총 바이트 수입니다.

outgoing-byte-rate

노드의 초당 전송된 평균 발신 바이트 수입니다.

outgoing-byte-total

노드에 전송된 총 발신 바이트 수입니다.

request-latency-avg

노드의 평균 요청 대기 시간 ms입니다.

request-latency-max

노드의 최대 요청 대기 시간(ms)입니다.

request-rate

노드의 초당 전송되는 평균 요청 수입니다.

request-size-avg

노드의 창에 있는 모든 요청의 평균 크기입니다.

request-size-max

노드의 창에서 전송된 모든 요청의 최대 크기입니다.

request-total

노드에 대해 전송된 총 요청 수입니다.

response-rate

노드에 대해 초당 응답이 수신되었습니다.

response-total

노드에 대해 수신된 총 응답입니다.

작업자에 대한 Kafka Connect 지표

표 18.14. Cryostat와 일치하는 kafka.connect:type=connect-worker-metrics
속성설명

connector-count

이 작업자에서 실행되는 커넥터 수입니다.

connector-startup-attempts-total

이 작업자가 시도한 총 커넥터 시작 수입니다.

connector-startup-failure-percentage

이 작업자 커넥터의 평균 백분율은 실패한 것으로 시작됩니다.

connector-startup-failure-total

실패한 총 커넥터 수가 시작됩니다.

connector-startup-success-percentage

이 작업자의 커넥터의 평균 비율이 성공하기 시작합니다.

connector-startup-success-total

성공한 총 커넥터 수가 시작됩니다.

task-count

이 작업자에서 실행되는 작업 수입니다.

task-startup-attempts-total

이 작업자가 시도한 총 작업 시작 수입니다.

task-startup-failure-percentage

이 작업자의 작업의 평균 백분율이 실패한 것으로 시작됩니다.

task-startup-failure-total

실패한 총 작업 수입니다.

task-startup-success-percentage

이 작업자의 작업의 평균 백분율이 성공한 것으로 시작됩니다.

task-startup-success-total

성공한 총 작업 수입니다.

리밸런스에 대한 Kafka Connect 지표

표 18.15. Cryostat와 일치하는 kafka.connect:type=connect-worker-rebalance-metrics
속성설명

completed-rebalances-total

이 작업자가 완료한 총 리밸런스 수입니다.

connect-protocol

이 클러스터에서 사용하는 연결 프로토콜입니다.

epoch

이 작업자의 epoch 또는 generation 번호입니다.

leader-name

그룹 리더의 이름입니다.

rebalance-avg-time-ms

이 작업자가 재조정하는 데 소비되는 평균 시간(밀리초)입니다.

rebalance-max-time-ms

이 작업자가 재조정하는 데 소비되는 최대 시간(밀리초)입니다.

재조정

이 작업자가 현재 재조정 중인지 여부입니다.

time-since-last-rebalance-ms

이 작업자가 최신 리밸런스를 완료한 이후의 시간(밀리초)입니다.

커넥터에 대한 Kafka Connect 지표

표 18.16. Cryostat와 일치하는 kafka.connect:type=connector-metrics,connector=*
속성설명

connector-class

커넥터 클래스의 이름입니다.

connector-type

커넥터의 유형입니다. '소스' 또는 'sink' 중 하나입니다.

connector-version

커넥터에서 보고한 커넥터 클래스의 버전입니다.

status

커넥터의 상태입니다. 'unassigned', 'running', 'paused', 'failed' 또는 'destroyed' 중 하나입니다.

커넥터 작업에 대한 Kafka Connect 지표

표 18.17. Cryostat와 일치하는 kafka.connect:type=connector-task-metrics,connector=*,task=*
속성설명

batch-size-avg

커넥터에서 처리하는 배치의 평균 크기입니다.

batch-size-max

커넥터에서 처리하는 배치의 최대 크기입니다.

offset-commit-avg-time-ms

이 작업에서 오프셋을 커밋하는 데 걸리는 평균 시간(밀리초)입니다.

offset-commit-failure-percentage

이 작업의 오프셋 커밋의 평균 백분율이 실패한 것입니다.

offset-commit-max-time-ms

이 작업에서 오프셋을 커밋하는 데 걸리는 최대 시간(밀리초)입니다.

offset-commit-success-percentage

이 작업의 오프셋 커밋의 평균 백분율이 성공한 것입니다.

pause-ratio

이 작업이 일시 중지 상태에서 보낸 시간의 분수입니다.

running-ratio

이 작업이 실행 중 상태로 보낸 시간의 분수입니다.

status

커넥터 작업의 상태입니다. 'unassigned', 'running', 'paused', 'failed' 또는 'destroyed' 중 하나입니다.

싱크 커넥터에 대한 Kafka Connect 지표

표 18.18. Cryostat와 일치하는 kafka.connect:type=sink-task-metrics,connector=*,task=*
속성설명

offset-commit-completion-rate

성공적으로 완료된 평균 1초당 커밋 완료 횟수입니다.

offset-commit-completion-total

성공적으로 완료된 총 오프셋 커밋 완료 수입니다.

offset-commit-seq-no

오프셋 커밋의 현재 시퀀스 번호입니다.

offset-commit-skip-rate

너무 늦고 건너뛴 /무시된 평균 오프셋 커밋 완료 수입니다.

offset-commit-skip-total

너무 늦고 건너뛴/무시됨된 총 오프셋 커밋 완료 수입니다.

partition-count

이 작업자에서 이름이 지정된 싱크 커넥터에 속하는 이 작업에 할당된 주제 파티션 수입니다.

put-batch-avg-time-ms

이 작업에서 싱크 레코드 배치를 배치하는 데 걸리는 평균 시간입니다.

put-batch-max-time-ms

이 작업에서 싱크 레코드 배치를 배치하는 데 걸리는 최대 시간입니다.

sink-record-active-count

Kafka에서 읽었지만 아직 완전히 커밋되지 않은/종료/승인/취약된 레코드 수입니다.

sink-record-active-count-avg

Kafka에서 읽었지만 아직 완전히 커밋되지 않은/flushed/acknowled 작업에서 읽은 평균 레코드 수입니다.

sink-record-active-count-max

Kafka에서 읽은 최대 레코드 수이지만 싱크 작업에서 완전히 커밋/종료/취약되지 않은 레코드 수입니다.

sink-record-lag-max

싱크 작업에서 모든 주제 파티션에 대한 소비자의 위치 뒤에 있는 레코드 수에 대한 최대 지연입니다.

sink-record-read-rate

이 작업자의 이름이 지정된 싱크 커넥터에 속하는 이 작업의 Kafka에서 읽은 평균 초당 레코드 수입니다. 변환이 적용되기 전입니다.

sink-record-read-total

작업이 마지막으로 재시작되었기 때문에 이 작업자의 명명된 싱크 커넥터에 속하는 이 작업에서 Kafka에서 읽은 총 레코드 수입니다.

sink-record-send-rate

변환 및 이 작업자의 이름이 지정된 싱크 커넥터에 속하는 이 작업에 전송된 평균 초당 출력 수입니다. 변환 후 변환이 적용되고 변환에 의해 필터링된 모든 레코드를 제외합니다.

sink-record-send-total

작업이 마지막으로 다시 시작되었기 때문에 이 작업자의 이름이 지정된 싱크 커넥터에 속하는 이 작업에 대한 변환 및 전송/프로덕션의 총 레코드 출력 수입니다.

소스 커넥터에 대한 Kafka Connect 지표

표 18.19. Cryostat와 일치하는 kafka.connect:type=source-task-metrics,connector=*,task=*
속성설명

poll-batch-avg-time-ms

이 작업에서 소스 레코드 배치를 폴링하는 데 걸리는 평균 시간(밀리초)입니다.

poll-batch-max-time-ms

이 작업에서 소스 레코드 배치를 폴링하는 데 걸리는 최대 시간(밀리초)입니다.

source-record-active-count

이 작업에서 생성되었지만 Kafka에 완전히 기록되지 않은 레코드 수입니다.

source-record-active-count-avg

이 작업에서 생성되었지만 Kafka에 완전히 기록되지 않은 평균 레코드 수입니다.

source-record-active-count-max

이 작업에서 생성되었지만 Kafka에 완전히 기록되지 않은 최대 레코드 수입니다.

source-record-poll-rate

이 작업자의 이름이 지정된 소스 커넥터에 속하는 이 작업에 의해 생성/폴링된 평균 레코드 수입니다.

source-record-poll-total

이 작업자에서 이름이 지정된 소스 커넥터에 속하는 이 작업에 의해 생성/폴링된 총 레코드 수입니다.

source-record-write-rate

변환에서 출력하고 이 작업자의 이름이 지정된 소스 커넥터에 속하는 이 작업의 Kafka에 작성된 평균 초당 레코드 수입니다. 변환 후 변환이 적용되고 변환에 의해 필터링된 모든 레코드를 제외합니다.

source-record-write-total

작업이 마지막으로 다시 시작된 이후 이 작업자의 이름이 지정된 소스 커넥터에 속하는 이 작업의 변환 및 Kafka에 작성된 레코드 출력 수입니다.

transaction-size-avg

지금까지 작업에서 커밋한 트랜잭션의 평균 레코드 수입니다.

transaction-size-max

지금까지 작업에서 커밋한 가장 큰 트랜잭션의 레코드 수입니다.

transaction-size-min

지금까지 작업에서 커밋한 최소 트랜잭션의 레코드 수입니다.

커넥터 오류에 대한 Kafka Connect 지표

표 18.20. Cryostat와 일치하는 kafka.connect:type=task-error-metrics,connector=*,task=*
속성설명

deadletterqueue-produce-failures

dead letter queue에 대한 실패한 쓰기 수입니다.

deadletterqueue-produce-requests

dead letter 큐에 대한 시도된 쓰기 횟수입니다.

last-error-timestamp

이 작업에 마지막으로 오류가 발생했을 때의 epoch 타임 스탬프입니다.

total-errors-logged

기록된 오류 수입니다.

total-record-errors

이 작업의 레코드 처리 오류 수입니다.

total-record-failures

이 작업의 레코드 처리 실패 수입니다.

total-records-skipped

오류로 인해 건너뛰는 레코드 수입니다.

total-retries

재시도된 작업 수입니다.

Red Hat logoGithubRedditYoutubeTwitter

자세한 정보

평가판, 구매 및 판매

커뮤니티

Red Hat 문서 정보

Red Hat을 사용하는 고객은 신뢰할 수 있는 콘텐츠가 포함된 제품과 서비스를 통해 혁신하고 목표를 달성할 수 있습니다. 최신 업데이트를 확인하세요.

보다 포괄적 수용을 위한 오픈 소스 용어 교체

Red Hat은 코드, 문서, 웹 속성에서 문제가 있는 언어를 교체하기 위해 최선을 다하고 있습니다. 자세한 내용은 다음을 참조하세요.Red Hat 블로그.

Red Hat 소개

Red Hat은 기업이 핵심 데이터 센터에서 네트워크 에지에 이르기까지 플랫폼과 환경 전반에서 더 쉽게 작업할 수 있도록 강화된 솔루션을 제공합니다.

© 2024 Red Hat, Inc.