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

Posted to commits@kafka.apache.org by gu...@apache.org on 2018/10/04 01:05:59 UTC

[kafka] branch trunk updated (7bd8ada -> 87879d5)

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 7bd8ada  MINOR: Docs on state store instantiation (#5698)
     add 87879d5  KAFKA-7223: Add name config to Suppressed (#5731)

No new revisions were added by this update.

Summary of changes:
 .../org/apache/kafka/streams/kstream/KTable.java   |   2 +-
 .../apache/kafka/streams/kstream/Suppressed.java   |  31 +--
 .../streams/kstream/internals/KTableImpl.java      |  25 ++-
 .../internals/suppress/BufferConfigInternal.java   |   5 -
 .../suppress/FinalResultsSuppressionBuilder.java   |  20 +-
 .../suppress/KTableSuppressProcessor.java          |  10 +-
 .../internals/suppress/SuppressedInternal.java     |  33 +++-
 .../kafka/streams/kstream/SuppressedTest.java      |  39 +++-
 .../kstream/internals/SuppressScenarioTest.java    |  17 +-
 .../kstream/internals/SuppressTopologyTest.java    | 210 +++++++++++++++++++++
 10 files changed, 329 insertions(+), 63 deletions(-)
 create mode 100644 streams/src/test/java/org/apache/kafka/streams/kstream/internals/SuppressTopologyTest.java