@Incubating(since="1.4.0") @NonNullApi @NonNullFields public class KafkaStreamsMetrics 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 |
---|
KafkaStreamsMetrics(org.apache.kafka.streams.KafkaStreams kafkaStreams)
KafkaStreams metrics binder |
KafkaStreamsMetrics(org.apache.kafka.streams.KafkaStreams kafkaStreams,
java.lang.Iterable<Tag> tags)
KafkaStreams metrics binder |
Modifier and Type | Method and Description |
---|---|
void |
bindTo(MeterRegistry registry) |
void |
close() |
public KafkaStreamsMetrics(org.apache.kafka.streams.KafkaStreams kafkaStreams, java.lang.Iterable<Tag> tags)
KafkaStreams
metrics binderkafkaStreams
- instance to be instrumentedtags
- additional tagspublic KafkaStreamsMetrics(org.apache.kafka.streams.KafkaStreams kafkaStreams)
KafkaStreams
metrics binderkafkaStreams
- instance to be instrumentedpublic void bindTo(MeterRegistry registry)
bindTo
in interface MeterBinder
public void close()
close
in interface java.lang.AutoCloseable