kafka.log

CleanerConfig

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

Configuration parameters for the log cleaner

numThreads

The number of cleaner threads to run

dedupeBufferSize

The total memory used for log deduplication

dedupeBufferLoadFactor

The maximum percent full for the deduplication buffer

maxMessageSize

The maximum size of a message that can appear in the log

maxIoBytesPerSecond

The maximum read and write I/O that all cleaner threads are allowed to do

backOffMs

The amount of time to wait before rechecking if no logs are eligible for cleaning

enableCleaner

Allows completely disabling the log cleaner

hashAlgorithm

The hash algorithm to use in key comparison.

Linear Supertypes
Serializable, Serializable, Product, Equals, AnyRef, Any
Ordering
  1. Alphabetic
  2. By inheritance
Inherited
  1. CleanerConfig
  2. Serializable
  3. Serializable
  4. Product
  5. Equals
  6. AnyRef
  7. Any
  1. Hide All
  2. Show all
Learn more about member selection
Visibility
  1. Public
  2. All

Instance Constructors

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

    numThreads

    The number of cleaner threads to run

    dedupeBufferSize

    The total memory used for log deduplication

    dedupeBufferLoadFactor

    The maximum percent full for the deduplication buffer

    maxMessageSize

    The maximum size of a message that can appear in the log

    maxIoBytesPerSecond

    The maximum read and write I/O that all cleaner threads are allowed to do

    backOffMs

    The amount of time to wait before rechecking if no logs are eligible for cleaning

    enableCleaner

    Allows completely disabling the log cleaner

    hashAlgorithm

    The hash algorithm to use in key comparison.

Value Members

  1. final def !=(arg0: AnyRef): Boolean

    Definition Classes
    AnyRef

  2. final def !=(arg0: Any): Boolean

    Definition Classes
    Any

  3. final def ##(): Int

    Definition Classes
    AnyRef → Any

  4. final def ==(arg0: AnyRef): Boolean

    Definition Classes
    AnyRef

  5. final def ==(arg0: Any): Boolean

    Definition Classes
    Any

  6. final def asInstanceOf[T0]: T0

    Definition Classes
    Any

  7. val backOffMs: Long

    The amount of time to wait before rechecking if no logs are eligible for cleaning

  8. def clone(): AnyRef

    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )

  9. val dedupeBufferLoadFactor: Double

    The maximum percent full for the deduplication buffer

  10. val dedupeBufferSize: Long

    The total memory used for log deduplication

  11. val enableCleaner: Boolean

    Allows completely disabling the log cleaner

  12. final def eq(arg0: AnyRef): Boolean

    Definition Classes
    AnyRef

  13. def finalize(): Unit

    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( classOf[java.lang.Throwable] )

  14. final def getClass(): Class[_]

    Definition Classes
    AnyRef → Any

  15. val hashAlgorithm: String

    The hash algorithm to use in key comparison.

  16. val ioBufferSize: Int

  17. final def isInstanceOf[T0]: Boolean

    Definition Classes
    Any

  18. val maxIoBytesPerSecond: Double

    The maximum read and write I/O that all cleaner threads are allowed to do

  19. val maxMessageSize: Int

    The maximum size of a message that can appear in the log

  20. final def ne(arg0: AnyRef): Boolean

    Definition Classes
    AnyRef

  21. final def notify(): Unit

    Definition Classes
    AnyRef

  22. final def notifyAll(): Unit

    Definition Classes
    AnyRef

  23. val numThreads: Int

    The number of cleaner threads to run

  24. final def synchronized[T0](arg0: ⇒ T0): T0

    Definition Classes
    AnyRef

  25. final def wait(): Unit

    Definition Classes
    AnyRef
    Annotations
    @throws( ... )

  26. final def wait(arg0: Long, arg1: Int): Unit

    Definition Classes
    AnyRef
    Annotations
    @throws( ... )

  27. final def wait(arg0: Long): Unit

    Definition Classes
    AnyRef
    Annotations
    @throws( ... )

Inherited from Serializable

Inherited from Serializable

Inherited from Product

Inherited from Equals

Inherited from AnyRef

Inherited from Any

Ungrouped