com.opendxl.databus.serialization.internal

Class DatabusKeySerializer

java.lang.Object

com.opendxl.databus.serialization.internal.DatabusKeySerializer

All Implemented Interfaces:

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

public final class DatabusKeySerializer
extends java.lang.Object
implements org.apache.kafka.common.serialization.Serializer<java.lang.String>

Serializer for Databus key

Constructor Summary

Constructors

Constructor and Description
DatabusKeySerializer()

Method Summary

Modifier and Type	Method and Description
void	close() Close this deserializer.
void	configure(java.util.Map<java.lang.String,?> configs, boolean isKey) Add configuration.
byte[]	serialize(java.lang.String topic, java.lang.String data) Convert data into a byte array.

Methods inherited from class java.lang.Object

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

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

serialize

Constructor Detail

DatabusKeySerializer

public DatabusKeySerializer()

Method Detail

configure

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

Add configuration.

Specified by:

configure in interface org.apache.kafka.common.serialization.Serializer<java.lang.String>

Parameters:

configs - The configuration

isKey - To check if configuration is a key

serialize

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

Convert data into a byte array.

Specified by:

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

Parameters:

topic - Topic associated with data.

data - Typed data.

Returns:

Serialized bytes.

close

public void close()

Close this deserializer.

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.Serializer<java.lang.String>