Class Serdes


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