Class WrappingNullableUtils


  • public class WrappingNullableUtils
    extends java.lang.Object
    If a component's serdes are Wrapping serdes, then they require a little extra setup to be fully initialized at run time.
    • Method Summary

      All Methods Static Methods Concrete Methods 
      Modifier and Type Method Description
      static <T> void initNullableDeserializer​(org.apache.kafka.common.serialization.Deserializer<T> specificDeserializer, org.apache.kafka.common.serialization.Deserializer<?> contextKeyDeserializer, org.apache.kafka.common.serialization.Deserializer<?> contextValueDeserializer)  
      static <T> void initNullableSerializer​(org.apache.kafka.common.serialization.Serializer<T> specificSerializer, org.apache.kafka.common.serialization.Serializer<?> contextKeySerializer, org.apache.kafka.common.serialization.Serializer<?> contextValueSerializer)  
      static <K> org.apache.kafka.common.serialization.Deserializer<K> prepareKeyDeserializer​(org.apache.kafka.common.serialization.Deserializer<K> specificDeserializer, org.apache.kafka.common.serialization.Deserializer<?> contextKeyDeserializer, org.apache.kafka.common.serialization.Deserializer<?> contextValueDeserializer)  
      static <K> org.apache.kafka.common.serialization.Serde<K> prepareKeySerde​(org.apache.kafka.common.serialization.Serde<K> specificSerde, org.apache.kafka.common.serialization.Serde<?> keySerde, org.apache.kafka.common.serialization.Serde<?> valueSerde)  
      static <K> org.apache.kafka.common.serialization.Serializer<K> prepareKeySerializer​(org.apache.kafka.common.serialization.Serializer<K> specificSerializer, org.apache.kafka.common.serialization.Serializer<?> contextKeySerializer, org.apache.kafka.common.serialization.Serializer<?> contextValueSerializer)  
      static <V> org.apache.kafka.common.serialization.Deserializer<V> prepareValueDeserializer​(org.apache.kafka.common.serialization.Deserializer<V> specificDeserializer, org.apache.kafka.common.serialization.Deserializer<?> contextKeyDeserializer, org.apache.kafka.common.serialization.Deserializer<?> contextValueDeserializer)  
      static <V> org.apache.kafka.common.serialization.Serde<V> prepareValueSerde​(org.apache.kafka.common.serialization.Serde<V> specificSerde, org.apache.kafka.common.serialization.Serde<?> keySerde, org.apache.kafka.common.serialization.Serde<?> valueSerde)  
      static <V> org.apache.kafka.common.serialization.Serializer<V> prepareValueSerializer​(org.apache.kafka.common.serialization.Serializer<V> specificSerializer, org.apache.kafka.common.serialization.Serializer<?> contextKeySerializer, org.apache.kafka.common.serialization.Serializer<?> contextValueSerializer)  
      • Methods inherited from class java.lang.Object

        clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
    • Constructor Detail

      • WrappingNullableUtils

        public WrappingNullableUtils()
    • Method Detail

      • prepareKeyDeserializer

        public static <K> org.apache.kafka.common.serialization.Deserializer<K> prepareKeyDeserializer​(org.apache.kafka.common.serialization.Deserializer<K> specificDeserializer,
                                                                                                       org.apache.kafka.common.serialization.Deserializer<?> contextKeyDeserializer,
                                                                                                       org.apache.kafka.common.serialization.Deserializer<?> contextValueDeserializer)
      • prepareValueDeserializer

        public static <V> org.apache.kafka.common.serialization.Deserializer<V> prepareValueDeserializer​(org.apache.kafka.common.serialization.Deserializer<V> specificDeserializer,
                                                                                                         org.apache.kafka.common.serialization.Deserializer<?> contextKeyDeserializer,
                                                                                                         org.apache.kafka.common.serialization.Deserializer<?> contextValueDeserializer)
      • prepareKeySerializer

        public static <K> org.apache.kafka.common.serialization.Serializer<K> prepareKeySerializer​(org.apache.kafka.common.serialization.Serializer<K> specificSerializer,
                                                                                                   org.apache.kafka.common.serialization.Serializer<?> contextKeySerializer,
                                                                                                   org.apache.kafka.common.serialization.Serializer<?> contextValueSerializer)
      • prepareValueSerializer

        public static <V> org.apache.kafka.common.serialization.Serializer<V> prepareValueSerializer​(org.apache.kafka.common.serialization.Serializer<V> specificSerializer,
                                                                                                     org.apache.kafka.common.serialization.Serializer<?> contextKeySerializer,
                                                                                                     org.apache.kafka.common.serialization.Serializer<?> contextValueSerializer)
      • prepareKeySerde

        public static <K> org.apache.kafka.common.serialization.Serde<K> prepareKeySerde​(org.apache.kafka.common.serialization.Serde<K> specificSerde,
                                                                                         org.apache.kafka.common.serialization.Serde<?> keySerde,
                                                                                         org.apache.kafka.common.serialization.Serde<?> valueSerde)
      • prepareValueSerde

        public static <V> org.apache.kafka.common.serialization.Serde<V> prepareValueSerde​(org.apache.kafka.common.serialization.Serde<V> specificSerde,
                                                                                           org.apache.kafka.common.serialization.Serde<?> keySerde,
                                                                                           org.apache.kafka.common.serialization.Serde<?> valueSerde)
      • initNullableSerializer

        public static <T> void initNullableSerializer​(org.apache.kafka.common.serialization.Serializer<T> specificSerializer,
                                                      org.apache.kafka.common.serialization.Serializer<?> contextKeySerializer,
                                                      org.apache.kafka.common.serialization.Serializer<?> contextValueSerializer)
      • initNullableDeserializer

        public static <T> void initNullableDeserializer​(org.apache.kafka.common.serialization.Deserializer<T> specificDeserializer,
                                                        org.apache.kafka.common.serialization.Deserializer<?> contextKeyDeserializer,
                                                        org.apache.kafka.common.serialization.Deserializer<?> contextValueDeserializer)