object OffsetResetProtectionSettings

The thresholds after which reset protection is enabled. Offsets, time, or both can be provided.

Source
OffsetResetProtectionSettings.scala
Linear Supertypes
AnyRef, Any
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 Disabled: OffsetResetProtectionSettings
  2. def apply(config: Config): OffsetResetProtectionSettings

    Create settings from a configuration with layout connection-checker.

  3. def apply(offsetThreshold: Long, timeThreshold: Duration): OffsetResetProtectionSettings

    Enable offset-reset protection with the given offset and time threshold, where offsets received outside the threshold are considered indicative of an offset reset.

  4. def apply(offsetThreshold: Long, timeThreshold: FiniteDuration): OffsetResetProtectionSettings

    Enable offset-reset protection with the given offset and time threshold, where offsets received outside the threshold are considered indicative of an offset reset.

  5. val configPath: String
  6. def create(config: Config): OffsetResetProtectionSettings

    Java API: Create settings from a configuration with layout offset-reset-protection.