Package org.apache.kafka.common.serialization

Class Serdes

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

    • 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)