spring-boot - Spring Boot 2.1 Micrometer Kafka 消费者指标统计 COUNT 为 "NaN"

Question

目前我正在使用 Spring Boot 2.1、Spring Kafka (2.2.0) 和 Micrometer (1.1.0)。

我创建了一个简单的示例项目，其中包含:

一个 Spring Boot 2 应用程序向 Kafka 主题发布随机 Hello World 消息

使用来自 Kafka 主题的 Hello World 消息的 Spring Boot 2 应用程序

一个 docker-compose 文件来启动一个 Kafka 代理和一个 Zookeeper 实例(两个官方 Confluent Docker 镜像)

我的目标是使作为 micrometer 1.1.0 一部分发布的 Kakfa 消费者指标正常工作。

生成和使用 Hello World 消息工作得非常好，而且 (kafka) 指标也暴露了 http://host:port/actuator/metrics但当
我请求一个特定的 Kafka 指标，例如:

http://host:port/actuator/metrics/kafka.consumer.records.consumed.total

统计值 COUNT是 NaN .

{
  name: "kafka.consumer.records.consumed.total",
  description: "The total number of records consumed.",
  baseUnit: "records",
  measurements: [
    {
      statistic: "COUNT",
      value: "NaN"
    }
   ],
   availableTags: [
     {
       tag: "client.id",
       values: [
         "spring-kafka-consumer-hello-world-app"
       ]
     }
   ]
 }

我是否忽略了 Spring Boot 应用程序或 Kafka 代理上的一些配置？我希望你能指出我正确的方向。

您可以找到我的示例项目 here .

Answer 1

我只是在调试器中运行它，执行器正在寻找具有对象名称的 MBean...

kafka.consumer:type=consumer-fetch-manager-metrics,\
client-id=spring-kafka-consumer-hello-world-app

我们得到...

javax.management.InstanceNotFoundException: kafka.consumer:type=consumer-fetch-manager-metrics,client-id=spring-kafka-consumer-hello-world-app

...但该应用程序实际上有 3 个带有名称的消费者 MBean:

kafka.consumer:type=consumer-fetch-manager-metrics,\
client-id=spring-kafka-consumer-hello-world-app-0

(和 -1 、 -2 )。

我建议你打开一个针对千分尺的问题。