Кафка Продюсер Метрики

Question

Я работаю с производителем Kafka на локальной машине, используя мою Intellij IDE, и продюсер будет выпускать миллион записей. При этом я хочу получить показатели производителя следующим образом:

Мне известно о порте JMX для kafka, и я попытался установить порт Kafka JMX на 9999. Но я не уверен, сможем ли мы получить метрики с помощью JConsole или JVisualVM описанным выше способом, которого я ожидаю.

Может ли кто-нибудь предложить какую-либо идею относительно того, как этого можно достичь?

Answer 1

Помимо JMX, официальные клиенты Kafka также предоставляют свои метрики через Java API, см. Метод metrics(), чтобы получить их все.

Например, чтобы напечатать все имена и значения метрик:

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

Из всех метрик вас, вероятно, интересуют outgoing-byte-rate, request-total и request-rate.