T - Type to be deserialized into.public interface Deserializer<T> extends Closeable
Implement ClusterResourceListener to receive cluster metadata once it's available. Please see the class documentation for ClusterResourceListener for more information.
| Modifier and Type | Method and Description |
|---|---|
default void | close()Close this deserializer. |
default void | configure(Map<String,?> configs, boolean isKey)Configure this class. |
T | deserialize(String topic, byte[] data)Deserialize a record value from a byte array into a value or object. |
default T | deserialize(String topic, Headers headers, byte[] data)Deserialize a record value from a byte array into a value or object. |
default void configure(Map<String,?> configs, boolean isKey)
configs - configs in key/value pairsisKey - whether is for key or valueT deserialize(String topic, byte[] data)
topic - topic associated with the datadata - serialized bytes; may be null; implementations are recommended to handle null by returning a value or null rather than throwing an exception.default T deserialize(String topic, Headers headers, byte[] data)
topic - topic associated with the dataheaders - 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.default void close()
This method must be idempotent as it may be called multiple times.
close in interface AutoCloseableclose in interface Closeable