com.opendxl.databus.serialization.internal

Class DatabusKeyDeserializer

java.lang.Object

com.opendxl.databus.serialization.internal.DatabusKeyDeserializer

All Implemented Interfaces:

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

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

Deserializer for Databus key

Constructor Summary

Constructors

Constructor and Description
DatabusKeyDeserializer()

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.
java.lang.String	deserialize(java.lang.String topic, byte[] data) Deserialize a record value from a byte array into a value or object.

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.Deserializer

deserialize

Constructor Detail

DatabusKeyDeserializer

public DatabusKeyDeserializer()

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

Parameters:

configs - The configuration

isKey - To check if configuration is a key

deserialize

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

Deserialize a record value from a byte array into a value or object.

Specified by:

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

Parameters:

topic - Topic associated with the data.

data - Serialized bytes.

Returns:

A String deserialized data.

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