我有一个运行kafka consumers的应用程序，希望监视从主题中消耗的每条消息的处理时间。该应用程序是一个spring引导应用程序，使用micrometre注册表将kafka消费者指标公开给spring执行器prometheus端点。我可以使用kafka\u consumer\u commit\u latency\u avg\u seconds或kafka\u consumer\u commit\u latency\u max\u seconds监视或警报吗？
我有一个运行kafka consumers的应用程序，希望监视从主题中消耗的每条消息的处理时间。该应用程序是一个spring引导应用程序，使用micrometre注册表将kafka消费者指标公开给spring执行器prometheus端点。我可以使用kafka\u consumer\u commit\u latency\u avg\u seconds或kafka\u consumer\u commit\u latency\u max\u seconds监视或警报吗？
1条答案
按热度按时间btxsgosb1#
这些指标与记录处理时间无关。《SpringKafka》为此提供了衡量标准；看这里。
监视侦听器性能
从版本2.3开始，如果在类路径上检测到测微计，并且应用程序上下文中存在单个测微计注册表，则侦听器容器将自动为侦听器创建和更新测微计计时器。可以通过设置containerproperty来禁用计时器
micrometerEnabled错误的。维护两个计时器—一个用于成功调用侦听器，另一个用于>失败。