Spring Boot 2.1千分尺Kafka消费者指标统计COUNT是"NaN"

Question

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

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

• Spring Boot 2应用程序将随机Hello World消息发布到Kafka主题
• 使用Kafka主题的Hello World消息的Spring Boot 2应用程序
• 一个docker-compose文件,用于启动Kafka代理和Zookeeper实例(两个官方的Confluent Docker镜像)

我的目标是让Kakfa消费者指标工作,作为千分尺1.1.0的一部分发布.

生成和使用Hello World消息的工作完全正常(kafka)指标暴露在http:// host:port/actuator/metrics但是当我请求特定的Kafka指标时:

HTTP://主机:端口/致动器/度量/ 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代理的某些配置？我希望你能指出我正确的方向.

你可以在这里找到我的示例项目.

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）。

我建议你针对千分尺提出一个问题。