Skip to content

Conversation

@Nikita-Shupletsov
Copy link
Contributor

@Nikita-Shupletsov Nikita-Shupletsov commented Nov 22, 2025

  • Improved error handling in DefaultStateUpdater to take potential
    failures in Task#maybeCheckpoint into account.
  • Improved TaskManager#shutdownStateUpdater to not hang indefinitely if
    the State Updater thread is dead.

Cherry-pick of #20767

…20767)

- Improved error handling in DefaultStateUpdater to take potential
failures in Task#maybeCheckpoint into account.
- Improved TaskManager#shutdownStateUpdater to not hang indefinitely if
the State Updater thread is dead.

Reviewers: Matthias J. Sax <[email protected]>, Lucas Brutschy
 <[email protected]>

---------

Co-authored-by: Matthias J. Sax <[email protected]>

streams.removeStreamThread();

TestUtils.waitForCondition(() -> streams.state() == KafkaStreams.State.REBALANCING, TimeUnit.MINUTES.toMillis(2), "Streams never reached REBALANCING state");
Copy link
Member

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Why do we need this only for 4.1 branch?

Copy link
Contributor Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

for some reason in 4.1 branch rebalancing kicks in only after ~1 minute after the thread is removed. it didn't happen in trunk

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

Projects

None yet

Development

Successfully merging this pull request may close these issues.

2 participants