目前我正在使用Spring Boot2.1、Spring Kafka(2.2.0)和Micrometer(1.1.0)。
生成和使用Hello World消息非常正常,(kafka)度量也公开了http://host:port/acture/metrics,但当我请求特定的kafka度量时,比如:
http://host:port/actulator/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 Broker上的某些配置?我希望你能给我指明正确的方向。
你可以在这里找到我的示例项目。
我只是在调试器中运行它,执行器正在寻找一个带有对象名的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
)。
我建议你开一个关于千分尺的问题。