nicktelford opened a new pull request, #21649:
URL: https://github.com/apache/kafka/pull/21649
The main motivation for this is to better align `GlobalStateManagerImpl`
with `ProcessorStateManager` where we can, as it will make implementing
elements of KIP-1035 easier, and ultimately lead to easier to maintain
code.
The primary changes here are:
1. To encapsulate store metadata in
`GlobalStateManagerImpl.StateStoreMetadata`.
2. Moves the `restoreState`/`reprocessState` calls to the end of
`initialize()`.
Consequently, the only behavioural change here is that
`restoreState`/`reprocessState` now happens after _all_ stores have been
registered (`registerStore`), instead of at the end of the registration
process for each store.
This is similar to `ProcessorStateManager`, which registers and
initializes all stores before beginning state restore (via. the
`StateUpdater`).
This change should have no real impact on users, as it will still take
the same amount of time to fully restore all global stores, before they
begin processing.
--
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: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
