Package org.apache.kafka.streams.kstream.internals.foreignkeyjoin

Class SubscriptionWrapperSerde<K>

java.lang.Object

org.apache.kafka.streams.kstream.internals.WrappingNullableSerde<SubscriptionWrapper<K>,K,Void>

org.apache.kafka.streams.kstream.internals.foreignkeyjoin.SubscriptionWrapperSerde<K>

All Implemented Interfaces:

Closeable, AutoCloseable, Serde<SubscriptionWrapper<K>>

public class SubscriptionWrapperSerde<K>
extends WrappingNullableSerde<SubscriptionWrapper<K>,K,Void>

Constructor Summary

Constructors

Constructor	Description
SubscriptionWrapperSerde(Supplier<String> primaryKeySerializationPseudoTopicSupplier, Serde<K> primaryKeySerde)

Method Summary

Methods inherited from class org.apache.kafka.streams.kstream.internals.WrappingNullableSerde

close, configure, deserializer, serializer, setIfUnset

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

SubscriptionWrapperSerde

public SubscriptionWrapperSerde(Supplier<String> primaryKeySerializationPseudoTopicSupplier,
                                Serde<K> primaryKeySerde)