Kafka Listener 上的 Micrometer 定时注释

Question

由于某种原因，我在 Kafka Listener 上有 Micrometer 定时注释，但我没有生成此指标。我还有其他计数器指标，我可以看到它们已生成。只是想仔细检查 @Timed 注释是否适用于 @KafkaListener ？

@Timed(value = "kafka.consumer.processing.time", percentiles = {0.75, 0.90, 0.95})
@KafkaListener(topics = "${kafka.input.topic}", groupId = "${kafka.consumer.group.id}")
public void consumeFromInputTopic(ConsumerRecord<String, String> record) {

Answer 1

我认为没有什么可以阻止 @Timed 使用 @KafkaListener（但我还没有测试过）。

也就是说，从 2.3 版开始，容器已经为侦听器维护了 Timers

https://docs.spring.io/spring-kafka/docs/2.4.6.RELEASE/reference/html/#micrometer

Kafka Listener 上的 Micrometer 定时注释

Micrometer timed annotation on Kafka Listener

spring-kafka

spring-micrometer