18.7. 消费者 MBeans


MBeans 存在于 Kafka 消费者应用程序中,包括 Kafka Streams 应用程序和带有接收器连接器的 Kafka 连接。

消费者指标

Expand
表 18.6. Mbeans matching kafka.consumer:type=consumer-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 成功重新验证的连接总数。

有关代理连接的消费者指标

Expand
表 18.7. Mbeans matching kafka.consumer:type=consumer-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

为节点接收的总响应。

消费者组指标

Expand
表 18.8. Mbeans matching kafka.consumer:type=consumer-coordinator-metrics,client-id=*
属性描述

assigned-partitions

当前分配给此消费者的分区数量。

commit-latency-avg

提交请求的平均时间。

commit-latency-max

提交请求的最大时间。

commit-rate

每秒提交调用数。

commit-total

提交调用的总数。

failed-rebalance-rate-per-hour

每小时失败的组重新平衡事件数量。

failed-rebalance-total

失败的组重新平衡的总数。

heartbeat-rate

每秒心跳的平均数量。

heartbeat-response-time-max

接收对心跳请求的响应的最大时间。

heartbeat-total

心跳总数。

join-rate

组数每秒加入数。

join-time-avg

组的平均时间重新加入。

join-time-max

组的重新加入的最大时间。

join-total

组加入总数。

last-heartbeat-seconds-ago

最后一次控制器心跳以来的秒数。

last-rebalance-seconds-ago

自最后一次重新平衡事件以来的秒数。

partitions-assigned-latency-avg

on-partitions-assigned rebalance listener 回调的平均时间。

partitions-assigned-latency-max

on-partitions-assigned rebalance listener 回调所花费的最大时间。

partitions-lost-latency-avg

on-partitions-lost 重新平衡侦听器回调的平均时间。

partitions-lost-latency-max

on-partitions-lost 重新平衡监听程序回调的最大时间。

partitions-revoked-latency-avg

on-partitions-revoked rebalance listener 回调的平均时间。

partitions-revoked-latency-max

on-partitions-revoked rebalance listener 回调的最大时间。

rebalance-latency-avg

组重新平衡的平均时间。

rebalance-latency-max

组的重新平衡所花费的最大时间。

rebalance-latency-total

目前,组重新平衡的总时间。

rebalance-rate-per-hour

每小时参与的组重新平衡数量。

rebalance-total

参与的组重新平衡总数。

sync-rate

每秒组同步数量。

sync-time-avg

组同步的平均时间。

sync-time-max

组同步的最大时间。

sync-total

组同步总数。

消费者获取器指标

Expand
表 18.9. Mbeans matching kafka.consumer:type=consumer-fetch-manager-metrics,client-id=*
属性描述

bytes-consumed-rate

每秒消耗的字节数。

bytes-consumed-total

消耗的字节数。

fetch-latency-avg

获取请求的平均时间。

fetch-latency-max

任何获取请求获取的最大时间。

fetch-rate

每秒获取请求数。

fetch-size-avg

每个请求获取的平均字节数。

fetch-size-max

每个请求获取的最大字节数。

fetch-throttle-time-avg

以 ms 为单位的平均节流时间。

fetch-throttle-time-max

ms 中的最大节流时间。

fetch-total

获取请求的总数。

records-consumed-rate

平均每秒消耗的记录数。

records-consumed-total

所消耗的记录总数。

records-lag-max

此窗口中任何分区的记录数上限。注意:这基于当前的偏移量,而不是提交偏移。

records-lead-min

在此窗口中,最小导致任何分区的记录数。

records-per-request-avg

每个请求的平均记录数。

主题级别的使用者获取器指标

Expand
表 18.10. Mbeans matching kafka.consumer:type=consumer-fetch-manager-metrics,client-id=*,topic=*
属性描述

bytes-consumed-rate

主题每秒消耗的字节数。

bytes-consumed-total

为主题消耗的字节数。

fetch-size-avg

主题获取的每个请求的平均字节数。

fetch-size-max

每个请求获取的最大字节数。

records-consumed-rate

主题每秒消耗的记录平均数量。

records-consumed-total

为主题使用的记录总数。

records-per-request-avg

每个请求中主题的平均记录数。

在分区级别的使用者获取器指标

Expand
表 18.11. Mbeans matching kafka.consumer:type=consumer-fetch-manager-metrics,client-id=*,topic=*,partition=*
属性描述

preferred-read-replica

分区的当前读取副本,如果从领导读取,则为 -1。

records-lag

分区的最新滞后。

records-lag-avg

分区的平均滞后。

records-lag-max

分区的最大滞后。

records-lead

分区的最新领导。

records-lead-avg

分区的平均领导。

records-lead-min

分区的最小领导。

返回顶部
Red Hat logoGithubredditYoutubeTwitter

学习

尝试、购买和销售

社区

关于红帽文档

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

让开源更具包容性

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

關於紅帽

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

Theme

© 2025 Red Hat