Клиент KafkaConsumer предоставляет ряд метрик, включая скорость сообщения.
Метрика имеет имя kafka.consumer:type=consumer-fetch-manager-metrics,client-id="{client-id}", а атрибут для скорости сообщения: records-consumed-rate.
Проверьте метрики потребителя.список в документах Kafka .
Метрики доступны через JMX, вы можете запустить jconsole для быстрого доступа к ним.Потребитель также позволяет получить к ним доступ напрямую через метод metrics ()