io.confluent.kafka.serializers

Class KafkaJsonDeserializerConfig

java.lang.Object

org.apache.kafka.common.config.AbstractConfig

io.confluent.kafka.serializers.KafkaJsonDecoderConfig

io.confluent.kafka.serializers.KafkaJsonDeserializerConfig

public class KafkaJsonDeserializerConfig
extends KafkaJsonDecoderConfig

Deserializer configuration for KafkaJsonDeserializer. It's slightly odd to have this extend KafkaJsonDecoderConfig (in most other cases the Decoder variants extend from the Deserializer version), but the reason is that Decoder} doesn't provide the ability to distinguish between constructing serializers for keys or for values. So the type configuration options do not work with KafkaJsonDecoder.

Field Summary

Fields

Modifier and Type	Field and Description
static String	JSON_KEY_TYPE
static String	JSON_KEY_TYPE_DEFAULT
static String	JSON_KEY_TYPE_DOC
static String	JSON_VALUE_TYPE
static String	JSON_VALUE_TYPE_DEFAULT
static String	JSON_VALUE_TYPE_DOC

Fields inherited from class io.confluent.kafka.serializers.KafkaJsonDecoderConfig

FAIL_UNKNOWN_PROPERTIES, FAIL_UNKNOWN_PROPERTIES_DEFAULT, FAIL_UNKNOWN_PROPERTIES_DOC

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

AUTOMATIC_CONFIG_PROVIDERS_PROPERTY, CONFIG_PROVIDERS_CONFIG

Constructor Summary

Constructors

Constructor and Description
KafkaJsonDeserializerConfig(Map<?,?> props)

Method Summary

Methods inherited from class io.confluent.kafka.serializers.KafkaJsonDecoderConfig

baseConfig

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

documentationOf, equals, get, getBoolean, getClass, getConfiguredInstance, getConfiguredInstance, getConfiguredInstances, getConfiguredInstances, getConfiguredInstances, getDouble, getInt, getList, getLong, getPassword, getShort, getString, hashCode, ignore, logUnused, nonInternalValues, originals, 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

JSON_KEY_TYPE

public static final String JSON_KEY_TYPE

See Also:

Constant Field Values

JSON_KEY_TYPE_DEFAULT

public static final String JSON_KEY_TYPE_DEFAULT

JSON_KEY_TYPE_DOC

public static final String JSON_KEY_TYPE_DOC

See Also:

Constant Field Values

JSON_VALUE_TYPE

public static final String JSON_VALUE_TYPE

See Also:

Constant Field Values

JSON_VALUE_TYPE_DEFAULT

public static final String JSON_VALUE_TYPE_DEFAULT

JSON_VALUE_TYPE_DOC

public static final String JSON_VALUE_TYPE_DOC

See Also:

Constant Field Values

Constructor Detail

KafkaJsonDeserializerConfig

public KafkaJsonDeserializerConfig(Map<?,?> props)