Can we refactor the logic so we don't have to maintain global `logBeingCleaned`? It seems like we could move this exception handling to `cleanFilthiestLog` or have `cleanOrSleep` drive which segment to clean / delete.
[ Full content available at: https://github.com/apache/kafka/pull/5439 ] This message was relayed via gitbox.apache.org for [email protected]
