public class KafkaClientFactory extends Object
Constructor and Description |
---|
KafkaClientFactory() |
Modifier and Type | Method and Description |
---|---|
org.apache.kafka.clients.producer.KafkaProducer<byte[],io.opentelemetry.proto.metrics.v1.MetricsData> |
get(ProducerClientConfig config,
Properties properties) |
static KafkaClientFactory |
getInstance() |
void |
registerNamedClient(ProducerClientConfig config) |
public static KafkaClientFactory getInstance()
public void registerNamedClient(ProducerClientConfig config)
public org.apache.kafka.clients.producer.KafkaProducer<byte[],io.opentelemetry.proto.metrics.v1.MetricsData> get(ProducerClientConfig config, Properties properties) throws ExecutionException
ExecutionException