com.opendxl.databus.serialization

Class SerdeDatabus

java.lang.Object

com.opendxl.databus.serialization.SerdeDatabus

All Implemented Interfaces:

java.io.Closeable, java.lang.AutoCloseable, org.apache.kafka.common.serialization.Serde<DatabusMessage>

public class SerdeDatabus
extends java.lang.Object
implements org.apache.kafka.common.serialization.Serde<DatabusMessage>

Serializer / Deserializer for Databus messages

Constructor Summary

Constructors

Constructor and Description
SerdeDatabus()

Method Summary

Modifier and Type	Method and Description
void	close() Not implemented.
void	configure(java.util.Map<java.lang.String,?> configs, boolean isKey) Not implemented.
org.apache.kafka.common.serialization.Deserializer<DatabusMessage>	deserializer() Creates the deserializer.
org.apache.kafka.common.serialization.Serializer<DatabusMessage>	serializer() Creates the serializer.

Methods inherited from class java.lang.Object

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

Constructor Detail

SerdeDatabus

public SerdeDatabus()

Method Detail

configure

public void configure(java.util.Map<java.lang.String,?> configs,
                      boolean isKey)

Not implemented.

Specified by:

configure in interface org.apache.kafka.common.serialization.Serde<DatabusMessage>

close

public void close()

Not implemented.

Specified by:

close in interface java.io.Closeable

Specified by:

close in interface java.lang.AutoCloseable

Specified by:

close in interface org.apache.kafka.common.serialization.Serde<DatabusMessage>

serializer

public org.apache.kafka.common.serialization.Serializer<DatabusMessage> serializer()

Creates the serializer.

Specified by:

serializer in interface org.apache.kafka.common.serialization.Serde<DatabusMessage>

Returns:

A DatabusMessage serializer instance.

deserializer

public org.apache.kafka.common.serialization.Deserializer<DatabusMessage> deserializer()

Creates the deserializer.

Specified by:

deserializer in interface org.apache.kafka.common.serialization.Serde<DatabusMessage>

Returns:

A DatabusMessage deserializer instance.