org.apache.kafka.common.serialization

Class Serdes

java.lang.Object

org.apache.kafka.common.serialization.Serdes

public class Serdes
extends Object

Factory for creating serializers / deserializers.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	Serdes.ByteArraySerde
static class	Serdes.ByteBufferSerde
static class	Serdes.BytesSerde
static class	Serdes.DoubleSerde
static class	Serdes.FloatSerde
static class	Serdes.IntegerSerde
static class	Serdes.ListSerde<Inner>
static class	Serdes.LongSerde
static class	Serdes.ShortSerde
static class	Serdes.StringSerde
static class	Serdes.UUIDSerde
static class	Serdes.VoidSerde
static class	Serdes.WrapperSerde<T>

Constructor Summary

Constructors

Constructor and Description
Serdes()

Method Summary

Modifier and Type	Method and Description
static Serde<byte[]>	ByteArray() A serde for nullable byte[] type.
static Serde<ByteBuffer>	ByteBuffer() A serde for nullable ByteBuffer type.
static Serde<org.apache.kafka.common.utils.Bytes>	Bytes() A serde for nullable Bytes type.
static Serde<Double>	Double() A serde for nullable Double type.
static Serde<Float>	Float() A serde for nullable Float type.
static Serde<Integer>	Integer() A serde for nullable Integer type.
static <L extends List<Inner>,Inner> Serde<List<Inner>>	ListSerde(Class<L> listClass, Serde<Inner> innerSerde)
static Serde<Long>	Long() A serde for nullable Long type.
static <T> Serde<T>	serdeFrom(Class<T> type)
static <T> Serde<T>	serdeFrom(Serializer<T> serializer, Deserializer<T> deserializer) Construct a serde object from separate serializer and deserializer
static Serde<Short>	Short() A serde for nullable Short type.
static Serde<String>	String() A serde for nullable String type.
static Serde<UUID>	UUID() A serde for nullable UUID type
static Serde<Void>	Void() A serde for Void type.

Methods inherited from class java.lang.Object

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

Constructor Detail

Serdes

public Serdes()

Method Detail

serdeFrom

public static <T> Serde<T> serdeFrom(Class<T> type)

serdeFrom

public static <T> Serde<T> serdeFrom(Serializer<T> serializer,
                                     Deserializer<T> deserializer)

Construct a serde object from separate serializer and deserializer

Parameters:

serializer - must not be null.

deserializer - must not be null.

Long

public static Serde<Long> Long()

A serde for nullable Long type.

Integer

public static Serde<Integer> Integer()

A serde for nullable Integer type.

Short

public static Serde<Short> Short()

A serde for nullable Short type.

Float

public static Serde<Float> Float()

A serde for nullable Float type.

Double

public static Serde<Double> Double()

A serde for nullable Double type.

String

public static Serde<String> String()

A serde for nullable String type.

ByteBuffer

public static Serde<ByteBuffer> ByteBuffer()

A serde for nullable ByteBuffer type.

Bytes

public static Serde<org.apache.kafka.common.utils.Bytes> Bytes()

A serde for nullable Bytes type.

UUID

public static Serde<UUID> UUID()

A serde for nullable UUID type

ByteArray

public static Serde<byte[]> ByteArray()

A serde for nullable byte[] type.

Void

public static Serde<Void> Void()

A serde for Void type.

ListSerde

public static <L extends List<Inner>,Inner> Serde<List<Inner>> ListSerde(Class<L> listClass,
                                                                         Serde<Inner> innerSerde)