org.apache.kafka.common.serialization

Interface ExtendedDeserializer<T>

Type Parameters:

T -

All Superinterfaces:

AutoCloseable, Closeable, Deserializer<T>

All Known Implementing Classes:

ExtendedDeserializer.Wrapper

public interface ExtendedDeserializer<T>
extends Deserializer<T>

A Deserializer that has access to the headers associated with the record. Prefer Deserializer if access to the headers is not required. Once Kafka drops support for Java 7, the deserialize() method introduced by this interface will be added to Deserializer with a default implementation so that backwards compatibility is maintained. This interface may be deprecated once that happens. A class that implements this interface is expected to have a constructor with no parameters.

Nested Class Summary

Nested Classes

Modifier and Type	Interface and Description
static class	ExtendedDeserializer.Wrapper<T>

Method Summary

Modifier and Type	Method and Description
T	deserialize(String topic, Headers headers, byte[] data) Deserialize a record value from a byte array into a value or object.

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

close, configure, deserialize

Method Detail

deserialize

T deserialize(String topic,
              Headers headers,
              byte[] data)

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

Parameters:

topic - topic associated with the data

headers - headers associated with the record; may be empty.

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