18.8. Kafka Connect MBeans
Kafka 连接指标
属性 | 描述 |
---|---|
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 连接指标
属性 | 描述 |
---|---|
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 连接指标
属性 | 描述 |
---|---|
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 连接指标
属性 | 描述 |
---|---|
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 连接指标
属性 | 描述 |
---|---|
connector-class | 连接器类的名称。 |
connector-type | 连接器的类型。'source' 或 'sink' 之一。 |
connector-version | 连接器类的版本,如连接器所示。 |
status | 连接器的状态。'unassigned', 'running', 'paused', 'failed', 或 'restarting' 之一。 |
有关连接器任务的 Kafka 连接指标
属性 | 描述 |
---|---|
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 连接指标
属性 | 描述 |
---|---|
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 连接指标
属性 | 描述 |
---|---|
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 连接指标
属性 | 描述 |
---|---|
deadletterqueue-produce-failures | 对死信队列的失败写入次数。 |
deadletterqueue-produce-requests | 试图写入到死信队列的数量。 |
last-error-timestamp | 此任务上次遇到错误时的 epoch 时间戳。 |
total-errors-logged | 记录的错误数量。 |
total-record-errors | 此任务中的记录处理错误数量。 |
total-record-failures | 此任务中的记录处理失败数。 |
total-records-skipped | 由于错误而跳过的记录数。 |
total-retries | 重试操作数量。 |