Page History

...

• log.dirs=/tmp/log1,tmp/log2
• num.recovery.threads.per.data.dir=2

In the jmx, we'll see something like this during log recovery

• kafka.log
  • LogManager
    • RemainingLogsToRecover 
      • /tmp/log1 => 5            ← there are 5 logs under /tmp/log1 needed to be recovered
        
      • /tmp/log2 => 0
    • RemainingSegmentsToRecover
      • /tmp/log1                     ← 2 threads are doing log recovery for /tmp/log1
        
        • 0 => 10000         ← there are 10000 segments needed to be recovered for thread 0
        • 1 => 3
          
      • /tmp/log2
        • 0 => 0
        • 1 => 0

...