junrao commented on a change in pull request #11327:
URL: https://github.com/apache/kafka/pull/11327#discussion_r715227056
##
File path: core/src/main/scala/kafka/log/LogCleanerManager.scala
##
@@ -512,6 +514,27 @@ private[log] class LogCleanerManager(val logDirs:
Seq[File],
junrao commented on a change in pull request #11327:
URL: https://github.com/apache/kafka/pull/11327#discussion_r714305801
##
File path: core/src/main/scala/kafka/log/LogCleanerManager.scala
##
@@ -512,6 +514,27 @@ private[log] class LogCleanerManager(val logDirs:
Seq[File],
junrao commented on a change in pull request #11327:
URL: https://github.com/apache/kafka/pull/11327#discussion_r712335875
##
File path: core/src/main/scala/kafka/log/LogCleanerManager.scala
##
@@ -511,6 +513,27 @@ private[log] class LogCleanerManager(val logDirs:
Seq[File],
junrao commented on a change in pull request #11327:
URL: https://github.com/apache/kafka/pull/11327#discussion_r710316445
##
File path: core/src/main/scala/kafka/log/LogCleanerManager.scala
##
@@ -103,11 +103,14 @@ private[log] class LogCleanerManager(val logDirs:
Seq[File],