io.confluent.telemetry.exporter.kafka

Class KafkaExporter

java.lang.Object

io.confluent.telemetry.exporter.AbstractExporter

io.confluent.telemetry.exporter.kafka.KafkaExporter

All Implemented Interfaces:

Exporter, AutoCloseable

public class KafkaExporter
extends AbstractExporter

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	KafkaExporter.Builder

Field Summary

Fields

Modifier and Type	Field and Description
static byte[]	V1_HEADER_BYTES
static String	VERSION_HEADER_KEY

Constructor Summary

Constructors

Constructor and Description
KafkaExporter(KafkaExporter.Builder builder)

Method Summary

Modifier and Type	Method and Description
void	close()
void	doEmit(ExportableMetric metric)
org.apache.kafka.clients.producer.Producer<byte[],io.opentelemetry.proto.metrics.v1.MetricsData>	getProducer()
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.

Methods inherited from class io.confluent.telemetry.exporter.AbstractExporter

emit, getPredicate, reconfigurePredicate

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

VERSION_HEADER_KEY

public static final String VERSION_HEADER_KEY

See Also:

Constant Field Values

V1_HEADER_BYTES

public static final byte[] V1_HEADER_BYTES

Constructor Detail

KafkaExporter

public KafkaExporter(KafkaExporter.Builder builder)

Method Detail

doEmit

public void doEmit(ExportableMetric metric)

Specified by:

doEmit in class AbstractExporter

close

public void close()
           throws Exception

Throws:

Exception

getProducer

public org.apache.kafka.clients.producer.Producer<byte[],io.opentelemetry.proto.metrics.v1.MetricsData> getProducer()

setMetricsRegistry

public void setMetricsRegistry(org.apache.kafka.common.metrics.Metrics metrics)

Description copied from interface: Exporter

Set the Metrics registry on this Exporter. The Exporter can use this to register its own metrics.

newBuilder

public static KafkaExporter.Builder newBuilder()

newBuilder

public static KafkaExporter.Builder newBuilder(KafkaExporterConfig config)

Create a new Builder using values from the ConfluentTelemetryConfig.