18.9. Kafka Streams MBeans
客户端的 Kafka Streams 指标
当 metrics.recording.level 配置参数是 info 或 debug 时,会收集这些指标。
| 属性 | 描述 |
|---|---|
| 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-total | 标点调用的总数。 |
| task-closed-rate | 每秒关闭的平均任务数量。 |
| task-closed-total | 已关闭的任务总数。 |
| task-created-rate | 每秒创建的任务平均数量。 |
| task-created-total | 所创建的任务总数。 |
任务 Kafka Streams 指标
在 metrics.recording.level 配置参数被 调试 时,会收集这些指标。
| 属性 | 描述 |
|---|---|
| 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 配置参数被 调试 时,会收集这些指标。
| 属性 | 描述 |
|---|---|
| process-rate | 源处理器节点每秒处理的平均记录数。 |
| process-total | 源处理器节点每秒处理的记录总数。 |
| record-e2e-latency-avg | 记录的平均端到端延迟,通过在节点完全处理后将记录时间戳与系统时间进行比较。 |
| record-e2e-latency-max | 记录的最大端到端延迟,通过在节点完全处理后将记录时间戳与系统时间进行比较。 |
| record-e2e-latency-min | 记录的最小端到端延迟,通过在节点完全处理后将记录时间戳与系统时间进行比较。 |
| suppression-emit-rate | 被发出的下游拒绝操作节点的记录率。 |
| suppression-emit-total | 已发出的下游阻止操作节点的记录总数。 |
州存储的 Kafka Streams 指标
在 metrics.recording.level 配置参数被 调试 时,会收集这些指标。
| 属性 | 描述 |
|---|---|
| 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 | 最大的 get 执行时间以 ns 为单位。 |
| get-rate | 此存储的平均速率。 |
| put-all-latency-avg | 平均将执行时间置于 ns 中。 |
| put-all-latency-max | 最大放置(all)执行时间为 ns。 |
| put-all-rate | 此存储的平均放置率。 |
| put-if-absent-latency-avg | 平均将执行时间置于 ns 中。 |
| put-if-absent-latency-max | 最大 put-if-absent 执行时间为 ns。 |
| put-if-absent-rate | 此存储的平均放置率。 |
| 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 配置参数被 调试 时,会收集这些指标。
| 属性 | 描述 |
|---|---|
| hit-ratio-avg | 平均缓存命中率定义为缓存读取请求的总缓存命中率。 |
| hit-ratio-max | 最大缓存命中率。 |
| hit-ratio-min | 最小缓存命中率。 |