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() |
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 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()
close in interface Closeableclose in interface AutoCloseableclose in interface Deserializer<T>public static <T> ExtendedDeserializer<T> ensureExtended(Deserializer<T> deserializer)