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

Posted to commits@kafka.apache.org by ca...@apache.org on 2022/08/29 16:29:31 UTC

[kafka] branch trunk updated (0e6a3fa9789 -> 7b07b2676bf)

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

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


    from 0e6a3fa9789 KAFKA-10199: Handle restored tasks output by state updater (#12554)
     add 7b07b2676bf KAFKA-10199: Remove tasks from state updater on shutdown (#12562)

No new revisions were added by this update.

Summary of changes:
 .../processor/internals/DefaultStateUpdater.java   | 50 +++++++++----
 .../internals/DefaultStateUpdaterTest.java         | 86 ++++++++++++++++++++--
 2 files changed, 115 insertions(+), 21 deletions(-)