如何找到Kafka消息的处理时间？

Question

我有一个运行 Kafka 消费者的应用程序，并且想要监控从该主题消费的每条消息的处理时间。该应用程序是一个 Spring 启动应用程序，并使用微米注册表将 Kafka 消费者指标公开给 Spring Actuator Prometheus 端点。 是否可以使用 kafka_consumer_commit_latency_avg_seconds 或 kafka_consumer_commit_latency_max_seconds 进行监控或告警？

Answer 1

这些指标与记录处理时间无关。 spring-kafka 为此提供了指标；见here。

监控监听器性能

从 2.3 版开始，如果在类路径上检测到 Micrometer，并且应用程序上下文中存在单个 MeterRegistry，则侦听器容器将自动为侦听器创建和更新 Micrometer Timer。可以通过将 ContainerProperty micrometerEnabled 设置为 false 来禁用计时器。

维护了两个计时器 - 一个用于成功调用侦听器，一个用于>失败。