kafka.server

OffsetManagerConfig

case class OffsetManagerConfig (maxMetadataSize: Int, loadBufferSize: Int, offsetsRetentionMs: Long, offsetsRetentionCheckIntervalMs: Long, offsetsTopicNumPartitions: Int, offsetsTopicSegmentBytes: Int, offsetsTopicReplicationFactor: Short, offsetsTopicCompressionCodec: CompressionCodec, offsetCommitTimeoutMs: Int, offsetCommitRequiredAcks: Short) extends Product with Serializable

Configuration settings for in-built offset management

maxMetadataSize

The maximum allowed metadata for any offset commit.

loadBufferSize

Batch size for reading from the offsets segments when loading offsets into the cache.

offsetsRetentionMs

Offsets older than this retention period will be discarded.

offsetsRetentionCheckIntervalMs

Frequency at which to check for stale offsets.

offsetsTopicNumPartitions

The number of partitions for the offset commit topic (should not change after deployment).

offsetsTopicSegmentBytes

The offsets topic segment bytes should be kept relatively small to facilitate faster log compaction and faster offset loads

offsetsTopicReplicationFactor

The replication factor for the offset commit topic (set higher to ensure availability).

offsetsTopicCompressionCodec

Compression codec for the offsets topic - compression should be turned on in order to achieve "atomic" commits.

offsetCommitTimeoutMs

The offset commit will be delayed until all replicas for the offsets topic receive the commit or this timeout is reached. (Similar to the producer request timeout.)

offsetCommitRequiredAcks

The required acks before the commit can be accepted. In general, the default (-1) should not be overridden.

Linear Supertypes
Serializable, Serializable, Product, Equals, AnyRef, Any
Ordering
  1. Alphabetic
  2. By inheritance
Inherited
  1. Hide All
  2. Show all
  1. OffsetManagerConfig
  2. Serializable
  3. Serializable
  4. Product
  5. Equals
  6. AnyRef
  7. Any
Visibility
  1. Public
  2. All

Instance Constructors

  1. new OffsetManagerConfig (maxMetadataSize: Int, loadBufferSize: Int, offsetsRetentionMs: Long, offsetsRetentionCheckIntervalMs: Long, offsetsTopicNumPartitions: Int, offsetsTopicSegmentBytes: Int, offsetsTopicReplicationFactor: Short, offsetsTopicCompressionCodec: CompressionCodec, offsetCommitTimeoutMs: Int, offsetCommitRequiredAcks: Short)

    maxMetadataSize

    The maximum allowed metadata for any offset commit.

    loadBufferSize

    Batch size for reading from the offsets segments when loading offsets into the cache.

    offsetsRetentionMs

    Offsets older than this retention period will be discarded.

    offsetsRetentionCheckIntervalMs

    Frequency at which to check for stale offsets.

    offsetsTopicNumPartitions

    The number of partitions for the offset commit topic (should not change after deployment).

    offsetsTopicSegmentBytes

    The offsets topic segment bytes should be kept relatively small to facilitate faster log compaction and faster offset loads

    offsetsTopicReplicationFactor

    The replication factor for the offset commit topic (set higher to ensure availability).

    offsetsTopicCompressionCodec

    Compression codec for the offsets topic - compression should be turned on in order to achieve "atomic" commits.

    offsetCommitTimeoutMs

    The offset commit will be delayed until all replicas for the offsets topic receive the commit or this timeout is reached. (Similar to the producer request timeout.)

    offsetCommitRequiredAcks

    The required acks before the commit can be accepted. In general, the default (-1) should not be overridden.

