如何从Vert. x Kafka生产者客户端获取Kafka客户端指标

Question

我是Vert.x的新手，对Kafka来说相对较新。

如何设置我的Vert.x KafkaProducer来导出Prometheus指标？

目前，我可以启用Prometheus度量，如＜code＞vertx_http_server_request_bytes_max＜/code＞并通过Web服务器查看它们：

// simplified

import io.vertx.kafka.client.producer.KafkaProducer;
// ...
Vertx vertx = Vertx.vertx(new VertxOptions().setMetricsOptions(
    new MicrometerMetricsOptions()
        .setPrometheusOptions(new VertxPrometheusOptions().setEnabled(true))
        .setEnabled(true)));
// ...
// set up HttpServer then add a route for the metrics
Router.router(vertx).route("/metrics").handler(PrometheusScrapingHandler.create());
// ...
// create a new io.vertx.kafka.client.producer.KafkaProducer
producer = KafkaProducer.create(vertx, config);

在使用Vert. x之前，我可以使用Apache KafkaProducer并绑定KafkaClientMetrics，如下所示：

import io.micrometer.core.instrument.binder.kafka.KafkaClientMetrics;
import org.apache.kafka.clients.producer.KafkaProducer;
// ...
// after creating a producer
new KafkaClientMetrics(producer).bindTo(BackendRegistries.getDefaultNow());

关于如何获得通常的Kafka客户端指标的任何建议，例如Vert.x KafkaProducer的kafka_producer_buffer_total_bytes和其他指标？

更新:按照Jonatan的建议，查看代码来创建一个SharedProducer，我已经设法让下面的工作:

KafkaWriteStream<String, String> stream = KafkaWriteStream.create(vertx, config);

// unwrap to get org.apache.kafka.clients.producer.Producer
Producer<String, String> apacheProducer = stream.unwrap();

// create io.vertx.kafka.client.producer.KafkaProducer
KafkaProducer vertxProducer = (new KafkaProducerImpl(vertx, stream)).registerCloseHook();

// set up metrics
MeterRegistry registry = BackendRegistries.getDefaultNow();
new KafkaClientMetrics(apacheProducer).bindTo(registry);

我通过触发vertxProducer来测试这一点。send（）并监视Prometheus度量。

Answer 1

千分尺正在为每个KafkaMetric创建一个Meter。它只需调用producer.metrics（）（查看KafkaClientMetrics）即可获取它们。有了这个，您的选项是：

1. 从vert. x Kafka客户端获取KafkaProducer的引用（检查vertx kafka客户端中的SharedProducer）
2. 要求vert. x维护者提供一个metrics（）方法
3. 要求vert. x维护者对他们的客户端进行检测
4. 看看千分尺中Kafka绑定器的旧仪器，它使用JMX创建仪表