Class Serdes
java.lang.Object
org.apache.kafka.common.serialization.Serdes
Factory for creating serializers / deserializers.
-
Nested Class Summary
Modifier and TypeClassDescriptionstatic final class
static final class
static final class
static final class
static final class
static final class
static final class
static final class
static final class
static final class
static final class
static final class
static class
-
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptionstatic Serde<byte[]>
A serde for nullablebyte[]
type.static Serde<ByteBuffer>
A serde for nullableByteBuffer
type.static Serde<org.apache.kafka.common.utils.Bytes>
Bytes()
A serde for nullableBytes
type.Double()
A serde for nullableDouble
type.Float()
A serde for nullableFloat
type.Integer()
A serde for nullableInteger
type.Long()
A serde for nullableLong
type.static <T> Serde<T>
static <T> Serde<T>
serdeFrom
(Serializer<T> serializer, Deserializer<T> deserializer) Construct a serde object from separate serializer and deserializerShort()
A serde for nullableShort
type.String()
A serde for nullableString
type.UUID()
A serde for nullableUUID
typeVoid()
A serde forVoid
type.
-
Constructor Details
-
Serdes
public Serdes()
-
-
Method Details
-
serdeFrom
-
serdeFrom
Construct a serde object from separate serializer and deserializer- Parameters:
serializer
- must not be null.deserializer
- must not be null.
-
Long
A serde for nullableLong
type. -
Integer
A serde for nullableInteger
type. -
Short
A serde for nullableShort
type. -
Float
A serde for nullableFloat
type. -
Double
A serde for nullableDouble
type. -
String
A serde for nullableString
type. -
ByteBuffer
A serde for nullableByteBuffer
type. -
Bytes
A serde for nullableBytes
type. -
UUID
A serde for nullableUUID
type -
ByteArray
A serde for nullablebyte[]
type. -
Void
A serde forVoid
type. -
ListSerde
-