chia7712 commented on a change in pull request #11006: URL: https://github.com/apache/kafka/pull/11006#discussion_r668398858
########## File path: core/src/main/scala/kafka/log/LogManager.scala ########## @@ -312,7 +312,15 @@ class LogManager(logDirs: Seq[File], val logDirAbsolutePath = dir.getAbsolutePath var hadCleanShutdown: Boolean = false try { - val pool = Executors.newFixedThreadPool(numRecoveryThreadsPerDataDir) + val pool = Executors.newFixedThreadPool(numRecoveryThreadsPerDataDir, new ThreadFactory { + private val factory = Executors.defaultThreadFactory() + private val threadNumber = new AtomicInteger(1) Review comment: Why we need this counter? It seems to me `log-recovery` is good enough. ########## File path: core/src/main/scala/kafka/log/LogManager.scala ########## @@ -312,7 +312,15 @@ class LogManager(logDirs: Seq[File], val logDirAbsolutePath = dir.getAbsolutePath var hadCleanShutdown: Boolean = false try { - val pool = Executors.newFixedThreadPool(numRecoveryThreadsPerDataDir) + val pool = Executors.newFixedThreadPool(numRecoveryThreadsPerDataDir, new ThreadFactory { Review comment: line#495 (`shutdown`) creates thread poll also. Does it need a better naming? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: jira-unsubscr...@kafka.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org