public class KafkaMetricsCollector extends 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 String |
KAFKA_METRICS_LIB |
LABEL_COLLECTOR, LABEL_LIBRARY, LABEL_ORIGINAL, LIBRARY_NONE
Constructor and Description |
---|
KafkaMetricsCollector(Context context,
KafkaMetricsCollector.StateLedger ledger,
Clock clock) |
Modifier and Type | Method and Description |
---|---|
void |
collect(Emitter emitter) |
static KafkaMetricsCollector.Builder |
newBuilder() |
String |
toString() |
public static final String KAFKA_METRICS_LIB
public KafkaMetricsCollector(Context context, KafkaMetricsCollector.StateLedger ledger, Clock clock)
public void collect(Emitter emitter)
collect
in interface MetricsCollector
public static KafkaMetricsCollector.Builder newBuilder()