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:

AutoCloseable, Closeable

All Known Implementing Classes:

ByteArrayDeserializer, ByteBufferDeserializer, BytesDeserializer, DoubleDeserializer, IntegerDeserializer, LongDeserializer, StringDeserializer

public interface Deserializer<T>
extends Closeable

Method Summary

Methods

Modifier and Type	Method and Description
void	close()
void	configure(Map<String,?> configs, boolean isKey) Configure this class.
T	deserialize(String topic, byte[] data) Deserialize a record value from a bytearray into a value or object.

Method Detail

configure

void configure(Map<String,?> configs,
             boolean isKey)

Configure this class.

Parameters:

configs - configs in key/value pairs

isKey - whether is for key or value

deserialize

T deserialize(String topic,
            byte[] data)

Deserialize a record value from a bytearray into a value or object.

Parameters:

topic - topic associated with the data

data - serialized bytes; may be null; implementations are recommended to handle null by returning a value or null rather than throwing an exception.

Returns:

deserialized typed data; may be null

close

void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable