public static class Serdes.WrapperSerde<T> extends Object implements Serde<T>
| Constructor and Description |
|---|
WrapperSerde(Serializer<T> serializer, Deserializer<T> deserializer) |
| Modifier and Type | Method and Description |
|---|---|
void | close()Close this serde class, which will close the underlying serializer and deserializer. |
void | configure(Map<String,?> configs, boolean isKey)Configure this class, which will configure the underlying serializer and deserializer. |
Deserializer<T> | deserializer() |
Serializer<T> | serializer() |
public WrapperSerde(Serializer<T> serializer, Deserializer<T> deserializer)
public void configure(Map<String,?> configs, boolean isKey)
Serdepublic void close()
SerdeThis method has to be idempotent because it might be called multiple times.
public Serializer<T> serializer()
serializer in interface Serde<T>public Deserializer<T> deserializer()
deserializer in interface Serde<T>