public class KafkaExporter extends java.lang.Object implements Exporter, MetricsCollectorProvider
Modifier and Type | Class and Description |
---|---|
static class |
KafkaExporter.Builder |
Constructor and Description |
---|
KafkaExporter(KafkaExporter.Builder builder) |
Modifier and Type | Method and Description |
---|---|
void |
close() |
MetricsCollector |
collector(ConfluentTelemetryConfig config,
Context context,
java.lang.String domain) |
void |
emit(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 . |
public KafkaExporter(KafkaExporter.Builder builder)
public void emit(io.opencensus.proto.metrics.v1.Metric metric)
public void close() throws java.lang.Exception
close
in interface java.lang.AutoCloseable
java.lang.Exception
public MetricsCollector collector(ConfluentTelemetryConfig config, Context context, java.lang.String domain)
collector
in interface MetricsCollectorProvider
public static KafkaExporter.Builder newBuilder()
public static KafkaExporter.Builder newBuilder(KafkaExporterConfig config)
ConfluentTelemetryConfig
.