com.tibco.messaging.kafka.avro

Class AvroSerializer

java.lang.Object

com.tibco.messaging.kafka.avro.AvroSerDe

com.tibco.messaging.kafka.avro.AvroSerializer

All Implemented Interfaces:

java.io.Closeable, java.lang.AutoCloseable, org.apache.kafka.common.serialization.Serializer<java.lang.Object>

public class AvroSerializer
extends AvroSerDe
implements org.apache.kafka.common.serialization.Serializer<java.lang.Object>

Field Summary

Fields inherited from class com.tibco.messaging.kafka.avro.AvroSerDe

isKey, keySubjectName, schemaRegistrationStrategy, valueSubjectName

Constructor Summary

Constructors

Constructor and Description
AvroSerializer()

Method Summary

Modifier and Type	Method and Description
byte[]	serialize(java.lang.String subject, java.lang.Object data)

Methods inherited from class com.tibco.messaging.kafka.avro.AvroSerDe

close, configure, configure

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.kafka.common.serialization.Serializer

close, configure, serialize

Constructor Detail

AvroSerializer

public AvroSerializer()

Method Detail

serialize

public byte[] serialize(java.lang.String subject,
                        java.lang.Object data)

Specified by:

serialize in interface org.apache.kafka.common.serialization.Serializer<java.lang.Object>