Package io.streamthoughts.azkarra.commons.error

Class SafeDeserializerConfig

java.lang.Object

org.apache.kafka.common.config.AbstractConfig

io.streamthoughts.azkarra.commons.error.SafeDeserializerConfig

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

Field Summary

Fields

Modifier and Type	Field	Description
static String	SAFE_DESERIALIZER_DEFAULT_VALUE_CONFIG
static String	SAFE_DESERIALIZER_DEFAULT_VALUE_DOC

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

CONFIG_PROVIDERS_CONFIG

Constructor Summary

Constructors

Constructor	Description
SafeDeserializerConfig(Class<?> objectValueType, Map<?,?> originals)	Creates a new SafeDeserializerConfig instance.

Method Summary

Modifier and Type	Method	Description
static org.apache.kafka.common.config.ConfigDef	configDef(org.apache.kafka.common.config.ConfigDef.Type type)
Object	defaultObject()

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

SAFE_DESERIALIZER_DEFAULT_VALUE_CONFIG

public static final String SAFE_DESERIALIZER_DEFAULT_VALUE_CONFIG

See Also:

Constant Field Values

SAFE_DESERIALIZER_DEFAULT_VALUE_DOC

public static final String SAFE_DESERIALIZER_DEFAULT_VALUE_DOC

See Also:

Constant Field Values

Constructor Detail

SafeDeserializerConfig

public SafeDeserializerConfig(Class<?> objectValueType,
                              Map<?,?> originals)

Creates a new SafeDeserializerConfig instance.

Parameters:

originals - the originals configuration.

Method Detail

defaultObject

public Object defaultObject()

configDef

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