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

Class KafkaManager

java.lang.Object

org.apache.logging.log4j.core.appender.AbstractManager

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

public class KafkaManager
extends AbstractManager

Field Summary

Fields

Modifier and Type	Field and Description
static String	DEFAULT_TIMEOUT_MILLIS

Fields inherited from class org.apache.logging.log4j.core.appender.AbstractManager

count, LOGGER

Constructor Summary

Constructors

Constructor and Description
KafkaManager(String name, String topic, Property[] properties)

Method Summary

Modifier and Type	Method and Description
void	releaseSub() May be overridden by Managers to perform processing while the Manager is being released and the lock is held.
void	send(byte[] msg)
void	startup()

Methods inherited from class org.apache.logging.log4j.core.appender.AbstractManager

getContentFormat, getCount, getManager, getName, hasManager, release

Methods inherited from class java.lang.Object

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

Field Detail

DEFAULT_TIMEOUT_MILLIS

public static final String DEFAULT_TIMEOUT_MILLIS

See Also:

Constant Field Values

Constructor Detail

KafkaManager

public KafkaManager(String name,
                    String topic,
                    Property[] properties)

Method Detail

releaseSub

public void releaseSub()

Description copied from class: AbstractManager

May be overridden by Managers to perform processing while the Manager is being released and the lock is held.

Overrides:

releaseSub in class AbstractManager

send

public void send(byte[] msg)
          throws ExecutionException,
                 InterruptedException,
                 TimeoutException

Throws:

ExecutionException

InterruptedException

TimeoutException

startup

public void startup()