[GitHub] [kafka] junrao commented on a diff in pull request #12347: KAFKA-13919: expose log recovery metrics

junrao commented on code in PR #12347: URL: https://github.com/apache/kafka/pull/12347#discussion_r920568430 ## core/src/test/scala/unit/kafka/log/LogManagerTest.scala: ## @@ -638,6 +641,221 @@ class LogManagerTest { assertTrue(logManager.partitionsInitializing.isEmpty)

[GitHub] [kafka] junrao commented on a diff in pull request #12347: KAFKA-13919: expose log recovery metrics

junrao commented on code in PR #12347: URL: https://github.com/apache/kafka/pull/12347#discussion_r919529062 ## core/src/main/scala/kafka/log/LogManager.scala: ## @@ -366,25 +392,30 @@ class LogManager(logDirs: Seq[File], val numLogsLoaded = new AtomicInteger(0)