com.tibco.messaging.kafka.avro

Class AvroDeserializer

java.lang.Object

com.tibco.messaging.kafka.avro.AvroSerDe

com.tibco.messaging.kafka.avro.AvroDeserializer

All Implemented Interfaces:

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

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

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected static class	AvroDeserializer.AvroDeserializerInputStream

Field Summary

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

isKey, keySubjectName, schemaRegistrationStrategy, valueSubjectName

Constructor Summary

Constructors

Constructor and Description
AvroDeserializer()

Method Summary

Modifier and Type	Method and Description
java.lang.Object	deserialize(java.lang.String subject, byte[] 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.Deserializer

close, configure, deserialize

Constructor Detail

AvroDeserializer

public AvroDeserializer()

Method Detail

deserialize

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

Specified by:

deserialize in interface org.apache.kafka.common.serialization.Deserializer<java.lang.Object>