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 05:40:08 UTC

[kafka] branch trunk updated (342f13a -> 059a81e)

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