class CommitterSettings extends AnyRef

Settings for committer. See akka.kafka.committer section in reference.conf. Note that the companion object provides apply and create functions for convenient construction of the settings, together with the with methods.

Source
CommitterSettings.scala
Linear Supertypes
AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. CommitterSettings
  2. AnyRef
  3. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Value Members

  1. val delivery: CommitDelivery
  2. val maxBatch: Long
  3. val maxInterval: FiniteDuration
  4. val parallelism: Int
  5. def toString(): String
    Definition Classes
    CommitterSettings → AnyRef → Any
  6. val when: CommitWhen
  7. def withCommitWhen(value: CommitWhen): CommitterSettings
    Annotations
    @ApiMayChange()
  8. def withDelivery(value: CommitDelivery): CommitterSettings
    Annotations
    @ApiMayChange()
  9. def withMaxBatch(maxBatch: Long): CommitterSettings
  10. def withMaxInterval(maxInterval: Duration): CommitterSettings
  11. def withMaxInterval(maxInterval: FiniteDuration): CommitterSettings
  12. def withParallelism(parallelism: Int): CommitterSettings