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.
      • Bytes

        public static Serde<org.apache.kafka.common.utils.Bytes> Bytes()
      • ByteArray

        public static Serde<byte[]> ByteArray()