public class KafkaMetricsCollector extends java.lang.Object implements MetricsCollector
Modifier and Type | Class and Description |
---|---|
static class |
KafkaMetricsCollector.Builder |
static class |
KafkaMetricsCollector.StateLedger
Keeps track of the state of metrics, e.g.
|
Modifier and Type | Field and Description |
---|---|
static java.lang.String |
KAFKA_METRICS_LIB |
LABEL_COLLECTOR, LABEL_LIBRARY, LABEL_ORIGINAL, LIBRARY_NONE
Constructor and Description |
---|
KafkaMetricsCollector(java.util.function.Predicate<MetricKey> metricsPredicate,
Context context,
KafkaMetricsCollector.StateLedger ledger,
java.time.Clock clock) |
Modifier and Type | Method and Description |
---|---|
void |
collect(Exporter exporter) |
static KafkaMetricsCollector.Builder |
newBuilder() |
void |
reconfigurePredicate(java.util.function.Predicate<MetricKey> metricsPredicate)
Reconfigure the metrics predicate.
|
java.lang.String |
toString() |
public static final java.lang.String KAFKA_METRICS_LIB
public KafkaMetricsCollector(java.util.function.Predicate<MetricKey> metricsPredicate, Context context, KafkaMetricsCollector.StateLedger ledger, java.time.Clock clock)
public void reconfigurePredicate(java.util.function.Predicate<MetricKey> metricsPredicate)
MetricsCollector
reconfigurePredicate
in interface MetricsCollector
metricsPredicate
- predicate to switch topublic void collect(Exporter exporter)
collect
in interface MetricsCollector
public java.lang.String toString()
toString
in class java.lang.Object
public static KafkaMetricsCollector.Builder newBuilder()