You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by mj...@apache.org on 2021/06/16 16:28:06 UTC
[kafka] branch trunk updated (f0bb85c -> 96767a6)
This is an automated email from the ASF dual-hosted git repository.
mjsax pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git.
from f0bb85c KAFKA-12931: KIP-746: Revise KRaft Metadata Records (#10867)
add 96767a6 KAFKA-12909: disable spurious left/outer stream-stream join fix for old JoinWindows API (#10861)
No new revisions were added by this update.
Summary of changes:
.../apache/kafka/streams/kstream/JoinWindows.java | 33 +-
...essorSupplier.java => JoinWindowsInternal.java} | 13 +-
.../streams/kstream/internals/KStreamImplJoin.java | 13 +-
.../kstream/internals/KStreamKStreamJoin.java | 24 +-
.../internals/graph/StreamStreamJoinNode.java | 28 +-
.../apache/kafka/streams/StreamsBuilderTest.java | 83 +++-
.../org/apache/kafka/streams/TopologyTest.java | 12 +-
.../StreamStreamJoinIntegrationTest.java | 57 ++-
.../KStreamImplValueJoinerWithKeyTest.java | 95 ++--
.../kstream/internals/KStreamKStreamJoinTest.java | 512 +++++++++++++--------
.../internals/KStreamKStreamLeftJoinTest.java | 420 ++++++++++-------
.../internals/KStreamKStreamOuterJoinTest.java | 445 +++++++++++-------
12 files changed, 1109 insertions(+), 626 deletions(-)
copy streams/src/main/java/org/apache/kafka/streams/kstream/internals/{KStreamAggProcessorSupplier.java => JoinWindowsInternal.java} (74%)