tombentley commented on code in PR #12347:
URL: https://github.com/apache/kafka/pull/12347#discussion_r925348863
##
core/src/main/scala/kafka/log/LogLoader.scala:
##
@@ -64,6 +65,7 @@ object LogLoader extends Logging {
* @param recoveryPointCheckpoint The checkpoint of the off
tombentley commented on code in PR #12347:
URL: https://github.com/apache/kafka/pull/12347#discussion_r916044426
##
core/src/main/scala/kafka/log/LogManager.scala:
##
@@ -307,6 +313,22 @@ class LogManager(logDirs: Seq[File],
log
}
+ import java.util.concurrent.ThreadF
