Class ForeignJoinSubscriptionSendProcessorSupplier<K,​KO,​V>

    • Constructor Summary

      Constructors 
      Constructor Description
      ForeignJoinSubscriptionSendProcessorSupplier​(java.util.function.Function<V,​KO> foreignKeyExtractor, java.util.function.Supplier<java.lang.String> foreignKeySerdeTopicSupplier, java.util.function.Supplier<java.lang.String> valueSerdeTopicSupplier, org.apache.kafka.common.serialization.Serde<KO> foreignKeySerde, org.apache.kafka.common.serialization.Serializer<V> valueSerializer, boolean leftJoin)  
    • Constructor Detail

      • ForeignJoinSubscriptionSendProcessorSupplier

        public ForeignJoinSubscriptionSendProcessorSupplier​(java.util.function.Function<V,​KO> foreignKeyExtractor,
                                                            java.util.function.Supplier<java.lang.String> foreignKeySerdeTopicSupplier,
                                                            java.util.function.Supplier<java.lang.String> valueSerdeTopicSupplier,
                                                            org.apache.kafka.common.serialization.Serde<KO> foreignKeySerde,
                                                            org.apache.kafka.common.serialization.Serializer<V> valueSerializer,
                                                            boolean leftJoin)