public final class AvroMessageSerializer extends java.lang.Object implements InternalSerializer<DatabusMessage>
#send(com.opendxl.streaming.nativeclient.producer.ProducerRecord,
com.opendxl.streaming.nativeclient.producer.Callback)
)} }
before sending a ProducerRecord
Constructor and Description |
---|
AvroMessageSerializer(org.apache.avro.Schema schema)
Constructor
|
Modifier and Type | Method and Description |
---|---|
byte[] |
serialize(DatabusMessage data)
Serialize a message
|
public AvroMessageSerializer(org.apache.avro.Schema schema)
schema
- Avro schemapublic byte[] serialize(DatabusMessage data)
serialize
in interface InternalSerializer<DatabusMessage>
data
- Data to be serialized