Package org.apache.kafka.common.serialization

Interface Deserializer<T>

Type Parameters:

T - Type to be deserialized into.

All Superinterfaces:

java.lang.AutoCloseable, java.io.Closeable

All Known Subinterfaces:

ExtendedDeserializer<T>

All Known Implementing Classes:

ByteArrayDeserializer, ByteBufferDeserializer, BytesDeserializer, DoubleDeserializer, ExtendedDeserializer.Wrapper, FloatDeserializer, IntegerDeserializer, LongDeserializer, SessionWindowedDeserializer, ShortDeserializer, StringDeserializer, TimeWindowedDeserializer

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

An interface for converting bytes to objects. A class that implements this interface is expected to have a constructor with no parameters.

Implement ClusterResourceListener to receive cluster metadata once it's available. Please see the class documentation for ClusterResourceListener for more information.

Method Summary

Modifier and Type	Method	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)	Deserialize a record value from a byte array into a value or object.

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)

Deserialize a record value from a byte array 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 java.lang.AutoCloseable

Specified by:

close in interface java.io.Closeable