java.io.Closeable
, java.lang.AutoCloseable
, Deserializer<T>
, ExtendedDeserializer<T>
public static class ExtendedDeserializer.Wrapper<T> extends java.lang.Object implements ExtendedDeserializer<T>
ExtendedDeserializer.Wrapper<T>
Constructor | Description |
---|---|
Wrapper(Deserializer<T> deserializer) |
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.
|
T |
deserialize(java.lang.String topic,
Headers headers,
byte[] data) |
Deserialize a record value from a byte array into a value or object.
|
static <T> ExtendedDeserializer<T> |
ensureExtended(Deserializer<T> deserializer) |
public Wrapper(Deserializer<T> deserializer)
public T deserialize(java.lang.String topic, Headers headers, byte[] data)
ExtendedDeserializer
deserialize
in interface ExtendedDeserializer<T>
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.public void configure(java.util.Map<java.lang.String,?> configs, boolean isKey)
Deserializer
configure
in interface Deserializer<T>
configs
- configs in key/value pairsisKey
- whether is for key or valuepublic T deserialize(java.lang.String topic, byte[] data)
Deserializer
deserialize
in interface Deserializer<T>
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.public void close()
close
in interface java.lang.AutoCloseable
close
in interface java.io.Closeable
close
in interface Deserializer<T>
public static <T> ExtendedDeserializer<T> ensureExtended(Deserializer<T> deserializer)