如何从 Actuator 为 Spring Cloud Stream Kafka 消费者解释指标 spring.cloud.stream.binder.kafka.offset答案

【问题标题】：How to interpret metric spring.cloud.stream.binder.kafka.offset from Actuator for Spring Cloud Stream Kafka consumer如何从 Actuator 为 Spring Cloud Stream Kafka 消费者解释指标 spring.cloud.stream.binder.kafka.offset
【发布时间】：2019-08-13 09:55:33
【问题描述】：

我正在通过 Spring Boot Actuator 公开 Kafka 偏移量度。当我使用 curl 命令时：

    http://server/actuator/metrics/spring.cloud.stream.binder.kafka.offset

我得到以下信息：

    {"name":"spring.cloud.stream.binder.kafka.offset",
     "description":"Consumer lag for a particular group and topic",
     "baseUnit":"seconds",
     "measurements":[{"statistic":"VALUE","value":0.152}],
     "availableTags":[{"tag":"topic","values":["kafka.topic.input"]}, 
                      {"tag":"group","values":["Consumer1"]}]
     }

0.152 秒的测量值是什么意思？

谢谢

【问题讨论】：

标签： apache-kafka offset spring-cloud-stream spring-boot-actuator

【解决方案1】：

这是一个错误，fixed in 2.1。

使用TimeGauge（缩放到毫秒）而不是简单的Gauge。

所以，这个数字似乎意味着您在所有分区中的总延迟为 152。

【讨论】：

谢谢加里。从您发布的链接中，我看到了这条评论“Kafka Offset 只是数值而不是时间”。这是否意味着有 152 条待处理消息要由我的消费者在所有 patition 中处理？
看起来是这样，是的。