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

Posted to commits@kafka.apache.org by vv...@apache.org on 2020/02/25 19:23:57 UTC

[kafka] branch trunk updated (9639ff4 -> 9064026)

This is an automated email from the ASF dual-hosted git repository.

vvcephei pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git.


    from 9639ff4  Revert "KAFKA-9533: ValueTransform forwards `null` values (#8108)" (#8167)
     add 9064026  KAFKA-8147: Add changelog topic configuration to KTable suppress (#8029)

No new revisions were added by this update.

Summary of changes:
 .../apache/kafka/streams/kstream/Suppressed.java   |  20 +++
 .../streams/kstream/internals/KTableImpl.java      |  20 ++-
 .../internals/suppress/BufferConfigInternal.java   |   8 +-
 .../internals/suppress/EagerBufferConfigImpl.java  |  36 +++-
 .../internals/suppress/StrictBufferConfigImpl.java |  35 ++++
 .../internals/suppress/SuppressedInternal.java     |   3 +-
 .../InMemoryTimeOrderedKeyValueBuffer.java         |   6 +-
 .../integration/SuppressionIntegrationTest.java    | 183 +++++++++++++++++++++
 .../integration/utils/EmbeddedKafkaCluster.java    |   9 +
 .../InMemoryTimeOrderedKeyValueBufferTest.java     |  30 ++++
 10 files changed, 343 insertions(+), 7 deletions(-)