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 2271e748a11 MINOR: fix zookeeper_migration_test.py (#13620)
add 6dcdb017327 KAFKA-14862: Outer stream-stream join does not output all
results with multiple input partitions (#13592)
No new revisions were added by this update.
Summary of changes:
.../streams/kstream/internals/KStreamImplJoin.java | 21 ++-
.../kstream/internals/KStreamKStreamJoin.java | 15 +-
.../kstream/internals/KStreamKStreamSelfJoin.java | 9 +-
.../integration/KStreamKStreamIntegrationTest.java | 185 +++++++++++++++++++++
.../kstream/internals/KStreamKStreamJoinTest.java | 2 +-
5 files changed, 217 insertions(+), 15 deletions(-)
create mode 100644
streams/src/test/java/org/apache/kafka/streams/integration/KStreamKStreamIntegrationTest.java
