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 java.lang.String |
VERSION_HEADER_KEY |
Constructor and Description |
---|
KafkaExporter(KafkaExporter.Builder builder) |
Modifier and Type | Method and Description |
---|---|
void |
close() |
MetricsCollector |
collector(java.util.function.Predicate<MetricKey> initialMetricsPredicate,
Context context) |
void |
doEmit(MetricKey metricKey,
io.opencensus.proto.metrics.v1.Metric 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 java.lang.String VERSION_HEADER_KEY
public static final byte[] V0_HEADER_BYTES
public KafkaExporter(KafkaExporter.Builder builder)
public void reconfigure(KafkaExporterConfig exporterConfig)
public void doEmit(MetricKey metricKey, io.opencensus.proto.metrics.v1.Metric metric)
doEmit
in interface Exporter
doEmit
in class AbstractExporter
public void close() throws java.lang.Exception
close
in interface java.lang.AutoCloseable
java.lang.Exception
public MetricsCollector collector(java.util.function.Predicate<MetricKey> initialMetricsPredicate, Context context)
collector
in interface MetricsCollectorProvider
public static KafkaExporter.Builder newBuilder()
public static KafkaExporter.Builder newBuilder(KafkaExporterConfig config)
ConfluentTelemetryConfig
.