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 and Description
DefaultKafkaProducerFactory()

Method Summary

Modifier and Type	Method and 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 Detail

DefaultKafkaProducerFactory

public DefaultKafkaProducerFactory()

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

Parameters:

config - Kafka Producer configuration properties.

Returns:

a new Kafka Producer.