< Back
 

# Packages

-  package root
  Definition Classes
    root
-  package kafka
  Definition Classes
    root
-  package manager

  Definition Classes
    kafka
-  package utils

  Definition Classes
    manager
-  package zero82
  Definition Classes
    utils
- Defaults
- LogConfig

c

kafka.manager.utils.zero82

# LogConfig 

###
Companion object LogConfig

#### 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

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

Linear Supertypes
Serializable, Serializable, Product, Equals, AnyRef, Any
 
Ordering

1. Alphabetic
2. By Inheritance

Inherited

1. LogConfig
2. Serializable
3. Serializable
4. Product
5. Equals
6. AnyRef
7. Any

1. Hide All
2. Show All

Visibility

1. Public
2. All

### Instance Constructors

1.  new 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)

   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.  final def !=(arg0: Any): Boolean
   Definition Classes
     AnyRef → Any
2.  final def ##(): Int
   Definition Classes
     AnyRef → Any
3.  final def ==(arg0: Any): Boolean
   Definition Classes
     AnyRef → Any
4.  def abs(n: Int): Int

   Get the absolute value of the given number.

   Get the absolute value of the given number. If the number is Int.MinValue return 0. This is different from java.lang.Math.abs or scala.math.abs in that they return Int.MinValue (!).

5.  final def asInstanceOf[T0]: T0
   Definition Classes
     Any
6.  def clone(): AnyRef
   Attributes
     protected[java.lang]
   Definition Classes
     AnyRef
   Annotations
     @native() @throws( ... )
7.  val compact: Boolean
8.  val deleteRetentionMs: Long
9.  final def eq(arg0: AnyRef): Boolean
   Definition Classes
     AnyRef
10.  val fileDeleteDelayMs: Long
11.  def finalize(): Unit
    Attributes
      protected[java.lang]
    Definition Classes
      AnyRef
    Annotations
      @throws( classOf[java.lang.Throwable] )
12.  val flushInterval: Long
13.  val flushMs: Long
14.  final def getClass(): Class[_]
    Definition Classes
      AnyRef → Any
    Annotations
      @native()
15.  val indexInterval: Int
16.  final def isInstanceOf[T0]: Boolean
    Definition Classes
      Any
17.  val maxIndexSize: Int
18.  val maxMessageSize: Int
19.  val minCleanableRatio: Double
20.  val minInSyncReplicas: Int
21.  final def ne(arg0: AnyRef): Boolean
    Definition Classes
      AnyRef
22.  final def notify(): Unit
    Definition Classes
      AnyRef
    Annotations
      @native()
23.  final def notifyAll(): Unit
    Definition Classes
      AnyRef
    Annotations
      @native()
24.  def randomSegmentJitter: Long
25.  val retentionMs: Long
26.  val retentionSize: Long
27.  val segmentJitterMs: Long
28.  val segmentMs: Long
29.  val segmentSize: Int
30.  final def synchronized[T0](arg0: ⇒ T0): T0
    Definition Classes
      AnyRef
31.  def toProps: Properties
32.  val uncleanLeaderElectionEnable: Boolean
33.  final def wait(): Unit
    Definition Classes
      AnyRef
    Annotations
      @throws( ... )
34.  final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
      AnyRef
    Annotations
      @throws( ... )
35.  final def wait(arg0: Long): Unit
    Definition Classes
      AnyRef
    Annotations
      @native() @throws( ... )

### Inherited from Serializable

### Inherited from Product

### Inherited from Equals

### Inherited from AnyRef

### Inherited from Any

### Ungrouped