[GitHub] [kafka] junrao commented on a change in pull request #9178: KAFKA-8362: fix the old checkpoint won't be removed after alter log dir

junrao commented on a change in pull request #9178: URL: https://github.com/apache/kafka/pull/9178#discussion_r486454693 ## File path: core/src/main/scala/kafka/log/LogCleanerManager.scala ## @@ -354,12 +354,30 @@ private[log] class LogCleanerManager(val logDirs: Seq[File],

[GitHub] [kafka] junrao commented on a change in pull request #9178: KAFKA-8362: fix the old checkpoint won't be removed after alter log dir

junrao commented on a change in pull request #9178: URL: https://github.com/apache/kafka/pull/9178#discussion_r485958438 ## File path: core/src/main/scala/kafka/server/ReplicaManager.scala ## @@ -1698,8 +1698,12 @@ class ReplicaManager(val config: KafkaConfig, Partition.re