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 classSerdes.ByteArraySerdestatic classSerdes.ByteBufferSerdestatic classSerdes.BytesSerdestatic classSerdes.DoubleSerdestatic classSerdes.FloatSerdestatic classSerdes.IntegerSerdestatic classSerdes.LongSerdestatic classSerdes.ShortSerdestatic classSerdes.StringSerdestatic classSerdes.UUIDSerdestatic classSerdes.VoidSerdestatic classSerdes.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()
-
-