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 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.UUIDSerde
static class
Serdes.VoidSerde
static class
Serdes.WrapperSerde<T>
-
Constructor Summary
Constructors Constructor Description Serdes()
-
Method Summary
All Methods Static Methods Concrete Methods Modifier and Type Method Description static Serde<byte[]>
ByteArray()
static Serde<ByteBuffer>
ByteBuffer()
static Serde<org.apache.kafka.common.utils.Bytes>
Bytes()
static Serde<Double>
Double()
static Serde<Float>
Float()
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 deserializerstatic Serde<Short>
Short()
static Serde<String>
String()
static Serde<UUID>
UUID()
static Serde<Void>
Void()
-
-
-
Method Detail
-
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.
-
ByteBuffer
public static Serde<ByteBuffer> ByteBuffer()
-
Bytes
public static Serde<org.apache.kafka.common.utils.Bytes> Bytes()
-
ByteArray
public static Serde<byte[]> ByteArray()
-
-