Constructor Detail

• Serdes

  public Serdes()

Method Detail

• 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

• Boolean

  public static Serde<Boolean> Boolean()

  A serde for nullable Boolean 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)