Package

kafka.manager.utils

zero82

Permalink

package zero82

Visibility
  1. Public
  2. All

Type Members

  1. 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

    Permalink

    Configuration settings for a log

    Configuration settings for a log

    segmentSize

    The soft maximum for the size of a segment file in the log

    segmentMs

    The soft maximum on the amount of time before a new log segment is rolled

    segmentJitterMs

    The maximum random jitter subtracted from segmentMs to avoid thundering herds of segment rolling

    flushInterval

    The number of messages that can be written to the log before a flush is forced

    flushMs

    The amount of time the log can have dirty data before a flush is forced

    retentionSize

    The approximate total number of bytes this log can use

    retentionMs

    The age approximate maximum age of the last segment that is retained

    maxIndexSize

    The maximum size of an index file

    indexInterval

    The approximate number of bytes between index entries

    fileDeleteDelayMs

    The time to wait before deleting a file from the filesystem

    deleteRetentionMs

    The time to retain delete markers in the log. Only applicable for logs that are being compacted.

    minCleanableRatio

    The ratio of bytes that are available for cleaning to the bytes already cleaned

    compact

    Should old segments in this log be deleted or deduplicated?

    uncleanLeaderElectionEnable

    Indicates whether unclean leader election is enabled; actually a controller-level property but included here for topic-specific configuration validation purposes

    minInSyncReplicas

    If number of insync replicas drops below this number, we stop accepting writes with -1 (or all) required acks

Value Members

  1. object Defaults

    Permalink

    Copied from kafka 0.8.2.1 https://git-wip-us.apache.org/repos/asf?p=kafka.git;a=blob;f=core/src/main/scala/kafka/log/LogConfig.scala

  2. object LogConfig extends TopicConfigs with Serializable

    Permalink

Ungrouped