kafka.server

OffsetManagerConfig

case class OffsetManagerConfig(maxMetadataSize: Int = ..., loadBufferSize: Int = ..., offsetsRetentionMs: Long = 24.*(60).*(60000L), 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. OffsetManagerConfig
  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 OffsetManagerConfig(maxMetadataSize: Int = ..., loadBufferSize: Int = ..., offsetsRetentionMs: Long = 24.*(60).*(60000L), 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. 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. def clone(): AnyRef

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

    Definition Classes
    AnyRef
  9. def finalize(): Unit

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

    Definition Classes
    AnyRef → Any
  11. final def isInstanceOf[T0]: Boolean

    Definition Classes
    Any
  12. val loadBufferSize: Int

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

  13. val maxMetadataSize: Int

    The maximum allowed metadata for any offset commit.

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

    Definition Classes
    AnyRef
  15. final def notify(): Unit

    Definition Classes
    AnyRef
  16. final def notifyAll(): Unit

    Definition Classes
    AnyRef
  17. 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.

  18. 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.)

  19. val offsetsRetentionCheckIntervalMs: Long

    Frequency at which to check for stale offsets.

  20. val offsetsRetentionMs: Long

    Offsets older than this retention period will be discarded.

  21. val offsetsTopicCompressionCodec: CompressionCodec

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

  22. val offsetsTopicNumPartitions: Int

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

  23. val offsetsTopicReplicationFactor: Short

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

  24. val offsetsTopicSegmentBytes: Int

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

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

    Definition Classes
    AnyRef
  26. final def wait(): Unit

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

    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  28. 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