7.8. Kafka Connect MBeans
这些是连接级别的指标。
属性 | 描述 |
---|---|
connection-close-rate | 窗口中每秒关闭的连接。 |
connection-count | 当前活跃的连接数。 |
connection-creation-rate | 窗口中每秒建立的新连接。 |
failed-authentication-rate | 身份验证失败的连接。 |
incoming-byte-rate | 对所有套接字进行字节/秒读取。 |
io-ratio | I/O 线程处理 I/O 线程的几分时间。 |
io-time-ns-avg | 每个选择调用的 I/O 的平均时间长度(以纳秒为单位)。 |
io-wait-ratio | I/O 线程等待的时间部分。 |
io-wait-time-ns-avg | I/O 线程的平均时间长度为等待一个套接字,准备好以纳秒为单位进行读取或写入。 |
network-io-rate | 每秒所有连接上的网络操作(读或写)的平均数量。 |
outgoing-byte-rate | 每秒发送到所有服务器的平均传出字节数。 |
request-rate | 每秒发送的请求数平均数。 |
request-size-avg | 窗口中所有请求的平均大小。 |
request-size-max | 窗口中发送的任何请求的最大大小。 |
response-rate | 每秒发送的响应数。 |
select-rate | 检查 I/O 层每秒执行的 I/O 层的次数。 |
successful-authentication-rate | 使用 SASL 或 SSL 成功进行身份验证的连接。 |
这些是在连接每个代理的连接级别的指标。
属性 | 描述 |
---|---|
incoming-byte-rate | 节点每秒接收的平均响应数。 |
outgoing-byte-rate | 节点每秒发送的传出字节数。 |
request-latency-avg | 节点的平均请求延迟为 ms。 |
request-latency-max | 节点的最大请求延迟( ms)。 |
request-rate | 节点每秒发送的请求数。 |
request-size-avg | 节点窗口中所有请求的平均大小。 |
request-size-max | 在节点窗口中发送的任何请求的最大大小。 |
response-rate | 节点每秒发送的响应。 |
这些是连接级别的指标。
属性 | 描述 |
---|---|
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 | 任务总数开始成功。 |
属性 | 描述 |
---|---|
completed-rebalances-total | 此 worker 完成的重新平衡总数。 |
connect-protocol | 此集群使用的 Connect 协议。 |
epoch | 此 worker 的 epoch 或生成号。 |
leader-name | 组 leader 的名称。 |
rebalance-avg-time-ms | 此 worker 要重新平衡的平均时间(以毫秒为单位)。 |
rebalance-max-time-ms | 此 worker 要重新平衡的最大时间(毫秒)。 |
重新平衡 | 此 worker 当前是重新平衡的。 |
time-since-last-rebalance-ms | 此 worker 完成最新重新平衡后的时间(毫秒)。 |
属性 | 描述 |
---|---|
connector-class | 连接器类的名称。 |
connector-type | 连接器的类型。'source' 或 'sink' 之一。 |
connector-version | 连接器类的版本,如连接器所示。 |
status | 连接器的状态。'unassigned'、'running'、'paused'、'failed' 或 'destroyed' 的一个。 |
属性 | 描述 |
---|---|
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' 或 'destroyed' 的一个。 |
属性 | 描述 |
---|---|
offset-commit-completion-rate | 成功完成的偏移提交完成的平均数量。 |
offset-commit-completion-total | 成功完成的偏移提交完成总数。 |
offset-commit-seq-no | 偏移提交的当前序列号。 |
offset-commit-skip-rate | 接收太晚并跳过/忽略的偏移提交完成的平均数量。 |
offset-commit-skip-total | 收到太晚并跳过/忽略的偏移提交完成总数。 |
partition-count | 分配给此任务的主题分区数量属于此 worker 中命名 sink 连接器。 |
put-batch-avg-time-ms | 此任务用于放置批处理接收器记录的平均时间。 |
put-batch-max-time-ms | 此任务放置批处理接收器记录的最大时间。 |
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 | 从 Kafka 读取的平均每秒记录数,用于属于此 worker 中命名 sink 连接器的此任务。这是应用转换前的。 |
sink-record-read-total | 此任务从 Kafka 读取的记录总数属于这个 worker 中的命名 sink 连接器,因为任务上次重启。 |
sink-record-send-rate | 转换中平均每秒记录输出数,并将/吞吐量发送到此 worker 中名为 sink 连接器的此任务。这是在应用转换后,会排除转换过滤的所有记录。 |
sink-record-send-total | 从转换和发送/计算到此任务的记录输出总数,属于此 worker 中的指定 sink 连接器,因为任务上次重启。 |
属性 | 描述 |
---|---|
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 的记录输出数量,因为任务上次重启。 |
属性 | 描述 |
---|---|
deadletterqueue-produce-failures | 对死信队列的失败写入数量。 |
deadletterqueue-produce-requests | 尝试写入死信队列的数量。 |
last-error-timestamp | 此任务最后一次遇到错误时的 epoch 时间戳。 |
total-errors-logged | 记录的错误数。 |
total-record-errors | 此任务中的记录处理错误数量。 |
total-record-failures | 此任务中的记录处理失败数量。 |
total-records-skipped | 由于错误,跳过的记录数量。 |
total-retries | 重试的操作数量。 |