You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@kafka.apache.org by mj...@apache.org on 2020/02/09 06:00:14 UTC

[kafka] branch 2.5 updated (2747cdc -> 536805d)

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