Class WrappingNullableUtils
- java.lang.Object
-
- org.apache.kafka.streams.kstream.internals.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.
-
-
Constructor Summary
Constructors Constructor Description WrappingNullableUtils()
-
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)
-
-
-
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)
-
-