dajac opened a new pull request #8672: URL: https://github.com/apache/kafka/pull/8672
* Update checkpoint files once for all deleted partitions instead of updating them for each deleted partitions. * Refactor the checkpointing methods to not compute the `logsByDir` all the time. It is now reused as much as possible. * Refactor the exception handling. Some checkpointing methods were handling `IOException` but the underlying write process already catches them and throws KafkaStorageException instead. * Reduce the logging in the log cleaner manager. It does not log anymore when a partition is deleted as it is not a useful information. ### Committer Checklist (excluded from commit message) - [ ] Verify design and implementation - [ ] Verify test coverage and CI build status - [ ] 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. For queries about this service, please contact Infrastructure at: us...@infra.apache.org
