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 2022/04/20 18:39:22 UTC

[kafka] branch trunk updated (d83fccd65f -> c5077c679c)

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 d83fccd65f KAFKA-13785: [5/N][emit final] cache for time ordered window store (#12030)
     add c5077c679c KAFKA-13588: consolidate `changelogFor` methods to simplify the generation of internal topic names (#11703)

No new revisions were added by this update.

Summary of changes:
 .../internals/InternalTopologyBuilder.java         | 24 ++++++++-----------
 .../processor/internals/ProcessorContextUtils.java | 26 +++++++++++++-------
 .../state/internals/CachingWindowStore.java        | 20 ++++++----------
 .../InMemoryTimeOrderedKeyValueBuffer.java         | 12 +++-------
 .../state/internals/MeteredKeyValueStore.java      | 28 ++++------------------
 .../state/internals/MeteredSessionStore.java       | 28 ++++------------------
 .../state/internals/MeteredWindowStore.java        | 24 ++++---------------
 7 files changed, 49 insertions(+), 113 deletions(-)