Packages

t

akka.kafka.ConsumerMessage

CommittableOffset

sealed trait CommittableOffset extends Committable

Included in CommittableMessage. Makes it possible to commit an offset with the Committable#commitScaladsl / Committable#commitJavadsl method or aggregate several offsets in a batch before committing.

Note that the offset position that is committed to Kafka will automatically be one more than the offset of the message, because the committed offset should be the next message your application will consume, i.e. lastProcessedMessageOffset + 1.

Annotations
@DoNotInherit()
Source
ConsumerMessage.scala
Linear Supertypes
Committable, AnyRef, Any
Known Subclasses
CommittableOffsetMetadata
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. CommittableOffset
  2. Committable
  3. AnyRef
  4. 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

    Get a number of processed messages this committable contains

    Definition Classes
    Committable
  2. abstract def partitionOffset: PartitionOffset
  3. abstract def commitJavadsl(): CompletionStage[Done]

    Definition Classes
    Committable
    Annotations
    @Deprecated @deprecated
    Deprecated

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

  4. abstract def commitScaladsl(): Future[Done]
    Definition Classes
    Committable
    Annotations
    @deprecated
    Deprecated

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