KAFKA-17668: Rewrite LogCleaner#maxOverCleanerThreads and LogCleanerManager#maintainUncleanablePartitions

Open frankvicky opened this issue 1 year ago • 0 comments

Both methods can be rewrite by scala 2.13 methods

Since maxOverCleanerThreads does not have a corresponding unit test, I have added a unit test to ensure the result remains the same after replacing it with the new implementation.

maintainUncleanablePartitions has been thoroughly tested in unit tests, so I simply replaced the old implementation with the new one.

Committer Checklist (excluded from commit message)

[ ] Verify design and implementation
[ ] Verify test coverage and CI build status
[ ] Verify documentation (including upgrade notes)

Oct 07 '24 12:10 frankvicky