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(-)