Value Members

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

    Attributes
    final
    Definition Classes
    AnyRef
  2. def != (arg0: Any): Boolean

    Attributes
    final
    Definition Classes
    Any
  3. def ## (): Int

    Attributes
    final
    Definition Classes
    AnyRef → Any
  4. def == (arg0: AnyRef): Boolean

    Attributes
    final
    Definition Classes
    AnyRef
  5. def == (arg0: Any): Boolean

    Attributes
    final
    Definition Classes
    Any
  6. def asInstanceOf [T0] : T0

    Attributes
    final
    Definition Classes
    Any
  7. def canEqual (arg0: Any): Boolean

    Definition Classes
    OffsetManagerConfig → Equals
  8. def clone (): AnyRef

    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws()
  9. def eq (arg0: AnyRef): Boolean

    Attributes
    final
    Definition Classes
    AnyRef
  10. def equals (arg0: Any): Boolean

    Definition Classes
    OffsetManagerConfig → Equals → AnyRef → Any
  11. def finalize (): Unit

    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws()
  12. def getClass (): java.lang.Class[_]

    Attributes
    final
    Definition Classes
    AnyRef → Any
  13. def hashCode (): Int

    Definition Classes
    OffsetManagerConfig → AnyRef → Any
  14. def isInstanceOf [T0] : Boolean

    Attributes
    final
    Definition Classes
    Any
  15. val loadBufferSize : Int

    Batch size for reading from the offsets segments when loading offsets into the cache.

  16. val maxMetadataSize : Int

    The maximum allowed metadata for any offset commit.

  17. def ne (arg0: AnyRef): Boolean

    Attributes
    final
    Definition Classes
    AnyRef
  18. def notify (): Unit

    Attributes
    final
    Definition Classes
    AnyRef
  19. def notifyAll (): Unit

    Attributes
    final
    Definition Classes
    AnyRef
  20. val offsetCommitRequiredAcks : Short

    The required acks before the commit can be accepted.

    The required acks before the commit can be accepted. In general, the default (-1) should not be overridden.

  21. val offsetCommitTimeoutMs : Int

    The offset commit will be delayed until all replicas for the offsets topic receive the commit or this timeout is reached.

    The offset commit will be delayed until all replicas for the offsets topic receive the commit or this timeout is reached. (Similar to the producer request timeout.)

  22. val offsetsRetentionCheckIntervalMs : Long

    Frequency at which to check for stale offsets.

  23. val offsetsRetentionMs : Long

    Offsets older than this retention period will be discarded.

  24. val offsetsTopicCompressionCodec : CompressionCodec

    Compression codec for the offsets topic - compression should be turned on in order to achieve "atomic" commits.

  25. val offsetsTopicNumPartitions : Int

    The number of partitions for the offset commit topic (should not change after deployment).

  26. val offsetsTopicReplicationFactor : Short

    The replication factor for the offset commit topic (set higher to ensure availability).

  27. val offsetsTopicSegmentBytes : Int

    The offsets topic segment bytes should be kept relatively small to facilitate faster log compaction and faster offset loads

  28. def productArity : Int

    Definition Classes
    OffsetManagerConfig → Product
  29. def productElement (arg0: Int): Any

    Definition Classes
    OffsetManagerConfig → Product
  30. def productIterator : Iterator[Any]

    Definition Classes
    Product
  31. def productPrefix : String

    Definition Classes
    OffsetManagerConfig → Product
  32. def synchronized [T0] (arg0: ⇒ T0): T0

    Attributes
    final
    Definition Classes
    AnyRef
  33. def toString (): String

    Definition Classes
    OffsetManagerConfig → AnyRef → Any
  34. def wait (): Unit

    Attributes
    final
    Definition Classes
    AnyRef
    Annotations
    @throws()
  35. def wait (arg0: Long, arg1: Int): Unit

    Attributes
    final
    Definition Classes
    AnyRef
    Annotations
    @throws()
  36. def wait (arg0: Long): Unit

    Attributes
    final
    Definition Classes
    AnyRef
    Annotations
    @throws()

Deprecated Value Members

  1. def productElements : Iterator[Any]

    Definition Classes
    Product
    Annotations
    @deprecated
    Deprecated

    use productIterator instead

Inherited from Serializable

Inherited from Serializable

Inherited from Product

Inherited from Equals

Inherited from AnyRef

Inherited from Any