com.opendxl.databus.serialization.internal

Class AvroMessageSerializer

java.lang.Object

com.opendxl.databus.serialization.internal.AvroMessageSerializer

All Implemented Interfaces:

InternalSerializer<DatabusMessage>

public final class AvroMessageSerializer
extends java.lang.Object
implements InternalSerializer<DatabusMessage>

Avro Message Serializer It used internally by #send(com.opendxl.streaming.nativeclient.producer.ProducerRecord, com.opendxl.streaming.nativeclient.producer.Callback) )} } before sending a ProducerRecord

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
byte[]	serialize(DatabusMessage data) Serialize a message

Methods inherited from class java.lang.Object

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

Constructor Detail

AvroMessageSerializer

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

Constructor

Parameters:

schema - Avro schema

Method Detail

serialize

public byte[] serialize(DatabusMessage data)

Serialize a message

Specified by:

serialize in interface InternalSerializer<DatabusMessage>

Parameters:

data - Data to be serialized

Returns:

A serialized avro message as byte[]