Package org.apache.kafka.common.serialization

Class Serdes.WrapperSerde<T>

java.lang.Object

org.apache.kafka.common.serialization.Serdes.WrapperSerde<T>

All Implemented Interfaces:

Closeable, AutoCloseable, Serde<T>

Direct Known Subclasses:

Serdes.ByteArraySerde, Serdes.ByteBufferSerde, Serdes.BytesSerde, Serdes.DoubleSerde, Serdes.FloatSerde, Serdes.IntegerSerde, Serdes.ListSerde, Serdes.LongSerde, Serdes.ShortSerde, Serdes.StringSerde, Serdes.UUIDSerde, Serdes.VoidSerde, WindowedSerdes.SessionWindowedSerde, WindowedSerdes.TimeWindowedSerde

Enclosing class:

Serdes

public static class Serdes.WrapperSerde<T>
extends Object
implements Serde<T>

Constructor Summary

Constructors

Constructor	Description
WrapperSerde(Serializer<T> serializer, Deserializer<T> deserializer)

Method Summary

Modifier and Type	Method	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()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

WrapperSerde

public WrapperSerde(Serializer<T> serializer,
Deserializer<T> deserializer)

Method Details

configure

public void configure(Map<String,?> configs,
boolean isKey)

Description copied from interface: Serde

Configure this class, which will configure the underlying serializer and deserializer.

Specified by:

configure in interface Serde<T>

Parameters:

configs - configs in key/value pairs

isKey - whether is for key or value

close

public void close()

Description copied from interface: Serde

Close this serde class, which will close the underlying serializer and deserializer.

This method has to be idempotent because it might be called multiple times.

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Specified by:

close in interface Serde<T>

serializer

public Serializer<T> serializer()

Specified by:

serializer in interface Serde<T>

deserializer

public Deserializer<T> deserializer()

Specified by:

deserializer in interface Serde<T>