18.9. Kafka Streams MBeans
客户端的 Kafka Streams 指标
当 metrics.recording.level
配置参数是 info
或 debug
时,会收集这些指标。
属性 | 描述 |
---|---|
blocked-time-ns-total | 线程在 kafka 上阻断的总时间。 |
commit-latency-avg | 在这个线程的所有运行任务中,用于提交的平均执行时间(以 ms 为单位)。 |
commit-latency-max | 在这个线程的所有运行任务中,用于提交的最大执行时间(以 ms 为单位)。 |
commit-rate | 每秒提交的平均数量。 |
commit-total | 提交调用的总数。 |
poll-latency-avg | ms 的平均执行时间,用于消费者轮询。 |
poll-latency-max | ms 中的最大执行时间,用于消费者轮询。 |
poll-rate | 平均消费者轮询调用数每秒。 |
poll-total | 消费者轮询调用总数。 |
process-latency-avg | ms 的平均执行时间,用于处理。 |
process-latency-max | ms 中的最大执行时间,用于处理。 |
process-rate | 每秒已处理记录的平均数量。 |
process-total | 处理记录的总数。 |
punctuate-latency-avg | ms 的平均执行时间,用于标点。 |
punctuate-latency-max | ms 中的最大执行时间,用于标点。 |
punctuate-rate | 每秒 punctuate 调用的平均数量。 |
punctuate-total | 标点调用总数。 |
task-closed-rate | 每秒关闭的平均任务数量。 |
task-closed-total | 已关闭的任务总数。 |
task-created-rate | 每秒创建的平均任务数量。 |
task-created-total | 创建的任务的总数。 |
thread-start-time | 线程启动的时间。 |
用于任务的 Kafka Streams 指标
当 metrics.recording.level
配置参数是 debug
时,会收集这些指标。
属性 | 描述 |
---|---|
active-process-ratio | 在所有分配的活跃任务中,流线程处理此任务的比例。 |
commit-latency-avg | ns 中平均执行时间,用于提交。 |
commit-latency-max | ns 中的最大执行时间,用于提交。 |
commit-rate | 每秒提交调用的平均数量。 |
commit-total | 提交调用的总数。 |
dropped-records-rate | 此任务中丢弃的记录平均数量。 |
dropped-records-total | 此任务中丢弃的记录总数。 |
enforced-processing-rate | 每秒实施处理的平均数量。 |
enforced-processing-total | 强制处理总数。 |
process-latency-avg | ns 的平均执行时间,用于处理。 |
process-latency-max | ns 中用于处理的最大执行时间。 |
process-rate | 此任务的所有源处理器节点之间每秒处理记录的平均数量。 |
process-total | 此任务的所有源处理器节点中已处理记录总数。 |
record-lateness-avg | 记录的平均观察到晚上(流时间 - 记录时间戳)。 |
record-lateness-max | 记录的最大观察到晚时间(流时间 - 记录时间戳)。 |
处理器节点的 Kafka Streams 指标
当 metrics.recording.level
配置参数是 debug
时,会收集这些指标。
属性 | 描述 |
---|---|
bytes-consumed-total | 源处理器节点消耗的字节数。 |
bytes-produced-total | sink 处理器节点生成的字节数。 |
process-rate | 源处理器节点每秒处理的平均记录数。 |
process-total | 源处理器节点每秒处理的记录总数。 |
record-e2e-latency-avg | 记录的平均端到端延迟,通过在节点完全处理后将记录时间戳与系统时间进行比较。 |
record-e2e-latency-max | 记录的最大端到端延迟,通过在节点完全处理后将记录时间戳与系统时间进行比较。 |
record-e2e-latency-min | 记录的最小端到端延迟,通过在节点完全处理后将记录时间戳与系统时间进行比较。 |
records-consumed-total | 源处理器节点使用的记录总数。 |
records-produced-total | sink 处理器节点生成的记录总数。 |
suppression-emit-rate | 从阻止操作节点发送下游的记录率。 |
suppression-emit-total | 下游阻止操作节点的记录总数。 |
状态存储的 Kafka Streams 指标
当 metrics.recording.level
配置参数是 debug
时,会收集这些指标。
属性 | 描述 |
---|---|
all-latency-avg | ns 的平均操作执行时间。 |
all-latency-max | ns 中的最大所有操作执行时间。 |
all-rate | 此存储的平均操作率。 |
delete-latency-avg | ns 的平均删除执行时间。 |
delete-latency-max | ns 中的最大删除执行时间。 |
delete-rate | 此存储的平均删除率。 |
flush-latency-avg | ns 的平均冲刷执行时间。 |
flush-latency-max | ns 中的最大冲刷执行时间。 |
flush-rate | 此存储的平均冲刷率。 |
get-latency-avg | ns 的平均获得执行时间。 |
get-latency-max | ns 中最大获取执行时间。 |
get-rate | 此存储的平均获得率。 |
put-all-latency-avg | ns 的平均放置所有执行时间。 |
put-all-latency-max | ns 中最大放置执行时间。 |
put-all-rate | 此存储的平均放置率。 |
put-if-absent-latency-avg | ns 中的平均 put-if-absent 执行时间。 |
put-if-absent-latency-max | ns 中的最大 put-if-absent 执行时间。 |
put-if-absent-rate | 此存储的平均 put-if-absent 速率。 |
put-latency-avg | ns 的平均执行时间。 |
put-latency-max | ns 中的最大放置执行时间。 |
put-rate | 此存储的平均放置率。 |
range-latency-avg | ns 的平均范围执行时间。 |
range-latency-max | ns 中最大范围执行时间。 |
range-rate | 此存储的平均范围率。 |
record-e2e-latency-avg | 记录的平均端到端延迟,通过在节点完全处理后将记录时间戳与系统时间进行比较。 |
record-e2e-latency-max | 记录的最大端到端延迟,通过在节点完全处理后将记录时间戳与系统时间进行比较。 |
record-e2e-latency-min | 记录的最小端到端延迟,通过在节点完全处理后将记录时间戳与系统时间进行比较。 |
restore-latency-avg | ns 的平均恢复执行时间。 |
restore-latency-max | ns 中的最大恢复执行时间。 |
restore-rate | 此存储的平均恢复率。 |
suppression-buffer-count-avg | 在抽样窗口中缓冲的平均记录数。 |
suppression-buffer-count-max | 抽样窗口中缓冲的最大记录数。 |
suppression-buffer-size-avg | 抽样窗口中缓冲数据的平均总大小(以字节为单位)。 |
suppression-buffer-size-max | 抽样窗口中缓冲数据的最大大小(以字节为单位)。 |
记录缓存的 Kafka Streams 指标
当 metrics.recording.level
配置参数是 debug
时,会收集这些指标。
属性 | 描述 |
---|---|
hit-ratio-avg | 平均缓存命中率是缓存读取命中总缓存读取请求的比率。 |
hit-ratio-max | 缓存命中率上限。 |
hit-ratio-min | 最低缓存命中率。 |