Packages

trait Committable extends AnyRef

Carries offsets from Kafka for aggregation and committing by the scaladsl.Committer or javadsl.Committer.

Committable may be a single offset in CommittableOffset or CommittableOffsetMetadata, or a number of offsets aggregated as CommittableOffsetBatch.

Annotations
@DoNotInherit()
Source
ConsumerMessage.scala
Linear Supertypes
AnyRef, Any
Known Subclasses
CommittableOffset, CommittableOffsetBatch, CommittableOffsetMetadata
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. Committable
  2. AnyRef
  3. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Abstract Value Members

  1. abstract def batchSize: Long

    Get a number of processed messages this committable contains

  2. abstract def commitJavadsl(): CompletionStage[Done]

    Annotations
    @Deprecated @deprecated
    Deprecated

    (Since version 2.0.0) use Committer.flow or Committer.sink instead of direct usage

  3. abstract def commitScaladsl(): Future[Done]
    Annotations
    @deprecated
    Deprecated

    (Since version 2.0.0) use Committer.flow or Committer.sink instead of direct usage