This is an automated email from the ASF dual-hosted git repository. mjsax pushed a change to branch 2.5 in repository https://gitbox.apache.org/repos/asf/kafka.git.
from 2747cdc KAFKA-8843: KIP-515: Zookeeper TLS support add 536805d KAFKA-7658: Follow up to original PR (#8027) No new revisions were added by this update. Summary of changes: .../org/apache/kafka/streams/StreamsBuilder.java | 5 +- .../org/apache/kafka/streams/kstream/KStream.java | 56 ++++++- .../streams/kstream/internals/AbstractStream.java | 14 +- .../kstream/internals/CogroupedKStreamImpl.java | 29 ++-- .../internals/GroupedStreamAggregateBuilder.java | 15 +- .../kstream/internals/KGroupedStreamImpl.java | 17 +- .../kstream/internals/KGroupedTableImpl.java | 4 +- .../streams/kstream/internals/KStreamImpl.java | 121 ++++++-------- .../streams/kstream/internals/KStreamImplJoin.java | 10 +- .../streams/kstream/internals/KTableImpl.java | 39 ++--- .../SessionWindowedCogroupedKStreamImpl.java | 13 +- .../internals/SessionWindowedKStreamImpl.java | 4 +- .../TimeWindowedCogroupedKStreamImpl.java | 13 +- .../kstream/internals/TimeWindowedKStreamImpl.java | 4 +- .../kstream/internals/AbstractStreamTest.java | 6 +- .../streams/kstream/internals/KStreamImplTest.java | 182 +++++++++++---------- 16 files changed, 288 insertions(+), 244 deletions(-)