我有一个Sping Boot 应用程序,其中包含生产者和几个消费者。我需要展示Kafka指标。为此,我添加了千分尺依赖项,并使用producerFactory. addfields(new MicrometerProducerRegistry <>(meterRegistry))更新我的消费者和生产者日志
此选项不显示应用程序从主题xxx获得了多少消息。仅按消费者显示常用计数消息。示例Kafka_producer_record_send_total{client_id=“producer-1”,Kafka_version=“2.7.1”,spring_id=“producerFactory.producer-1”,} 4.0如何使配置过期以获取更多详细指标。
1条答案
按热度按时间ipakzgxi1#
JMX指标应该已经在Kafka消费者客户端中本地可用(而不是来自ProducerFactory)
records-consumed-total
https://docs.confluent.io/platform/current/kafka/monitoring.html#consumer-metrics