public class Serdes extends Object
Modifier and Type | Class and Description |
---|---|
static class |
Serdes.BooleanSerde |
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 and Description |
---|
Serdes() |
Modifier and Type | Method and Description |
---|---|
static Serde<Boolean> |
Boolean()
A serde for nullable
Boolean type. |
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> |
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. |
public static <T> Serde<T> serdeFrom(Serializer<T> serializer, Deserializer<T> deserializer)
serializer
- must not be null.deserializer
- must not be null.public static Serde<ByteBuffer> ByteBuffer()
ByteBuffer
type.public static Serde<org.apache.kafka.common.utils.Bytes> Bytes()
Bytes
type.public static Serde<byte[]> ByteArray()
byte[]
type.