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

Posted to commits@kafka.apache.org by ab...@apache.org on 2022/11/19 06:39:20 UTC

[kafka] branch trunk updated (1d6430249b8 -> 56ab2f80343)

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

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


    from 1d6430249b8 KAFKA-14406: Fix double iteration of restoring records (#12842)
     add 56ab2f80343 KAFKA-14382: wait for current rebalance to complete before triggering followup (#12869)

No new revisions were added by this update.

Summary of changes:
 .../streams/processor/internals/StreamThread.java  |   8 +-
 .../streams/processor/internals/TaskManager.java   |   2 +-
 .../processor/internals/StreamThreadTest.java      | 112 ++++++++++++++++-----
 .../processor/internals/TaskManagerTest.java       |   8 +-
 4 files changed, 98 insertions(+), 32 deletions(-)