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.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 Summary

Constructors

Constructor Description

Serdes()

Method Summary

Modifier and Type	Method	Description
`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> Serde<List<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.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details
- Serdes
  
  public Serdes()
Method Details
- 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()
  
  A serde for nullable Long type.
- Integer
  
  public static Serde<Integer> Integer()
  
  A serde for nullable Integer type.
- Short
  
  public static Serde<Short> Short()
  
  A serde for nullable Short type.
- Float
  
  public static Serde<Float> Float()
  
  A serde for nullable Float type.
- Double
  
  public static Serde<Double> Double()
  
  A serde for nullable Double type.
- String
  
  public static Serde<String> String()
  
  A serde for nullable String type.
- ByteBuffer
  
  public static Serde<ByteBuffer> ByteBuffer()
  
  A serde for nullable ByteBuffer type.
- Bytes
  
  public static Serde<org.apache.kafka.common.utils.Bytes> Bytes()
  
  A serde for nullable Bytes type.
- UUID
  
  public static Serde<UUID> UUID()
  
  A serde for nullable UUID type
- ByteArray
  
  public static Serde<byte[]> ByteArray()
  
  A serde for nullable byte[] type.
- Void
  
  public static Serde<Void> Void()
  
  A serde for Void type.
- ListSerde
  
  public static <L extends List<Inner>, Inner> Serde<List<Inner>> ListSerde(Class<L> listClass, Serde<Inner> innerSerde)

Class Serdes

Nested Class Summary

Constructor Summary

Method Summary

Methods inherited from class java.lang.Object

Constructor Details

Serdes

Method Details

serdeFrom

serdeFrom

Long

Integer

Short

Float

Double

String

ByteBuffer

Bytes

UUID

ByteArray

Void

ListSerde