18.8. Kafka Connect MBeans


注意

除了这里文档外,Kafka Connect 还包含用于接收器连接器 和消费者 连接器的 生产者 MBeans。

Kafka 连接指标

Expand
表 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 线程在纳秒内花费的总时间。替换为 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

收到的总响应。

select-rate

检查新 I/O 层以每秒执行每秒的 I/O 层的次数。

select-total

为要执行的新 I/O 层检查 I/O 层的次数总数。

successful-authentication-no-reauth-total

由旧的、pre-2.2.0 SASL 客户端(不支持重新身份验证)成功验证的连接总数。只能为零。

successful-authentication-rate

使用 SASL 或 SSL 成功验证的每秒连接。

successful-authentication-total

使用 SASL 或 SSL 成功验证的连接总数。

successful-reauthentication-rate

每秒使用 SASL 重新验证的连接。

successful-reauthentication-total

使用 SASL 成功重新验证的连接总数。

有关代理连接的 Kafka 连接指标

Expand
表 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

为节点接收的总响应。

有关 worker 的 Kafka 连接指标

Expand
表 18.14. Mbeans matching kafka.connect:type=connect-worker-metrics
属性描述

connector-count

此 worker 中运行连接器的数量。

connector-startup-attempts-total

此 worker 试图的连接器启动总数。

connector-startup-failure-percentage

此 worker 连接器的平均百分比启动失败。

connector-startup-failure-total

连接器总数启动该失败。

connector-startup-success-percentage

此 worker 连接器的平均百分比启动成功。

connector-startup-success-total

连接器的总数启动成功。

task-count

此 worker 中运行的任务数量。

task-startup-attempts-total

此 worker 试图进行的任务启动总数。

task-startup-failure-percentage

此 worker 任务的平均百分比启动失败。

task-startup-failure-total

任务总数启动失败。

task-startup-success-percentage

此 worker 任务的平均百分比启动成功。

task-startup-success-total

任务总数启动成功。

有关重新平衡的 Kafka 连接指标

Expand
表 18.15. Mbeans matching kafka.connect:type=connect-worker-rebalance-metrics
属性描述

completed-rebalances-total

此 worker 完成的重新平衡总数。

connect-protocol

此集群使用的 Connect 协议。

epoch

此 worker 的 epoch 或生成号。

leader-name

组群领导的名称。

rebalance-avg-time-ms

此 worker 重新平衡的平均时间(毫秒)。

rebalance-max-time-ms

此 worker 重新平衡所花费的最大时间(毫秒)。

重新平衡

此 worker 目前是重新平衡。

time-since-last-rebalance-ms

此 worker 完成最新重新平衡以来的时间(毫秒)。

有关连接器的 Kafka 连接指标

Expand
表 18.16. Mbeans matching kafka.connect:type=connector-metrics,connector=*
属性描述

connector-class

连接器类的名称。

connector-type

连接器的类型。'source' 或 'sink' 之一。

connector-version

连接器类的版本,如连接器所示。

status

连接器的状态。'unassigned', 'running', 'paused', 'failed', 或 'restarting' 之一。

有关连接器任务的 Kafka 连接指标

Expand
表 18.17. Mbeans matching 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

此任务处于 running 状态的部分时间。

status

连接器任务的状态。'unassigned', 'running', 'paused', 'failed', 或 'restarting' 之一。

有关接收器连接器的 Kafka 连接指标

Expand
表 18.18. Mbeans matching kafka.connect:type=sink-task-metrics,connector=*,task=*
属性描述

offset-commit-completion-rate

成功完成的偏移提交完成的平均每秒数量。

offset-commit-completion-total

成功完成的偏移提交完成总数。

offset-commit-seq-no

偏移提交的当前序列号。

offset-commit-skip-rate

收到的时间过晚并跳过/忽略的平均偏移提交完成数。

offset-commit-skip-total

收到太晚并跳过/忽略的偏移提交完成总数。

partition-count

分配给此任务的主题分区数量,属于此 worker 中命名的接收器连接器。

put-batch-avg-time-ms

此任务的平均时间用于放置 sink 记录批处理。

put-batch-max-time-ms

此任务用于放置 sink 记录批处理的最大时间。

sink-record-active-count

从 Kafka 读取的记录数量,但还没有完全提交/冲刷/已由 sink 任务提交/确认。

sink-record-active-count-avg

从 Kafka 读取的平均记录数量,但还没有完全提交/冲刷/已由 sink 任务提交/确认。

sink-record-active-count-max

从 Kafka 读取的最大记录数量,但还没有完全提交/冲刷/已由 sink 任务提交/确认。

sink-record-lag-max

sink 任务在消费者的任何主题分区位置后面的记录数量上限。

sink-record-read-rate

对于属于此 worker 中命名接收器连接器的此任务,从 Kafka 读取的平均每秒记录数。这在应用转换前。

sink-record-read-total

此任务从 Kafka 读取的记录总数属于这个 worker 中的命名 sink 连接器,因为任务上次重启。

sink-record-send-rate

转换中平均每秒记录输出数,并将/计算发送到此任务,属于此 worker 中命名的接收器连接器。这是应用转换后,并排除转换过程中过滤的所有记录。

sink-record-send-total

从转换和发送/计算到属于此 worker 中命名 sink 连接器的记录输出总数,因为任务上次重启。

有关源连接器的 Kafka 连接指标

Expand
表 18.19. Mbeans matching 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

此任务由此任务生成的平均每秒记录数(在转换前)属于此 worker 中命名的源连接器。

source-record-poll-total

此任务由属于此 worker 中命名源连接器的此任务生成/polled (在转换前)的记录总数。

source-record-write-rate

从转换后,对此任务的每秒记录输出数平均数写入 Kafka,此任务属于这个 worker 中命名的源连接器。这是应用转换后,并排除转换过程中过滤的所有记录。

source-record-write-total

对于属于该 worker 中命名的源连接器,从转换中写入 Kafka 的记录输出数量,因为任务上次重启。

transaction-size-avg

任务目前所提交的事务的平均记录数。

transaction-size-max

任务目前已提交的最大事务中的记录数。

transaction-size-min

任务目前已提交的最小事务中的记录数。

有关连接器错误的 Kafka 连接指标

Expand
表 18.20. Mbeans matching kafka.connect:type=task-error-metrics,connector=*,task=*
属性描述

deadletterqueue-produce-failures

对死信队列的失败写入次数。

deadletterqueue-produce-requests

试图写入到死信队列的数量。

last-error-timestamp

此任务上次遇到错误时的 epoch 时间戳。

total-errors-logged

记录的错误数量。

total-record-errors

此任务中的记录处理错误数量。

total-record-failures

此任务中的记录处理失败数。

total-records-skipped

由于错误而跳过的记录数。

total-retries

重试操作数量。

返回顶部
Red Hat logoGithubredditYoutubeTwitter

学习

尝试、购买和销售

社区

关于红帽文档

通过我们的产品和服务,以及可以信赖的内容,帮助红帽用户创新并实现他们的目标。 了解我们当前的更新.

让开源更具包容性

红帽致力于替换我们的代码、文档和 Web 属性中存在问题的语言。欲了解更多详情,请参阅红帽博客.

關於紅帽

我们提供强化的解决方案,使企业能够更轻松地跨平台和环境(从核心数据中心到网络边缘)工作。

Theme

© 2025 Red Hat