io.confluent.telemetry.exporter.kafka

Class KafkaClientFactory

java.lang.Object

io.confluent.telemetry.exporter.kafka.KafkaClientFactory

public class KafkaClientFactory
extends Object

Constructor Summary

Constructors

Constructor and Description
KafkaClientFactory()

Method Summary

Modifier and Type	Method and Description
org.apache.kafka.clients.producer.Producer<byte[],io.opentelemetry.proto.metrics.v1.MetricsData>	get(ProducerClientConfig producerConfig, Properties properties)
static KafkaClientFactory	getInstance()

Methods inherited from class java.lang.Object

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

Constructor Detail

KafkaClientFactory

public KafkaClientFactory()

Method Detail

getInstance

public static KafkaClientFactory getInstance()

get

public org.apache.kafka.clients.producer.Producer<byte[],io.opentelemetry.proto.metrics.v1.MetricsData> get(ProducerClientConfig producerConfig,
                                                                                                            Properties properties)