使用带有手动计数器增量的千分尺计时器

Question

我有一个 KafkaListener，它接收包含对象列表的消息。

@KafkaListener(
    id = "dataConsumer",
    topics = "data.topic",
    groupId = "${spring.kafka.consumer.group-id}",
    containerFactory = "dataKafkaListenerContainerFactory")
public void consumeData(DataContainer message) {
    List<Data> data = message.getList();
    ...
}

对象列表的大小可能不同，因此每条消息的指标可能没有用。

我可以通过转到/actuator/metrics/spring.kafka.listener?tag=name:dataConsumer-0 来获取此方法的计时器指标，但计数是针对消息而不是消息中的元素列表。如何切换此指标或为消息中数据元素的时间和计数制定类似指标？

Answer 1

您可以使用MeterRegistry 注册自己的Meter - 请参阅Micrometer Documentation。