Packages

trait CommittableOffsetBatch extends Committable

For improved efficiency it is good to aggregate several CommittableOffset, using this class, before committing them. Start with the empty batch.

Annotations
@DoNotInherit()
Source
ConsumerMessage.scala
Linear Supertypes
Committable, AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. CommittableOffsetBatch
  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 getOffsets: Map[GroupTopicPartition, Long]

    Java API: Get current offset positions

  3. abstract def isEmpty: Boolean

    returns

    true if the batch contains no commits.

  4. abstract def offsets: Map[GroupTopicPartition, Long]

    Scala API: Get current offset positions

  5. abstract def updated(offset: Committable): CommittableOffsetBatch

    Add/overwrite an offset position from another committable.

  6. 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

  7. 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