apache kafka jmx metrics和spring boot

lbsnaicq  于 2021-07-15  发布在  Java
关注(0)|答案(1)|浏览(493)

全部,
我需要将apachekafka指标公开给spring-boot(v2.3.0.release)执行器端点。
请注意,我没有使用 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>

我试过这个 spring.jmx.enabled=true 但这似乎行不通。我想这是因为斯普林没有管理Kafka。
有没有一种方法可以将这些jmx指标绑定到测微计注册表?
我可以使用prometheus提供的jmx导出器来完成这项工作,但是由于这需要在不同的端口上运行代理,所以我希望使用默认的测微计和spring boot来完成这项工作。

8yoxcaq7

8yoxcaq71#

你试过了吗 KafkaClientMetrics , KafkaStreamsMetrics 或者 KafkaConsumerMetrics ? KafkaConsumerMetrics 通过jmx收集度量值,但它被弃用,取而代之的是 KafkaClientMetrics .
您只需创建它们并绑定到注册表:

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

...

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

同样适用于 KafkaStreams :

new KafkaStreamsMetrics(kafkaStreams).bindTo(registry);

如果spring不能管理您的kafka组件,那么您为什么期望 spring.jmx.enabled=true 做什么?

相关问题