Синхронизированная аннотация микрометра на Kafka Listener

У меня есть синхронизированная аннотация Micrometer в Kafka Listener, по какой-то причине я не получаю эти метрики. У меня есть другие метрики для счетчиков, которые я мог бы видеть сгенерированными. Просто хотел дважды проверить, работает ли аннотация @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) {

spring-kafka spring-micrometer
person Leo Prince    schedule 10.05.2020    source источник

Ответы (1)


arrow_upward
1
arrow_downward

Я не могу придумать ничего, что могло бы помешать @Timed работе с @KafkaListener (но я не тестировал это).

Тем не менее, начиная с версии 2.3, контейнер уже поддерживает Timers для слушателей.

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

person Gary Russell    schedule 11.05.2020
comment
Спасибо, мы можем использовать таймер 2.3 для слушателей. - person Leo Prince; 12.05.2020
comment
Я вижу таймер, но не вижу сегментов, только sum _count и _max. Я использую Прометей в качестве системы мониторинга. - person soltzu; 13.04.2021