Package com.solace.serdes.avro

Class AvroDeserializer<T>

java.lang.Object

com.solace.serdes.common.AbstractDeserializer<T,org.apache.avro.Schema>

com.solace.serdes.avro.AvroDeserializer<T>

Type Parameters:

T - The type of object this deserializer produces.

All Implemented Interfaces:

com.solace.serdes.Deserializer<T>, Closeable, AutoCloseable

public class AvroDeserializer<T>
extends AbstractDeserializer<T,org.apache.avro.Schema>

A deserializer for Avro-formatted data that converts byte arrays into objects of type T. This class extends AbstractDeserializer and implements the deserialization logic specific to Avro schemas. Supported Avro types include GenericRecord and SpecificRecord.
AvroDeserializer does not support non-header decoding of schema ID. Must use AbstractDeserializer.deserialize(String, byte[], Map) to ensure the schema ID is available for schema resolution. Using AbstractDeserializer.deserialize(String, byte[]) will not resolve the payload schema.
Note: A Vertx connection will be made when configuring this AvroDeserializer. Vertx threads are non-daemon and will prevent JVM exit, so always remember to call AbstractDeserializer.close().

See Also:

AvroProperties, AvroHeaders

Constructor Summary

Constructors

Constructor	Description
AvroDeserializer()	Creates an instance of an AvroDeserializer.

Method Summary

Modifier and Type	Method	Description
void	configure(Map<String,?> properties)	Configures the deserializer with the given properties.

Methods inherited from class com.solace.serdes.common.AbstractDeserializer

close, deserialize, deserialize

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

AvroDeserializer

public AvroDeserializer()

Creates an instance of an AvroDeserializer. Once created, configure(java.util.Map) must be called to use this instance.

Method Detail

configure

public void configure(Map<String,?> properties)

Configures the deserializer with the given properties. Properties are defined in AvroProperties and SerdeProperties
Note: A Vertx connection will be made when configuring this AvroDeserializer. Vertx threads are non-daemon and will prevent JVM exit, so always remember to call AbstractDeserializer.close().

Specified by:

configure in interface com.solace.serdes.Deserializer<T>

Overrides:

configure in class AbstractDeserializer<T,org.apache.avro.Schema>

Parameters:

properties - A Map containing configuration properties.

See Also:

AvroProperties, SerdeProperties