Package io.streamthoughts.azkarra.commons.error

Class DeadLetterTopicExceptionHandlerConfig

java.lang.Object

org.apache.kafka.common.config.AbstractConfig

io.streamthoughts.azkarra.commons.error.DeadLetterTopicExceptionHandlerConfig

public class DeadLetterTopicExceptionHandlerConfig
extends org.apache.kafka.common.config.AbstractConfig

Config class for DeadLetterTopicExceptionHandler.

Field Summary

Fields

Modifier and Type	Field	Description
static String	DEAD_LETTER_HEADERS_PREFIX
static String	DEAD_LETTER_PRODUCER_CONFIG
static String	DEAD_LETTER_TOPIC_CONFIG
static String	DEAD_LETTER_TOPIC_DOC
static String	FATAL_ERRORS_CONFIG
static String	FATAL_ERRORS_DOC

Fields inherited from class org.apache.kafka.common.config.AbstractConfig

CONFIG_PROVIDERS_CONFIG

Constructor Summary

Constructors

Constructor	Description
DeadLetterTopicExceptionHandlerConfig(Map<String,?> originals)	Creates a new DeadLetterTopicExceptionHandlerConfig instance.

Method Summary

Modifier and Type	Method	Description
static org.apache.kafka.common.config.ConfigDef	configDef()
Map<String,Object>	customHeaders()
List<Class<?>>	getFatalExceptions()
String	outputTopic()
Map<String,Object>	producerConfigs()

Methods inherited from class org.apache.kafka.common.config.AbstractConfig

equals, get, getBoolean, getClass, getConfiguredInstance, getConfiguredInstances, getConfiguredInstances, getConfiguredInstances, getDouble, getInt, getList, getLong, getPassword, getShort, getString, hashCode, ignore, logUnused, originals, originalsStrings, originalsWithPrefix, originalsWithPrefix, postProcessParsedConfig, typeOf, unused, values, valuesWithPrefixAllOrNothing, valuesWithPrefixOverride

Methods inherited from class java.lang.Object

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

Field Detail

DEAD_LETTER_TOPIC_CONFIG

public static final String DEAD_LETTER_TOPIC_CONFIG

See Also:

Constant Field Values

DEAD_LETTER_TOPIC_DOC

public static final String DEAD_LETTER_TOPIC_DOC

See Also:

Constant Field Values

FATAL_ERRORS_CONFIG

public static final String FATAL_ERRORS_CONFIG

See Also:

Constant Field Values

FATAL_ERRORS_DOC

public static final String FATAL_ERRORS_DOC

See Also:

Constant Field Values

DEAD_LETTER_PRODUCER_CONFIG

public static final String DEAD_LETTER_PRODUCER_CONFIG

See Also:

Constant Field Values

DEAD_LETTER_HEADERS_PREFIX

public static final String DEAD_LETTER_HEADERS_PREFIX

See Also:

Constant Field Values

Constructor Detail

DeadLetterTopicExceptionHandlerConfig

public DeadLetterTopicExceptionHandlerConfig(Map<String,?> originals)

Creates a new DeadLetterTopicExceptionHandlerConfig instance.

Parameters:

originals - the original configs.

Method Detail

outputTopic

public String outputTopic()

customHeaders

public Map<String,Object> customHeaders()

producerConfigs

public Map<String,Object> producerConfigs()

getFatalExceptions

public List<Class<?>> getFatalExceptions()

configDef

public static org.apache.kafka.common.config.ConfigDef configDef()