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 342f13a KAFKA-8843: KIP-515: Zookeeper TLS support add 059a81e 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 | 212 +++++++++++---------- 16 files changed, 303 insertions(+), 259 deletions(-)