Package io.apicurio.registry.serde.avro
Class DefaultAvroDatumProvider<T>
- java.lang.Object
-
- io.apicurio.registry.serde.avro.DefaultAvroDatumProvider<T>
-
- All Implemented Interfaces:
AvroDatumProvider<T>
public class DefaultAvroDatumProvider<T> extends Object implements AvroDatumProvider<T>
- Author:
- Ales Justin
-
-
Constructor Summary
Constructors Constructor Description DefaultAvroDatumProvider()
DefaultAvroDatumProvider(boolean useSpecificAvroReader)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
configure(AvroKafkaSerdeConfig config)
org.apache.avro.io.DatumReader<T>
createDatumReader(org.apache.avro.Schema schema)
org.apache.avro.io.DatumWriter<T>
createDatumWriter(T data, org.apache.avro.Schema schema)
DefaultAvroDatumProvider<T>
setUseSpecificAvroReader(boolean useSpecificAvroReader)
org.apache.avro.Schema
toSchema(T data)
-
-
-
Method Detail
-
setUseSpecificAvroReader
public DefaultAvroDatumProvider<T> setUseSpecificAvroReader(boolean useSpecificAvroReader)
-
configure
public void configure(AvroKafkaSerdeConfig config)
- Specified by:
configure
in interfaceAvroDatumProvider<T>
-
createDatumWriter
public org.apache.avro.io.DatumWriter<T> createDatumWriter(T data, org.apache.avro.Schema schema)
- Specified by:
createDatumWriter
in interfaceAvroDatumProvider<T>
-
createDatumReader
public org.apache.avro.io.DatumReader<T> createDatumReader(org.apache.avro.Schema schema)
- Specified by:
createDatumReader
in interfaceAvroDatumProvider<T>
-
toSchema
public org.apache.avro.Schema toSchema(T data)
- Specified by:
toSchema
in interfaceAvroDatumProvider<T>
-
-