This is an automated email from the ASF dual-hosted git repository.
ableegoldman pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git
from 408ce19c629 KAFKA-18245 add Flaky annotation to
testMetricsDuringTopicCreateDelete (#18187)
add bac89285214 KAFKA-18026: KIP-1112, migrate foreign-key joins to use
ProcesserSupplier#stores (#18194)
No new revisions were added by this update.
Summary of changes:
.../streams/kstream/internals/KTableImpl.java | 13 ++--
.../ForeignTableJoinProcessorSupplier.java | 22 ++++--
.../SubscriptionReceiveProcessorSupplier.java | 24 +++++--
.../internals/graph/ForeignTableJoinNode.java | 8 +--
.../apache/kafka/streams/StreamsBuilderTest.java | 79 ++++++++++++++++++++++
.../ForeignTableJoinProcessorSupplierTests.java | 9 ++-
.../SubscriptionReceiveProcessorSupplierTest.java | 6 +-
7 files changed, 131 insertions(+), 30 deletions(-)
