Package io.apicurio.registry.serde.avro
Class AvroKafkaSerdeConfig
- java.lang.Object
-
- org.apache.kafka.common.config.AbstractConfig
-
- io.apicurio.registry.serde.config.BaseKafkaSerDeConfig
-
- io.apicurio.registry.serde.avro.AvroKafkaSerdeConfig
-
public class AvroKafkaSerdeConfig extends BaseKafkaSerDeConfig
- Author:
- Fabian Martinez
-
-
Field Summary
Fields Modifier and Type Field Description static String
AVRO_DATUM_PROVIDER
static String
AVRO_DATUM_PROVIDER_DEFAULT
static String
AVRO_ENCODING
Used by the Avro serde classes to choose anio.apicurio.registry.serde.avro.AvroEncoding
, for exampleJSON
or BINARY.static String
AVRO_ENCODING_BINARY
static String
AVRO_ENCODING_JSON
static String
USE_SPECIFIC_AVRO_READER
static boolean
USE_SPECIFIC_AVRO_READER_DEFAULT
-
Constructor Summary
Constructors Constructor Description AvroKafkaSerdeConfig(Map<?,?> originals)
Constructor.
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description Class<?>
getAvroDatumProvider()
AvroEncoding
getAvroEncoding()
boolean
useSpecificAvroReader()
-
Methods inherited from class io.apicurio.registry.serde.config.BaseKafkaSerDeConfig
enableConfluentIdHandler, enableHeaders, getHeadersHandler, getIdHandler, useIdOption
-
Methods inherited from class org.apache.kafka.common.config.AbstractConfig
documentationOf, equals, get, getBoolean, getClass, getConfiguredInstance, getConfiguredInstances, getConfiguredInstances, getConfiguredInstances, getDouble, getInt, getList, getLong, getPassword, getShort, getString, hashCode, ignore, logUnused, originals, originals, originalsStrings, originalsWithPrefix, originalsWithPrefix, postProcessParsedConfig, typeOf, unused, values, valuesWithPrefixAllOrNothing, valuesWithPrefixOverride
-
-
-
-
Field Detail
-
AVRO_ENCODING
public static final String AVRO_ENCODING
Used by the Avro serde classes to choose anio.apicurio.registry.serde.avro.AvroEncoding
, for exampleJSON
or BINARY. Serializer and Deserializer configuration must match.- See Also:
- Constant Field Values
-
AVRO_ENCODING_JSON
public static final String AVRO_ENCODING_JSON
- See Also:
- Constant Field Values
-
AVRO_ENCODING_BINARY
public static final String AVRO_ENCODING_BINARY
- See Also:
- Constant Field Values
-
AVRO_DATUM_PROVIDER
public static final String AVRO_DATUM_PROVIDER
- See Also:
- Constant Field Values
-
AVRO_DATUM_PROVIDER_DEFAULT
public static final String AVRO_DATUM_PROVIDER_DEFAULT
-
USE_SPECIFIC_AVRO_READER
public static final String USE_SPECIFIC_AVRO_READER
- See Also:
- Constant Field Values
-
USE_SPECIFIC_AVRO_READER_DEFAULT
public static final boolean USE_SPECIFIC_AVRO_READER_DEFAULT
- See Also:
- Constant Field Values
-
-
Constructor Detail
-
AvroKafkaSerdeConfig
public AvroKafkaSerdeConfig(Map<?,?> originals)
Constructor.- Parameters:
configDef
-originals
-
-
-
Method Detail
-
getAvroEncoding
public AvroEncoding getAvroEncoding()
-
getAvroDatumProvider
public Class<?> getAvroDatumProvider()
-
useSpecificAvroReader
public boolean useSpecificAvroReader()
-
-