public class KafkaExporter extends AbstractExporter
Modifier and Type | Class and Description |
---|---|
static class |
KafkaExporter.Builder |
Modifier and Type | Field and Description |
---|---|
static byte[] |
V1_HEADER_BYTES |
static String |
VERSION_HEADER_KEY |
Constructor and Description |
---|
KafkaExporter(KafkaExporter.Builder builder) |
Modifier and Type | Method and Description |
---|---|
void |
close() |
void |
doEmit(ExportableMetric metric) |
static KafkaExporter.Builder |
newBuilder() |
static KafkaExporter.Builder |
newBuilder(KafkaExporterConfig config)
Create a new Builder using values from the
ConfluentTelemetryConfig . |
void |
setMetricsRegistry(org.apache.kafka.common.metrics.Metrics metrics)
Set the Metrics registry on this Exporter.
|
emit, getPredicate, reconfigurePredicate
public static final String VERSION_HEADER_KEY
public static final byte[] V1_HEADER_BYTES
public KafkaExporter(KafkaExporter.Builder builder)
public void doEmit(ExportableMetric metric)
doEmit
in class AbstractExporter
public void setMetricsRegistry(org.apache.kafka.common.metrics.Metrics metrics)
Exporter
public static KafkaExporter.Builder newBuilder()
public static KafkaExporter.Builder newBuilder(KafkaExporterConfig config)
ConfluentTelemetryConfig
.