public class KafkaClientFactory extends Object
Constructor and Description |
---|
KafkaClientFactory() |
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() |
public static KafkaClientFactory getInstance()
public org.apache.kafka.clients.producer.Producer<byte[],io.opentelemetry.proto.metrics.v1.MetricsData> get(ProducerClientConfig producerConfig, Properties properties)