nicktelford opened a new pull request, #21739: URL: https://github.com/apache/kafka/pull/21739
As part of KIP-1035, we want to transition away from task-specific .checkpoint files, and instead delegate offset management to StateStores. We now have a `LegacyCheckpointingStateStore` wrapper to encapsulate the management of offsets for `StateStore` implementations that do not know how to manage their own offsets (i.e. for which `managesOffsets() == false`). As of KAFKA-20212, `RocksDBStore` now knows how to manage its own offsets, so it will not be wrapped in a `LegacyCheckpointingStateStore`; only user-defined persistent stores will use this wrapper. Corresponding changes to `ProcessorStateManager` have been submitted independently, as KAFKA-19712. Until both `ProcessorStateManager` and `GlobalStateManagerImpl` have been updated, the `StateManager` interface must remain as-is. Therefore, the `flush` and `checkpoint` methods will not be consolidated until a later PR, which will clean up the interface and its usage by `Task` and friends. -- 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]
