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/09/03 00:50:45 UTC

[kafka] branch trunk updated (7ec10ce19a -> 8380d2edf4)

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 7ec10ce19a HOTFIX: fix PriorityQueue iteration to assign warmups in priority order (#12585)
     add 8380d2edf4 KAFKA-10199: Handle exceptions from state updater (#12519)

No new revisions were added by this update.

Summary of changes:
 .../processor/internals/DefaultStateUpdater.java   |  10 ++
 .../streams/processor/internals/TaskManager.java   | 191 +++++++++++++--------
 .../kafka/streams/processor/internals/Tasks.java   |  53 ++----
 .../streams/processor/internals/TasksRegistry.java |   6 +-
 .../processor/internals/TaskManagerTest.java       |  95 +++++++++-
 5 files changed, 232 insertions(+), 123 deletions(-)