Class CombinedKeySchema<KO,K>
- java.lang.Object
-
- org.apache.kafka.streams.kstream.internals.foreignkeyjoin.CombinedKeySchema<KO,K>
-
public class CombinedKeySchema<KO,K> extends java.lang.Object
Factory for creating CombinedKey serializers / deserializers.
-
-
Constructor Summary
Constructors Constructor Description CombinedKeySchema(java.util.function.Supplier<java.lang.String> foreignKeySerdeTopicSupplier, org.apache.kafka.common.serialization.Serde<KO> foreignKeySerde, java.util.function.Supplier<java.lang.String> primaryKeySerdeTopicSupplier, org.apache.kafka.common.serialization.Serde<K> primaryKeySerde)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description CombinedKey<KO,K>
fromBytes(org.apache.kafka.common.utils.Bytes data)
void
init(ProcessorContext context)
-
-
-
Constructor Detail
-
CombinedKeySchema
public CombinedKeySchema(java.util.function.Supplier<java.lang.String> foreignKeySerdeTopicSupplier, org.apache.kafka.common.serialization.Serde<KO> foreignKeySerde, java.util.function.Supplier<java.lang.String> primaryKeySerdeTopicSupplier, org.apache.kafka.common.serialization.Serde<K> primaryKeySerde)
-
-
Method Detail
-
init
public void init(ProcessorContext context)
-
fromBytes
public CombinedKey<KO,K> fromBytes(org.apache.kafka.common.utils.Bytes data)
-
-