lucasbru opened a new pull request, #12771:
URL: https://github.com/apache/kafka/pull/12771
State stores are initialized from the `StreamThread` even when the state
updater thread is enabled.
However, we were missing the corresponding handling of exceptions when
thrown directly during
the initialization. In particular, `TaskCorruptedException` would directly
fall through to `runLoop`, and
the task would fall out of bookkeeping, since the exception is thrown when
neither the
`StreamThread` nor the `StateUpdater` is owning the task.
This change is validated by a unit test. We will add an integration test
once the code path is stable.
### Committer Checklist (excluded from commit message)
- [x] Verify design and implementation
- [x] Verify test coverage and CI build status
- [x] Verify documentation (including upgrade notes)
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: jira-unsubscr...@kafka.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
