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 2021/05/19 22:00:28 UTC

[kafka] branch trunk updated (b58da35 -> 476eccb)

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 b58da35  KAFKA-12810: Remove deprecated TopologyDescription.Source#topics (#10727)
     add 476eccb  KAFKA-12815: Preserve context for KTable.transformValues when getting value from upstream state store (#10720)

No new revisions were added by this update.

Summary of changes:
 .../kstream/internals/KStreamAggregate.java        |  7 ++---
 .../streams/kstream/internals/KStreamReduce.java   | 14 +++++-----
 .../internals/KStreamSessionWindowAggregate.java   | 17 +++++-------
 .../internals/KStreamSlidingWindowAggregate.java   | 21 ++++++++-------
 .../kstream/internals/KStreamWindowAggregate.java  | 19 +++++++-------
 .../streams/kstream/internals/KTableFilter.java    |  3 +--
 .../kstream/internals/KTableKTableInnerJoin.java   |  8 +++---
 .../kstream/internals/KTableKTableLeftJoin.java    |  8 +++---
 .../kstream/internals/KTableKTableOuterJoin.java   |  8 +++---
 .../kstream/internals/KTableKTableRightJoin.java   |  8 +++---
 .../streams/kstream/internals/KTableMapValues.java |  5 ++--
 .../KTableMaterializedValueGetterSupplier.java     |  3 +--
 .../kstream/internals/KTablePassThrough.java       |  3 +--
 .../internals/KTableSourceValueGetterSupplier.java |  3 +--
 .../kstream/internals/KTableTransformValues.java   | 25 +++++++++++++++---
 .../suppress/KTableSuppressProcessorSupplier.java  |  5 ++--
 .../internals/KTableTransformValuesTest.java       | 30 ++++++++++++++++++----
 17 files changed, 109 insertions(+), 78 deletions(-)