Kafka Network Metrics с использованием Metric API

Question

Есть ли способ получить общее время запроса от kafka.network:type=RequestMetrics,name=TotalTimeMs,request={Produce|FetchConsumer|FetchFollower} с помощью API-интерфейса Metrics java?

Используя приведенный ниже код, я могу получить метрику производителя.

for (Entry<MetricName, ? extends Metric> entry : producer.metrics().entrySet()) {
    System.out.println(entry.getKey().name() + " : " + entry.getValue().metricValue());
}

Но я не уверен, как получить показатель TotalTimeMs. Кто-нибудь может указать, как получить то же самое?

Answer 1

kafka.network:type=RequestMetrics,name=RequestsPerSec,request={Produce|FetchConsumer|FetchFollower} доступно в брокере, а не из клиентского приложения.

Вы должны были бы удаленно подключиться к открытому порту JMX на нем, или настроить Prometheus или Jolokia, например, для экспорта этой метрики через HTTP