如何使用spring boot 2将kafka指标公开给/致动器/指标

Question

我找了一段时间，似乎没有找到答案。我使用的是Spring boot2，Spring Kafka 2.1.4，我希望在spring boot执行器的/metrics端点中看到kafka的消费者指标。我不明白的是-我应该自己实现曝光，还是在boot2中是开箱即用的？

如果我自己去实现这一点，最好的方法是什么？

Answer 1

针对micrometer v1.1.0的是MeterBinder的KafkaConsumerMetrics实现。这应该会暴露出您正在寻找的kafka消费者指标。

来源参考：

https://github.com/micrometer-metrics/micrometer/blob/master/micrometer-core/src/main/java/io/micrometer/core/instrument/binder/kafka/KafkaConsumerMetrics.java

Answer 2

添加此配置对我有效：

spring.jmx.enabled=true

Answer 3

你说得对，没有开箱即用的方法。除非实现自己的MeterBinder，否则您别无选择。对于Apache Kafka Consumer指标本身，您应该注入一个KafkaListenerEndpointRegistry并调用它的getListenerContainers()，并使用它们的metrics()绑定到提供的MeterRegistry。

当你想出一些东西时，请随时将解决方案贡献给Spring Boot。