Package org.apache.kafka.common.serialization

Interface Serializer<T>

Type Parameters:

T - Type to be serialized from.

All Superinterfaces:

java.lang.AutoCloseable, java.io.Closeable

All Known Subinterfaces:

ExtendedSerializer<T>

All Known Implementing Classes:

ByteArraySerializer, ByteBufferSerializer, BytesSerializer, DoubleSerializer, ExtendedSerializer.Wrapper, FloatSerializer, IntegerSerializer, LongSerializer, SessionWindowedSerializer, ShortSerializer, StringSerializer, TimeWindowedSerializer

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

An interface for converting objects to bytes. A class that implements this interface is expected to have a constructor with no parameter.

Implement ClusterResourceListener to receive cluster metadata once it's available. Please see the class documentation for ClusterResourceListener for more information.

Method Summary

Modifier and Type	Method	Description
void	close()	Close this serializer.
void	configure(java.util.Map<java.lang.String,?> configs, boolean isKey)	Configure this class.
byte[]	serialize(java.lang.String topic, T data)	Convert data into a byte array.

Method Detail

configure

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

Configure this class.

Parameters:

configs - configs in key/value pairs

isKey - whether is for key or value

serialize

byte[] serialize(java.lang.String topic,
                 T data)

Convert data into a byte array.

Parameters:

topic - topic associated with data

data - typed data

Returns:

serialized bytes

close

void close()

Close this serializer. This method must be idempotent as it may be called multiple times.

Specified by:

close in interface java.lang.AutoCloseable

Specified by:

close in interface java.io.Closeable