Package org.apache.logging.log4j.core.appender.mom.kafka

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 Kafka Producer instances.

Constructor Summary

Constructors

Constructor	Description
DefaultKafkaProducerFactory()

Method Summary

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.

Methods inherited from class java.lang.Object

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

Constructor Details

DefaultKafkaProducerFactory

public DefaultKafkaProducerFactory()

Method Details

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 interface KafkaProducerFactory

Parameters:

config - Kafka Producer configuration properties.

Returns:

a new Kafka Producer.