Class 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)  
    • 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

      • fromBytes

        public CombinedKey<KO,​K> fromBytes​(org.apache.kafka.common.utils.Bytes data)