Kafka 生产者指标

Question

我是 运行 使用我的 Intellij IDE 的本地机器中的 Kafka 生产者，生产者将生产一百万条记录。在这样做的同时，我想通过以下方式捕获生产者指标：

我知道 kafka 的 JMX 端口，我确实尝试将 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 感兴趣。