This is an automated email from the ASF dual-hosted git repository.
guozhang pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git.
from 816f5c3 KAFKA-5876: KIP-216 Part 3, Apply StreamsNotStartedException
for Interactive Queries (#10597)
add 62221ed KAFKA-10847: Add internal flag to disable KAFKA-10847 fix
(#10612)
No new revisions were added by this update.
Summary of changes:
.../org/apache/kafka/streams/StreamsConfig.java | 15 +++
.../kstream/internals/KStreamKStreamJoin.java | 11 +-
.../internals/graph/StreamStreamJoinNode.java | 8 +-
.../internals/InternalTopologyBuilder.java | 17 +++
.../internals/KStreamKStreamLeftJoinTest.java | 124 +++++++++++++++++++++
.../internals/KStreamKStreamOuterJoinTest.java | 76 ++++++++++++-
.../internals/InternalTopologyBuilderTest.java | 12 ++
7 files changed, 255 insertions(+), 8 deletions(-)
