带有Spring Boot的Apache Kafka JMX指标

Question

所有的，

我需要将 Apache Kafka 指标公开给Spring启动 （v 2.3.0.RELEASE） 致动器endpoint。

请注意，我没有使用spring-kafka库。

我正在使用以下库：

        <dependency>
            <groupId>org.apache.kafka</groupId>
            <artifactId>kafka-streams</artifactId>
            <version>2.5.0</version>
        </dependency>


        <dependency>
            <groupId>org.apache.kafka</groupId>
            <artifactId>kafka-clients</artifactId>
            <version>2.5.0</version>
        </dependency>

我已经试过这个< code > spring . JMX . enabled = true 了，但是好像没有用。我认为这是因为Spring没有管理Kafka。

有没有一种方法可以将这些JMX度量绑定到千分尺注册表？

我可以使用普罗米修斯提供的jmx-extor完成这项工作，但由于这需要在不同端口上运行的代理，我希望使用默认的千分尺和Spring启动来完成这项工作。

Answer 1

您是否尝试过KafkaClientMetrics、KafkaStreamsMetrics或Kafka消费者度量？Kafka消费者度量通过JMX收集指标，但已弃用以支持KafkaClientMetrics。

您只需要创建它们并绑定到您的注册表：

KafkaConsumer<String, String> consumer;
KafkaProducer<String, String> producer;
MeterRegistry registry;

...

new KafkaClientMetrics(consumer).bindTo(registry);
new KafkaClientMetrics(producer).bindTo(registry);

类似地，对于＜code＞KafkaStreams＜code＞：

new KafkaStreamsMetrics(kafkaStreams).bindTo(registry);

如果Spring不管理您的Kafka组件，那么为什么期望＜code＞Spring.jmx。enabled=true是否执行任何操作？