public static class KafkaMetricsCollector.Builder
extends java.lang.Object
Modifier and Type | Method and Description |
---|---|
KafkaMetricsCollector |
build() |
KafkaMetricsCollector.Builder |
setClock(java.time.Clock clock) |
KafkaMetricsCollector.Builder |
setContext(Context context) |
KafkaMetricsCollector.Builder |
setLedger(KafkaMetricsCollector.StateLedger ledger) |
KafkaMetricsCollector.Builder |
setMetricsPredicate(java.util.function.Predicate<MetricKey> metricsPredicate) |
public KafkaMetricsCollector.Builder setMetricsPredicate(java.util.function.Predicate<MetricKey> metricsPredicate)
public KafkaMetricsCollector.Builder setContext(Context context)
public KafkaMetricsCollector.Builder setClock(java.time.Clock clock)
public KafkaMetricsCollector.Builder setLedger(KafkaMetricsCollector.StateLedger ledger)
public KafkaMetricsCollector build()