Package org.apache.kafka.common.serialization

Class Serdes

java.lang.Object

org.apache.kafka.common.serialization.Serdes

public class Serdes
extends java.lang.Object

Factory for creating serializers / deserializers.

Nested Class Summary

Nested Classes

Modifier and Type	Class	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.LongSerde
static class	Serdes.ShortSerde
static class	Serdes.StringSerde
static class	Serdes.WrapperSerde<T>

Constructor Summary

Constructors

Constructor	Description
Serdes()

Method Summary

Modifier and Type	Method	Description
static Serde<byte[]>	ByteArray()
static Serde<java.nio.ByteBuffer>	ByteBuffer()
static Serde<org.apache.kafka.common.utils.Bytes>	Bytes()
static Serde<java.lang.Double>	Double()
static Serde<java.lang.Float>	Float()
static Serde<java.lang.Integer>	Integer()
static Serde<java.lang.Long>	Long()
static <T> Serde<T>	serdeFrom(java.lang.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<java.lang.Short>	Short()
static Serde<java.lang.String>	String()

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(java.lang.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<java.lang.Long> Long()

Integer

public static Serde<java.lang.Integer> Integer()

Short

public static Serde<java.lang.Short> Short()

Float

public static Serde<java.lang.Float> Float()

Double

public static Serde<java.lang.Double> Double()

String

public static Serde<java.lang.String> String()

ByteBuffer

public static Serde<java.nio.ByteBuffer> ByteBuffer()

Bytes

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

ByteArray

public static Serde<byte[]> ByteArray()