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/09/25 20:41:33 UTC

[kafka] branch trunk updated (2933f21 -> f712ce6)

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 2933f21  KAFKA-7403; Use default timestamp if no expire timestamp set in offset commit value (#5690)
     add f712ce6  KAFKA-7223: add tests in preparation for suppression (#5687)

No new revisions were added by this update.

Summary of changes:
 .../apache/kafka/streams/kstream/Suppressed.java   |   2 +-
 .../streams/kstream/internals/FullChangeSerde.java | 128 +++++++
 .../streams/kstream/internals/KTableImpl.java      |   7 +-
 .../suppress/FinalResultsSuppressionBuilder.java   |   3 +-
 .../suppress/KTableSuppressProcessor.java          |  30 +-
 .../kstream/internals/suppress/SuppressedImpl.java |   9 +-
 .../integration/SuppressionIntegrationTest.java    | 297 ++++++++++++++-
 .../kafka/streams/kstream/SuppressedTest.java      |  10 +-
 .../kstream/internals/FullChangeSerdeTest.java     | 167 +++++++++
 .../kstream/internals/SuppressScenarioTest.java    | 410 +++++++++++++++++++++
 .../suppress/KTableSuppressProcessorTest.java      | 255 ++++++++++---
 11 files changed, 1242 insertions(+), 76 deletions(-)
 create mode 100644 streams/src/main/java/org/apache/kafka/streams/kstream/internals/FullChangeSerde.java
 create mode 100644 streams/src/test/java/org/apache/kafka/streams/kstream/internals/FullChangeSerdeTest.java