我如何找到 kafka 消费者的费率?

Raj*_*gir 2 apache-kafka kafka-consumer-api

有什么方法可以找到 kafka 消费者消费消息的速度吗?像 5000 条消息/秒

Mic*_*son 6

KafkaConsumer 客户端公开了许多指标,包括消息速率。

度量已命名kafka.consumer:type=consumer-fetch-manager-metrics,client-id="{client-id}",消息速率的属性为records-consumed-rate

检查Kafka 文档中的消费者指标列表。

指标通过 JMX 公开,您可以触发jconsole以快速访问它们。消费者还允许通过metrics()方法直接访问它们