Class AvroConverter<T>
- java.lang.Object
-
- io.apicurio.registry.serde.SchemaResolverConfigurer<S,T>
-
- io.apicurio.registry.utils.converter.SerdeBasedConverter<org.apache.avro.Schema,T>
-
- io.apicurio.registry.utils.converter.AvroConverter<T>
-
- All Implemented Interfaces:
Closeable
,AutoCloseable
,org.apache.kafka.connect.storage.Converter
public class AvroConverter<T> extends SerdeBasedConverter<org.apache.avro.Schema,T>
Avro converter.- Author:
- Ales Justin, Fabian Martinez
-
-
Field Summary
-
Fields inherited from class io.apicurio.registry.utils.converter.SerdeBasedConverter
deserializer, REGISTRY_CONVERTER_DESERIALIZER_PARAM, REGISTRY_CONVERTER_SERIALIZER_PARAM, serializer
-
-
Constructor Summary
Constructors Constructor Description AvroConverter()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected T
applySchema(org.apache.kafka.connect.data.Schema schema, Object value)
void
configure(Map<String,?> configs, boolean isKey)
protected Class<? extends org.apache.kafka.common.serialization.Deserializer>
deserializerClass()
protected Class<? extends org.apache.kafka.common.serialization.Serializer>
serializerClass()
protected org.apache.kafka.connect.data.SchemaAndValue
toSchemaAndValue(T result)
-
Methods inherited from class io.apicurio.registry.utils.converter.SerdeBasedConverter
close, fromConnectData, provideSchema, setDeserializer, setSerializer, toConnectData
-
Methods inherited from class io.apicurio.registry.serde.SchemaResolverConfigurer
configure, getSchemaResolver, setSchemaResolver
-
-
-
-
Method Detail
-
serializerClass
protected Class<? extends org.apache.kafka.common.serialization.Serializer> serializerClass()
- Overrides:
serializerClass
in classSerdeBasedConverter<org.apache.avro.Schema,T>
- See Also:
SerdeBasedConverter.serializerClass()
-
deserializerClass
protected Class<? extends org.apache.kafka.common.serialization.Deserializer> deserializerClass()
- Overrides:
deserializerClass
in classSerdeBasedConverter<org.apache.avro.Schema,T>
- See Also:
SerdeBasedConverter.deserializerClass()
-
configure
public void configure(Map<String,?> configs, boolean isKey)
- Specified by:
configure
in interfaceorg.apache.kafka.connect.storage.Converter
- Overrides:
configure
in classSerdeBasedConverter<org.apache.avro.Schema,T>
-
applySchema
protected T applySchema(org.apache.kafka.connect.data.Schema schema, Object value)
- Overrides:
applySchema
in classSerdeBasedConverter<org.apache.avro.Schema,T>
-
toSchemaAndValue
protected org.apache.kafka.connect.data.SchemaAndValue toSchemaAndValue(T result)
- Overrides:
toSchemaAndValue
in classSerdeBasedConverter<org.apache.avro.Schema,T>
-
-