如何使用 spring-cloud-stream 配置 Micrometer KafkaClientMetrics

Question

我想知道如何配置 io.micrometer.core.instrument.binder.kafka.KafkaClientMetrics class (v1.5.2)。我从哪里获得由底层 kafka 活页夹创建的消费者和生产者。我什么时候必须调用整个东西？ （还没有自动配置）

自动配置的 io.micrometer.core.instrument.binder.kafka.KafkaConsumerMetrics class 不会注册仪表，因为 Set<ObjectName> objs = mBeanServer.queryNames(new ObjectName(JMX_DOMAIN + ":type=" + type + ",*"), null); returns 是一个空集。我是否必须配置一些特殊的东西才能让它工作？

谢谢。

Answer 1

Spring Boot 2.3 自动使用 spring-kafka 2.5.x:

配置它们

https://github.com/spring-projects/spring-boot/blob/8abcb1b1254a9cc4b623e5af871563ff94bb15a6/spring-boot-project/spring-boot-actuator-autoconfigure/src/main/java/org/springframework/boot/actuate/autoconfigure/metrics/KafkaMetricsAutoConfiguration.java#L56-L64

https://github.com/spring-projects/spring-boot/issues/21008

Micrometer 已弃用旧的 JMX 抓取计量表。