Micrometer的@Timed注解不生效 指标未在Prometheus展示

@Timed注解基于Spring AOP实现，只有被Spring代理对象拦截到的方法调用才会织入指标统计逻辑。默认情况下@KafkaListener标记的消费方法是由Kafka监听容器直接通过反射调用的，不会走Spring代理的拦截链路，因此注解不会生效；而手动声明的Timer是直接调用Micrometer API埋点，不依赖AOP代理，所以可以正常上报。

按优先级从高到低选择以下方案即可：

• 方案1：拆分消费逻辑到Service层（最推荐，符合分层规范，无侵入）
  不要直接在Kafka监听类的方法上加@Timed，将实际消费逻辑下沉到Spring管理的Service类中，把@Timed注解加在Service的公共方法上。因为Listener中注入的Service是Spring代理对象，方法调用会被AOP正常拦截，注解即可生效：

  @Component
  @RequiredArgsConstructor
  public class KafkaMsgListener {
      private final MsgConsumeService msgConsumeService;
  
      @KafkaListener(topics = "your-topic")
      public void consume(String message) {
          // 仅做参数透传
          msgConsumeService.handleConsume(message);
      }
  }
  
  @Component
  public class MsgConsumeService {
      // @Timed加在Service公共方法上，可被AOP正常拦截
      @Timed(value = "kafka.consumed.messages")
      public void handleConsume(String message) {
          // 编写实际消费逻辑
      }
  }
  

• 方案2：手动埋点包裹消费逻辑（最稳定，无AOP依赖）
  如果不想拆分逻辑，可以直接在消费方法里用手动Timer埋点，和你项目中已有的手动指标写法保持一致，完全绕过AOP代理的限制，不会出现不生效的问题：

  @Component
  @RequiredArgsConstructor
  public class KafkaMsgListener {
      private final MeterRegistry meterRegistry;
  
      @KafkaListener(topics = "your-topic")
      public void consume(String message) {
          Timer.Sample sample = Timer.start(meterRegistry);
          try {
              // 编写实际消费逻辑
          } finally {
              sample.stop(meterRegistry.timer("kafka.consumed.messages"));
          }
      }
  }
  

• 方案3：补全基础切面配置
  如果项目中所有位置的@Timed注解都不生效，说明你没有注册TimedAspect核心切面，添加以下Bean即可：

  @Bean
  public TimedAspect timedAspect(MeterRegistry registry) {
      return new TimedAspect(registry);
  }
  

• 被@Timed标记的方法必须是public修饰、非final的，否则Spring AOP无法拦截
• 不要在类内部直接调用自身加了@Timed的方法，这类自调用同样会绕过代理，导致注解失效

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