org.cg.eventbus

Class AvroSerializer<T>

java.lang.Object

org.cg.eventbus.AvroSerializer<T>

All Implemented Interfaces:

kafka.serializer.Decoder<T>, org.apache.kafka.common.serialization.Deserializer<T>, org.apache.kafka.common.serialization.Serializer<T>, IEventBusSerializer<T>

public class AvroSerializer<T>
extends Object
implements IEventBusSerializer<T>

Event bus Avro serializer/deserializer. Usage : extend the AvroSerializer with default constructor

Author:

yanlinwang

Constructor Summary

Constructors

Constructor and Description
AvroSerializer(Class<T> typeParameterClass)

Method Summary

Modifier and Type	Method and Description
void	close()
void	configure(Map<String,?> arg0, boolean arg1)
T	deserialize(String arg0, byte[] data)
T	fromBytes(byte[] arg0)
byte[]	serialize(String arg0, T event)

Methods inherited from class java.lang.Object

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

Constructor Detail

AvroSerializer

public AvroSerializer(Class<T> typeParameterClass)

Method Detail

deserialize

public T deserialize(String arg0,
                     byte[] data)

Specified by:

deserialize in interface org.apache.kafka.common.serialization.Deserializer<T>

fromBytes

public T fromBytes(byte[] arg0)

Specified by:

fromBytes in interface kafka.serializer.Decoder<T>

close

public void close()

Specified by:

close in interface org.apache.kafka.common.serialization.Deserializer<T>

Specified by:

close in interface org.apache.kafka.common.serialization.Serializer<T>

configure

public void configure(Map<String,?> arg0,
                      boolean arg1)

Specified by:

configure in interface org.apache.kafka.common.serialization.Deserializer<T>

Specified by:

configure in interface org.apache.kafka.common.serialization.Serializer<T>

serialize

public byte[] serialize(String arg0,
                        T event)

Specified by:

serialize in interface org.apache.kafka.common.serialization.Serializer<T>