Class DefaultKafkaProducerFactory
- java.lang.Object
-
- org.apache.logging.log4j.core.appender.mom.kafka.DefaultKafkaProducerFactory
-
- All Implemented Interfaces:
KafkaProducerFactory
public class DefaultKafkaProducerFactory extends Object implements KafkaProducerFactory
Creates Apache KafkaProducer
instances.
-
-
Constructor Summary
Constructors Constructor Description DefaultKafkaProducerFactory()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description org.apache.kafka.clients.producer.Producer<byte[],byte[]>
newKafkaProducer(Properties config)
Creates a new Kafka Producer from the given configuration properties.
-
-
-
Method Detail
-
newKafkaProducer
public org.apache.kafka.clients.producer.Producer<byte[],byte[]> newKafkaProducer(Properties config)
Creates a new Kafka Producer from the given configuration properties.- Specified by:
newKafkaProducer
in interfaceKafkaProducerFactory
- Parameters:
config
- Kafka Producer configuration properties.- Returns:
- a new Kafka
Producer
.
-
-