@Incubating(since="1.4.0") @NonNullApi @NonNullFields public class KafkaClientMetrics extends java.lang.Object
It is based on the Kafka client's metrics()
method returning a Metric
map.
Meter names have the following convention: kafka.(metric_group).(metric_name)
Constructor and Description |
---|
KafkaClientMetrics(org.apache.kafka.clients.admin.AdminClient adminClient)
Kafka
AdminClient metrics binder |
KafkaClientMetrics(org.apache.kafka.clients.admin.AdminClient adminClient,
java.lang.Iterable<Tag> tags)
Kafka
AdminClient metrics binder |
KafkaClientMetrics(org.apache.kafka.clients.consumer.Consumer<?,?> kafkaConsumer)
Kafka
Consumer metrics binder |
KafkaClientMetrics(org.apache.kafka.clients.consumer.Consumer<?,?> kafkaConsumer,
java.lang.Iterable<Tag> tags)
Kafka
Consumer metrics binder |
KafkaClientMetrics(org.apache.kafka.clients.producer.Producer<?,?> kafkaProducer)
Kafka
Producer metrics binder |
KafkaClientMetrics(org.apache.kafka.clients.producer.Producer<?,?> kafkaProducer,
java.lang.Iterable<Tag> tags)
Kafka
Producer metrics binder |
Modifier and Type | Method and Description |
---|---|
void |
bindTo(MeterRegistry registry) |
void |
close() |
public KafkaClientMetrics(org.apache.kafka.clients.producer.Producer<?,?> kafkaProducer, java.lang.Iterable<Tag> tags)
Producer
metrics binderkafkaProducer
- producer instance to be instrumentedtags
- additional tagspublic KafkaClientMetrics(org.apache.kafka.clients.producer.Producer<?,?> kafkaProducer)
Producer
metrics binderkafkaProducer
- producer instance to be instrumentedpublic KafkaClientMetrics(org.apache.kafka.clients.consumer.Consumer<?,?> kafkaConsumer, java.lang.Iterable<Tag> tags)
Consumer
metrics binderkafkaConsumer
- consumer instance to be instrumentedtags
- additional tagspublic KafkaClientMetrics(org.apache.kafka.clients.consumer.Consumer<?,?> kafkaConsumer)
Consumer
metrics binderkafkaConsumer
- consumer instance to be instrumentedpublic KafkaClientMetrics(org.apache.kafka.clients.admin.AdminClient adminClient, java.lang.Iterable<Tag> tags)
AdminClient
metrics binderadminClient
- instance to be instrumentedtags
- additional tagspublic KafkaClientMetrics(org.apache.kafka.clients.admin.AdminClient adminClient)
AdminClient
metrics binderadminClient
- instance to be instrumentedpublic void bindTo(MeterRegistry registry)
bindTo
in interface MeterBinder
public void close()
close
in interface java.lang.AutoCloseable