Log Management System
LogManager is given the log directories that are configured using log.dirs or log.dir configuration properties (default: /tmp/kafka-logs). The log directories are immediately loaded (on a fixed thread pool with numRecoveryThreadsPerDataDir recovery threads).
Every log directory may hold zero, one or more partition log directories.
LogManager creates a Log for every partition log (that is of the format topic-partition or topic-partition.uniqueId-delete).
LogManager handles the enforcement of the flush policy and log compaction and retention.
Use kafka-dump-log.sh shell script for sanity check of log files and printing contents out to the console.