com.opendxl.databus.serialization.internal

Class AvroMessageDeserializer

java.lang.Object

com.opendxl.databus.serialization.internal.AvroMessageDeserializer

All Implemented Interfaces:

InternalDeserializer<DatabusMessage>

public final class AvroMessageDeserializer
extends java.lang.Object
implements InternalDeserializer<DatabusMessage>

Avro Message Deserializer It used internally by Consumer.poll(long) } after reading a ConsumerRecord

Constructor Summary

Constructors

Constructor and Description
AvroMessageDeserializer(org.apache.avro.Schema schema) Constructor

Method Summary

Modifier and Type	Method and Description
DatabusMessage	deserialize(java.lang.String topic, byte[] data) Deserialize a message

Methods inherited from class java.lang.Object

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

Constructor Detail

AvroMessageDeserializer

public AvroMessageDeserializer(org.apache.avro.Schema schema)

Constructor

Parameters:

schema - Avro schema.

Method Detail

deserialize

public DatabusMessage deserialize(java.lang.String topic,
                                  byte[] data)

Deserialize a message

Specified by:

deserialize in interface InternalDeserializer<DatabusMessage>

Parameters:

data - The data to serialize.

topic - the topic where the message comes from

Returns:

A DatabusMessage instance.