java.lang.Object
org.apache.kafka.common.serialization.Serdes

public class Serdes extends Object
Factory for creating serializers / deserializers.
  • 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)