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.IntegerSerde
static class	Serdes.LongSerde
static class	Serdes.StringSerde
protected static class	Serdes.WrapperSerde<T>

Constructor Summary

Constructors

Constructor and Description
Serdes()

Method Summary

Methods

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

Integer

public static Serde<Integer> Integer()

Double

public static Serde<Double> Double()

String

public static Serde<String> String()

ByteBuffer

public static Serde<ByteBuffer> ByteBuffer()

Bytes

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

ByteArray

public static Serde<byte[]> ByteArray()