org.apache.kafka.common.serialization

Interface Deserializer<T>

Type Parameters:

T - Type to be deserialized into. A class that implements this interface is expected to have a constructor with no parameter.

All Superinterfaces:

java.lang.AutoCloseable, java.io.Closeable

All Known Implementing Classes:

ByteArrayDeserializer, IntegerDeserializer, LongDeserializer, StringDeserializer

public interface Deserializer<T>
extends java.io.Closeable

Method Summary

Methods

Modifier and Type	Method and Description
void	close()
void	configure(java.util.Map<java.lang.String,?> configs, boolean isKey) Configure this class.
T	deserialize(java.lang.String topic, byte[] data)

Method Detail

configure

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

Configure this class.

Parameters:

configs - configs in key/value pairs

isKey - whether is for key or value

deserialize

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

Parameters:

topic - topic associated with the data

data - serialized bytes

Returns:

deserialized typed data

close

void close()

Specified by:

close in interface java.lang.AutoCloseable

Specified by:

close in interface java.io.Closeable