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(ContextExportableMetric 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) Sets the Metrics registry for this exporter.

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

emit, getName, 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(ContextExportableMetric 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)

Sets the Metrics registry for this exporter.

The Metrics object is associated with the TelemetryReporter instance. When the TelemetryReporter is reconfigured, the old KafkaExporter instance is closed, and a new KafkaExporter instance is created.

The null check if (metrics.metric(exporterMetricName) == null) is essential because the created KafkaExporter instance receives the same Metrics object. Since KafkaProducer can be shared by the exporters, we need to make sure that the same metric is not already registered with this Metrics instance.

Parameters:

metrics - The Metrics registry to use.

newBuilder

public static KafkaExporter.Builder newBuilder()

newBuilder

public static KafkaExporter.Builder newBuilder(KafkaExporterConfig config)

Create a new Builder using values from the ConfluentTelemetryConfig.