Spring Boot 2.2.6如何将Kafka生产者指标暴露给Prometheus

Spring Boot 2.2.6 版本未实现Kafka客户端到Micrometer指标体系的自动绑定，仅开启JMX无法让Prometheus端点采集到Kafka生产者指标，核心问题点有两个：

• 该版本自动配置的KafkaTemplate、生产者工厂默认不会注册Micrometer提供的Kafka指标采集监听器，JMX输出的Kafka指标与Prometheus依赖的Micrometer指标是两套独立采集链路，开启JMX不会自动完成指标桥接。
• 现有配置存在两处缺失：一是未显式开启Kafka客户端的指标上报配置，二是末尾的HTTP指标直方图配置值拼写截断为tr，虽不影响Kafka指标，但会导致HTTP服务直方图配置不生效。

1. 确认依赖完整性 #

确保项目已引入Prometheus注册表依赖，Maven配置如下：

<dependency>
    <groupId>io.micrometer</groupId>
    <artifactId>micrometer-registry-prometheus</artifactId>
</dependency>

Gradle配置如下：

implementation 'io.micrometer:micrometer-registry-prometheus'

Spring Boot 2.2.6内置的Micrometer版本与Kafka 2.3.7完全兼容，无需手动调整依赖版本

2. 修正配置文件 #

原有配置中spring.jmx.enabled=true可保留（供JMX采集场景使用），但对Prometheus指标采集无帮助，修正后的完整配置如下：

management.endpoint.health.show-details=always
management.endpoint.metrics.enabled=true
management.endpoint.prometheus.enabled=true
management.endpoints.web.exposure.include=*
# 修正拼写错误的HTTP服务直方图配置
management.metrics.distribution.percentiles-histogram.http.server.requests=true
# 开启Kafka客户端指标上报
spring.kafka.producer.properties.metric.reporters=org.apache.kafka.common.metrics.MetricsReporter

3. 手动绑定Kafka生产者指标到Micrometer #

Spring Boot 2.2.x没有提供该绑定的自动配置，需要手动添加配置类注册监听器：

import io.micrometer.core.instrument.MeterRegistry;
import org.springframework.boot.autoconfigure.kafka.DefaultKafkaProducerFactoryCustomizer;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.kafka.core.MicrometerProducerListener;

@Configuration
public class KafkaMetricsConfig {
    @Bean
    public DefaultKafkaProducerFactoryCustomizer producerMetricsBinding(MeterRegistry meterRegistry) {
        return factory -> factory.addListener(new MicrometerProducerListener<>(meterRegistry));
    }
}

如果项目同时使用Kafka消费者，新增同模式的MicrometerConsumerListener绑定即可采集消费者侧指标。

验证方法 #

服务启动后直接访问/actuator/prometheus端点，搜索kafka_producer_前缀的指标，例如kafka_producer_record_send_total（生产者发送消息总数）、kafka_producer_request_latency_avg（平均请求延迟），能查到对应指标说明配置生效，Prometheus同步采集后即可正常查询。

内容的提问来源于stack exchange，提问作者Trupti Prajapati