Package org.apache.kafka.common.serialization

Interface Serde<T>

Type Parameters:

T - Type to be serialized from and deserialized into. A class that implements this interface is expected to have a constructor with no parameter.

All Superinterfaces:

java.lang.AutoCloseable, java.io.Closeable

All Known Implementing Classes:

Serdes.ByteArraySerde, Serdes.ByteBufferSerde, Serdes.BytesSerde, Serdes.DoubleSerde, Serdes.FloatSerde, Serdes.IntegerSerde, Serdes.LongSerde, Serdes.ShortSerde, Serdes.StringSerde, Serdes.WrapperSerde, WindowedSerdes.SessionWindowedSerde, WindowedSerdes.TimeWindowedSerde

public interface Serde<T>
extends java.io.Closeable

The interface for wrapping a serializer and deserializer for the given data type.

Method Summary

Modifier and Type	Method	Description
void	close()	Close this serde class, which will close the underlying serializer and deserializer.
void	configure(java.util.Map<java.lang.String,?> configs, boolean isKey)	Configure this class, which will configure the underlying serializer and deserializer.
Deserializer<T>	deserializer()
Serializer<T>	serializer()

Method Detail

configure

void configure(java.util.Map<java.lang.String,?> configs,
               boolean isKey)

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

Parameters:

configs - configs in key/value pairs

isKey - whether is for key or value

close

void close()

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 java.lang.AutoCloseable

Specified by:

close in interface java.io.Closeable

serializer

Serializer<T> serializer()

deserializer

Deserializer<T> deserializer()