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/07/28 20:29:04 UTC

[kafka] branch trunk updated (9e74f91e56 -> 2724cc9920)

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 9e74f91e56 KAFKA-14089: Only check for committed seqnos after disabling exactly-once support in Connect integration test (#12429)
     add 2724cc9920 KAFKA-10199: Bookkeep tasks during assignment for use with state updater (#12442)

No new revisions were added by this update.

Summary of changes:
 .../streams/processor/internals/StreamThread.java  |  17 ++-
 .../streams/processor/internals/TaskManager.java   | 155 ++++++++++++++-------
 .../kafka/streams/processor/internals/Tasks.java   |  21 +++
 .../processor/internals/StreamThreadTest.java      |   4 +-
 .../processor/internals/TaskManagerTest.java       |  92 ++++++++----
 .../org/apache/kafka/test/StreamsTestUtils.java    |  23 ---
 6 files changed, 212 insertions(+), 100 deletions(-)