class OffsetResetProtectionSettings extends AnyRef

Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. OffsetResetProtectionSettings
  2. AnyRef
  3. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Value Members

  1. val enable: Boolean
  2. val offsetThreshold: Long
  3. val timeThreshold: FiniteDuration
  4. def toString(): String
    Definition Classes
    OffsetResetProtectionSettings → AnyRef → Any
  5. def withEnable(enable: Boolean): OffsetResetProtectionSettings

    Whether offset-reset protection should be enabled.

  6. def withOffsetThreshold(offsetThreshold: Long): OffsetResetProtectionSettings

    If consumer gets a record with an offset that is more than this number of offsets back from the previously requested offset, it is considered a reset.

  7. def withTimeThreshold(timeThreshold: Duration): OffsetResetProtectionSettings

    Java API

    Java API

    If the record is more than this duration earlier the last received record, it is considered a reset

  8. def withTimeThreshold(timeThreshold: FiniteDuration): OffsetResetProtectionSettings

    Scala API.

    Scala API.

    If the record is more than this duration earlier the last received record, it is considered a reset