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> metricWhitelistFilter,
Context context,
java.lang.String domain,
KafkaMetricsCollector.StateLedger ledger,
java.time.Clock clock) |
Modifier and Type | Method and Description |
---|---|
void |
collect(Exporter exporter) |
static KafkaMetricsCollector.Builder |
newBuilder() |
static KafkaMetricsCollector.Builder |
newBuilder(ConfluentTelemetryConfig config)
Create a new Builder using values from the
ConfluentTelemetryConfig . |
java.lang.String |
toString() |
public static final java.lang.String KAFKA_METRICS_LIB
public KafkaMetricsCollector(java.util.function.Predicate<MetricKey> metricWhitelistFilter, Context context, java.lang.String domain, KafkaMetricsCollector.StateLedger ledger, java.time.Clock clock)
public void collect(Exporter exporter)
collect
in interface MetricsCollector
public java.lang.String toString()
toString
in class java.lang.Object
public static KafkaMetricsCollector.Builder newBuilder(ConfluentTelemetryConfig config)
ConfluentTelemetryConfig
.public static KafkaMetricsCollector.Builder newBuilder()