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.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 and Description
WrapperSerde(Serializer<T> serializer, Deserializer<T> deserializer)

Method Summary

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()

Methods inherited from class java.lang.Object

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

Constructor Detail

WrapperSerde

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

Method Detail

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 Closeable

Specified by:

close in interface AutoCloseable

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>