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/11/14 09:00:36 UTC

[kafka] branch trunk updated (e422a67d3f0 -> a55071a99fa)

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 e422a67d3f0 KAFKA-14294: check whether a transaction is in flight before skipping a commit (#12835)
     add a55071a99fa KAFKA-14299: Initialize tasks in state updater (#12795)

No new revisions were added by this update.

Summary of changes:
 .../processor/internals/DefaultStateUpdater.java   | 54 +++++++++-----
 .../streams/processor/internals/TaskManager.java   | 22 +-----
 .../kafka/streams/processor/internals/Tasks.java   | 12 ----
 .../streams/processor/internals/TasksRegistry.java |  4 --
 .../internals/DefaultStateUpdaterTest.java         | 66 +++++++++++++++--
 .../processor/internals/TaskManagerTest.java       | 82 +---------------------
 6 files changed, 99 insertions(+), 141 deletions(-)