public static class ExtendedDeserializer.Wrapper<T> extends Object implements ExtendedDeserializer<T>
ExtendedDeserializer.Wrapper<T>| Constructor and Description |
|---|
Wrapper(Deserializer<T> deserializer) |
| Modifier and Type | Method and Description |
|---|---|
void |
close()
Close this deserializer.
|
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.
|
T |
deserialize(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(String topic, Headers headers, byte[] data)
ExtendedDeserializerdeserialize in interface Deserializer<T>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(Map<String,?> configs, boolean isKey)
Deserializerconfigure in interface Deserializer<T>configs - configs in key/value pairsisKey - whether is for key or valuepublic T deserialize(String topic, byte[] data)
Deserializerdeserialize 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()
DeserializerThis method must be idempotent as it may be called multiple times.
close in interface Closeableclose in interface AutoCloseableclose in interface Deserializer<T>public static <T> ExtendedDeserializer<T> ensureExtended(Deserializer<T> deserializer)