Package io.streamthoughts.azkarra.commons.error

Class SafeSerdes

  • public class SafeSerdes
extends Object
    Factory for creating serializers / safe-deserializers.

    • Constructor Summary

      Constructors 
      Constructor Description
      SafeSerdes()  

    • Method Summary

      All Methods Static Methods Concrete Methods 
      Modifier and Type Method Description
      static org.apache.kafka.common.serialization.Serde<Double> Double()  
      static org.apache.kafka.common.serialization.Serde<Double> Double​(Double defaultValue)  
      static org.apache.kafka.common.serialization.Serde<Float> Float()  
      static org.apache.kafka.common.serialization.Serde<Float> Float​(Float defaultValue)  
      static org.apache.kafka.common.serialization.Serde<Integer> Integer()  
      static org.apache.kafka.common.serialization.Serde<Long> Long()  
      static org.apache.kafka.common.serialization.Serde<Long> Long​(Long defaultValue)  
      static <T> org.apache.kafka.common.serialization.Serde<T> serdeFrom​(Class<T> type, T defaultValue)  
      static <T> org.apache.kafka.common.serialization.Serde<T> serdeFrom​(org.apache.kafka.common.serialization.Serde<T> serde, T defaultValue)  
      static <T> org.apache.kafka.common.serialization.Serde<T> serdeFrom​(org.apache.kafka.common.serialization.Serializer<T> serializer, org.apache.kafka.common.serialization.Deserializer<T> deserializer, T defaultValue)  
      static org.apache.kafka.common.serialization.Serde<String> String()  
      static org.apache.kafka.common.serialization.Serde<String> String​(String defaultValue)  
      static org.apache.kafka.common.serialization.Serde<UUID> UUID()  
      static org.apache.kafka.common.serialization.Serde<UUID> UUID​(UUID uuid)  

    • Constructor Detail

      • SafeSerdes

        public SafeSerdes()

    • Method Detail

      • serdeFrom

        public static <T> org.apache.kafka.common.serialization.Serde<T> serdeFrom​(org.apache.kafka.common.serialization.Serde<T> serde,
                                                                           T defaultValue)

      • serdeFrom

        public static <T> org.apache.kafka.common.serialization.Serde<T> serdeFrom​(org.apache.kafka.common.serialization.Serializer<T> serializer,
                                                                           org.apache.kafka.common.serialization.Deserializer<T> deserializer,
                                                                           T defaultValue)

      • serdeFrom

        public static <T> org.apache.kafka.common.serialization.Serde<T> serdeFrom​(Class<T> type,
                                                                           T defaultValue)

      • String

        public static org.apache.kafka.common.serialization.Serde<String> String()

      • String

        public static org.apache.kafka.common.serialization.Serde<String> String​(String defaultValue)

      • Long

        public static org.apache.kafka.common.serialization.Serde<Long> Long()

      • Long

        public static org.apache.kafka.common.serialization.Serde<Long> Long​(Long defaultValue)

      • Double

        public static org.apache.kafka.common.serialization.Serde<Double> Double()

      • Double

        public static org.apache.kafka.common.serialization.Serde<Double> Double​(Double defaultValue)

      • Integer

        public static org.apache.kafka.common.serialization.Serde<Integer> Integer()

      • Float

        public static org.apache.kafka.common.serialization.Serde<Float> Float()

      • Float

        public static org.apache.kafka.common.serialization.Serde<Float> Float​(Float defaultValue)

      • UUID

        public static org.apache.kafka.common.serialization.Serde<UUID> UUID()

      • UUID

        public static org.apache.kafka.common.serialization.Serde<UUID> UUID​(UUID uuid)