class
LogManager
extends Logging
Instance Constructors
-
new
LogManager
(logDirs: Array[File], topicConfigs: Map[String, LogConfig], defaultConfig: LogConfig, cleanerConfig: CleanerConfig, ioThreads: Int, flushCheckMs: Long, flushCheckpointMs: Long, retentionCheckMs: Long, scheduler: Scheduler, brokerState: BrokerState, time: Time)
Value Members
-
def
!=
(arg0: AnyRef): Boolean
-
def
!=
(arg0: Any): Boolean
-
def
##
(): Int
-
def
==
(arg0: AnyRef): Boolean
-
def
==
(arg0: Any): Boolean
-
val
InitialTaskDelayMs
: Int
-
val
LockFile
: String
-
val
RecoveryPointCheckpointFile
: String
-
def
allLogs
(): Iterable[Log]
-
def
asInstanceOf
[T0]
: T0
-
-
def
checkpointRecoveryPointOffsets
(): Unit
-
-
-
def
cleanupLogs
(): Unit
-
def
clone
(): AnyRef
-
-
def
debug
(msg: ⇒ String, e: ⇒ Throwable): Unit
-
def
debug
(e: ⇒ Throwable): Any
-
def
debug
(msg: ⇒ String): Unit
-
val
defaultConfig
: LogConfig
-
def
deleteLog
(topicAndPartition: TopicAndPartition): Unit
-
def
eq
(arg0: AnyRef): Boolean
-
def
equals
(arg0: Any): Boolean
-
def
error
(msg: ⇒ String, e: ⇒ Throwable): Unit
-
def
error
(e: ⇒ Throwable): Any
-
def
error
(msg: ⇒ String): Unit
-
def
fatal
(msg: ⇒ String, e: ⇒ Throwable): Unit
-
def
fatal
(e: ⇒ Throwable): Any
-
def
fatal
(msg: ⇒ String): Unit
-
def
finalize
(): Unit
-
val
flushCheckMs
: Long
-
val
flushCheckpointMs
: Long
-
def
getClass
(): java.lang.Class[_]
-
def
getLog
(topicAndPartition: TopicAndPartition): Option[Log]
-
def
hashCode
(): Int
-
def
info
(msg: ⇒ String, e: ⇒ Throwable): Unit
-
def
info
(e: ⇒ Throwable): Any
-
def
info
(msg: ⇒ String): Unit
-
def
isInstanceOf
[T0]
: Boolean
-
val
logDirs
: Array[File]
-
var
logIdent
: String
-
lazy val
logger
: Logger
-
val
loggerName
: String
-
-
def
ne
(arg0: AnyRef): Boolean
-
def
notify
(): Unit
-
def
notifyAll
(): Unit
-
val
retentionCheckMs
: Long
-
def
shutdown
(): Unit
-
def
startup
(): Unit
-
def
swallow
(action: ⇒ Unit): Unit
-
def
swallowDebug
(action: ⇒ Unit): Unit
-
def
swallowError
(action: ⇒ Unit): Unit
-
def
swallowInfo
(action: ⇒ Unit): Unit
-
def
swallowTrace
(action: ⇒ Unit): Unit
-
def
swallowWarn
(action: ⇒ Unit): Unit
-
def
synchronized
[T0]
(arg0: ⇒ T0): T0
-
def
toString
(): String
-
val
topicConfigs
: Map[String, LogConfig]
-
def
trace
(msg: ⇒ String, e: ⇒ Throwable): Unit
-
def
trace
(e: ⇒ Throwable): Any
-
def
trace
(msg: ⇒ String): Unit
-
def
truncateFullyAndStartAt
(topicAndPartition: TopicAndPartition, newOffset: Long): Unit
-
def
truncateTo
(partitionAndOffsets: Map[TopicAndPartition, Long]): Unit
-
def
wait
(): Unit
-
def
wait
(arg0: Long, arg1: Int): Unit
-
def
wait
(arg0: Long): Unit
-
def
warn
(msg: ⇒ String, e: ⇒ Throwable): Unit
-
def
warn
(e: ⇒ Throwable): Any
-
def
warn
(msg: ⇒ String): Unit
Inherited from AnyRef
Inherited from Any
The entry point to the kafka log management subsystem. The log manager is responsible for log creation, retrieval, and cleaning. All read and write operations are delegated to the individual log instances.
The log manager maintains logs in one or more directories. New logs are created in the data directory with the fewest logs. No attempt is made to move partitions after the fact or balance based on size or I/O rate.
A background thread handles log retention by periodically truncating excess log segments.