18.7. 消费者 MBeans
MBeans 存在于 Kafka 消费者应用程序中,包括 Kafka Streams 应用程序和带有接收器连接器的 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 成功重新验证的连接总数。 |
有关代理连接的消费者指标
| 属性 | 描述 |
|---|---|
| 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 | 为节点接收的总响应。 |
消费者组指标
| 属性 | 描述 |
|---|---|
| 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 | 组同步总数。 |
消费者获取器指标
| 属性 | 描述 |
|---|---|
| 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 | 每个请求的平均记录数。 |
主题级别的使用者获取器指标
| 属性 | 描述 |
|---|---|
| bytes-consumed-rate | 主题每秒消耗的字节数。 |
| bytes-consumed-total | 为主题消耗的字节数。 |
| fetch-size-avg | 主题获取的每个请求的平均字节数。 |
| fetch-size-max | 每个请求获取的最大字节数。 |
| records-consumed-rate | 主题每秒消耗的记录平均数量。 |
| records-consumed-total | 为主题使用的记录总数。 |
| records-per-request-avg | 每个请求中主题的平均记录数。 |
在分区级别的使用者获取器指标
| 属性 | 描述 |
|---|---|
| preferred-read-replica | 分区的当前读取副本,如果从领导读取,则为 -1。 |
| records-lag | 分区的最新滞后。 |
| records-lag-avg | 分区的平均滞后。 |
| records-lag-max | 分区的最大滞后。 |
| records-lead | 分区的最新领导。 |
| records-lead-avg | 分区的平均领导。 |
| records-lead-min | 分区的最小领导。 |