object CommitWhen

Selects when the stream will commit an offset.

Annotations
@ApiMayChange()
Source
CommitterSettings.scala
Linear Supertypes
AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. CommitWhen
  2. AnyRef
  3. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Value Members

  1. val nextOffsetObserved: CommitWhen

    Java API.

  2. val offsetFirstObserved: CommitWhen

    Java API.

  3. def valueOf(s: String): CommitWhen
  4. case object NextOffsetObserved extends CommitWhen with Product with Serializable

    Commit once the next Committable offset is observed

    Commit once the next Committable offset is observed

    Annotations
    @ApiMayChange()
  5. case object OffsetFirstObserved extends CommitWhen with Product with Serializable

    Commit as soon as a Committable offset is observed.

    Commit as soon as a Committable offset is observed.

    Annotations
    @ApiMayChange()