public class KafkaExporter extends AbstractExporter implements MetricsCollectorProvider
Modifier and Type | Class and Description |
---|---|
static class |
KafkaExporter.Builder |
Modifier and Type | Field and Description |
---|---|
static byte[] |
V0_HEADER_BYTES |
static String |
VERSION_HEADER_KEY |
Constructor and Description |
---|
KafkaExporter(KafkaExporter.Builder builder) |
Modifier and Type | Method and Description |
---|---|
void |
close() |
MetricsCollector |
collector(Context context) |
void |
doEmit(SerializedMetric metric) |
static KafkaExporter.Builder |
newBuilder() |
static KafkaExporter.Builder |
newBuilder(KafkaExporterConfig config)
Create a new Builder using values from the
ConfluentTelemetryConfig . |
void |
reconfigure(KafkaExporterConfig exporterConfig) |
emit, reconfigurePredicate
public static final String VERSION_HEADER_KEY
public static final byte[] V0_HEADER_BYTES
public KafkaExporter(KafkaExporter.Builder builder)
public void reconfigure(KafkaExporterConfig exporterConfig)
public void doEmit(SerializedMetric metric)
doEmit
in class AbstractExporter
public void close() throws Exception
close
in interface AutoCloseable
Exception
public MetricsCollector collector(Context context)
collector
in interface MetricsCollectorProvider
public static KafkaExporter.Builder newBuilder()
public static KafkaExporter.Builder newBuilder(KafkaExporterConfig config)
ConfluentTelemetryConfig
.