如何在Spring Boot Kafka Streams应用中开启Kafka指标？Prometheus无相关指标

一、完善Prometheus采集Kafka指标的配置 #

1. 补全Spring Boot管理端点配置
   在application.yml或application.properties中添加以下配置：

   management:
     endpoints:
       web:
         exposure:
           include: prometheus,health,info
     metrics:
       export:
         prometheus:
           enabled: true
       tags:
         application: ${spring.application.name}
   

   确保Prometheus端点正常暴露，同时开启指标导出开关。

2. 绑定Kafka Streams指标到Micrometer
   若使用Spring Kafka Streams，需手动将KafkaStreams实例与Micrometer绑定：

   @Configuration
   public class KafkaStreamsMetricsConfig {
       @Bean
       public KafkaStreamsMetrics kafkaStreamsMetrics(KafkaStreams kafkaStreams) {
           KafkaStreamsMetrics metrics = new KafkaStreamsMetrics(kafkaStreams);
           Metrics.globalRegistry.register(metrics);
           return metrics;
       }
   }
   

二、解决Streams Builder获取实例空指针问题 #

1. 检查KafkaStreams Bean的初始化逻辑
   空指针通常是因为KafkaStreams Bean未完成初始化就被调用，确保Bean创建逻辑正确：

   @Bean
   public KafkaStreams kafkaStreams(StreamsBuilder streamsBuilder, KafkaStreamsConfiguration streamsConfig) {
       KafkaStreams kafkaStreams = new KafkaStreams(streamsBuilder.build(), streamsConfig);
       kafkaStreams.start();
       // 添加关闭钩子，保证程序退出时正常关闭流
       Runtime.getRuntime().addShutdownHook(new Thread(kafkaStreams::close));
       return kafkaStreams;
   }
   

2. 用@DependsOn控制Bean加载顺序
   如果指标配置类依赖KafkaStreams Bean，添加@DependsOn注解明确加载顺序：

   @Configuration
   @DependsOn("kafkaStreams")
   public class KafkaStreamsMetricsConfig {
       // 指标绑定代码
   }
   

3. 避免直接从Streams Builder获取实例
   StreamsBuilder仅用于构建拓扑，真正运行的实例是KafkaStreams对象，直接注入KafkaStreams Bean即可，不要从Builder中强行获取实例。

三、额外验证步骤 #

• 检查spring.kafka.streams.metrics-recording-level配置，确保指标采集级别正确：

  spring:
    kafka:
      streams:
        metrics-recording-level: INFO
  

• 访问/actuator/prometheus端点，搜索kafka_streams_前缀的指标，确认是否已生成。

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