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

Class SubscriptionResponseWrapperSerde<V>

java.lang.Object

org.apache.kafka.streams.kstream.internals.foreignkeyjoin.SubscriptionResponseWrapperSerde<V>

All Implemented Interfaces:

Closeable, AutoCloseable, Serde<SubscriptionResponseWrapper<V>>

public class SubscriptionResponseWrapperSerde<V>
extends Object
implements Serde<SubscriptionResponseWrapper<V>>

Constructor Summary

Constructors

Constructor	Description
SubscriptionResponseWrapperSerde(Serde<V> foreignValueSerde)

Method Summary

Modifier and Type	Method	Description
Deserializer<SubscriptionResponseWrapper<V>>	deserializer()
Serializer<SubscriptionResponseWrapper<V>>	serializer()

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.kafka.common.serialization.Serde

close, configure

Constructor Detail

SubscriptionResponseWrapperSerde

public SubscriptionResponseWrapperSerde(Serde<V> foreignValueSerde)

Method Detail

serializer

public Serializer<SubscriptionResponseWrapper<V>> serializer()

Specified by:

serializer in interface Serde<V>

deserializer

public Deserializer<SubscriptionResponseWrapper<V>> deserializer()

Specified by:

deserializer in interface Serde<V>