o

org.apache.pekko.kafka

ConsumerMessage

object ConsumerMessage

Classes that are used in both javadsl.Consumer and scaladsl.Consumer.

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

Type Members

  1. trait Committable extends AnyRef

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

    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()
  2. final case class CommittableMessage[K, V](record: ConsumerRecord[K, V], committableOffset: CommittableOffset) extends Product with Serializable

    Output element of committableSource.

    Output element of committableSource. The offset can be committed via the included CommittableOffset.

  3. sealed trait CommittableOffset extends Committable

    Included in CommittableMessage.

    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()
  4. trait CommittableOffsetBatch extends Committable

    For improved efficiency it is good to aggregate several CommittableOffset, using this class, before committing them.

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

    Annotations
    @DoNotInherit()
  5. trait CommittableOffsetMetadata extends CommittableOffset
    Annotations
    @DoNotInherit()
  6. final case class GroupTopicPartition(groupId: String, topic: String, partition: Int) extends Product with Serializable

    groupId, topic, partition key for an offset position.

  7. sealed class PartitionOffset extends Product2[GroupTopicPartition, Long] with Serializable

    Offset position for a groupId, topic, partition.

  8. final case class PartitionOffsetMetadata(key: GroupTopicPartition, offset: Long, metadata: String) extends Product with Serializable

    Offset position and metadata for a groupId, topic, partition.

  9. final case class TransactionalMessage[K, V](record: ConsumerRecord[K, V], partitionOffset: PartitionOffset) extends Product with Serializable

    Output element of transactionalSource.

    Output element of transactionalSource. The offset is automatically committed as by the Producer

Value Members

  1. final def !=(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  2. final def ##: Int
    Definition Classes
    AnyRef → Any
  3. final def ==(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  4. final def asInstanceOf[T0]: T0
    Definition Classes
    Any
  5. def clone(): AnyRef
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.CloneNotSupportedException]) @native()
  6. def createCommittableOffsetBatch[T <: Committable](offsets: List[T]): CommittableOffsetBatch

    Java API: Create an offset batch out of a list of offsets.

  7. def createCommittableOffsetBatch(first: CommittableOffset): CommittableOffsetBatch

    Java API: Create an offset batch out of a first offsets.

  8. val emptyCommittableOffsetBatch: CommittableOffsetBatch
  9. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  10. def equals(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef → Any
  11. def finalize(): Unit
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.Throwable])
  12. final def getClass(): Class[_ <: AnyRef]
    Definition Classes
    AnyRef → Any
    Annotations
    @native()
  13. def hashCode(): Int
    Definition Classes
    AnyRef → Any
    Annotations
    @native()
  14. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  15. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  16. final def notify(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  17. final def notifyAll(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  18. final def synchronized[T0](arg0: => T0): T0
    Definition Classes
    AnyRef
  19. def toString(): String
    Definition Classes
    AnyRef → Any
  20. final def wait(): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])
  21. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])
  22. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException]) @native()
  23. object CommittableOffsetBatch
  24. object PartitionOffset extends AbstractFunction2[GroupTopicPartition, Long, PartitionOffset] with Serializable

Inherited from AnyRef

Inherited from Any

Ungrouped