package
log
Type Members
-
case class
CleanerConfig(numThreads: Int = 1, dedupeBufferSize: Long = 4.*(1024).*(1024L), dedupeBufferLoadFactor: Double = 0.9, ioBufferSize: Int = 1024.*(1024), maxMessageSize: Int = 32.*(1024).*(1024), maxIoBytesPerSecond: Double = scala.Double.MaxValue, backOffMs: Long = 15.*(1000), enableCleaner: Boolean = true, hashAlgorithm: String = "MD5") extends Product with Serializable
-
-
-
-
case class
LogConfig(segmentSize: Int = Defaults.SegmentSize, segmentMs: Long = Defaults.SegmentMs, segmentJitterMs: Long = Defaults.SegmentJitterMs, flushInterval: Long = Defaults.FlushInterval, flushMs: Long = Defaults.FlushMs, retentionSize: Long = Defaults.RetentionSize, retentionMs: Long = Defaults.RetentionMs, maxMessageSize: Int = Defaults.MaxMessageSize, maxIndexSize: Int = Defaults.MaxIndexSize, indexInterval: Int = Defaults.IndexInterval, fileDeleteDelayMs: Long = Defaults.FileDeleteDelayMs, deleteRetentionMs: Long = Defaults.DeleteRetentionMs, minCleanableRatio: Double = Defaults.MinCleanableDirtyRatio, compact: Boolean = Defaults.Compact, uncleanLeaderElectionEnable: Boolean = ..., minInSyncReplicas: Int = Defaults.MinInSyncReplicas) extends Product with Serializable
-
-
-
-
trait
OffsetMap extends AnyRef
-
case class
OffsetPosition(offset: Long, position: Int) extends Product with Serializable
-
Value Members
-
-
object
Log
-
object
LogConfig extends Serializable
-