object ConsumerMessage
Classes that are used in both javadsl.Consumer and scaladsl.Consumer.
- Source
- ConsumerMessage.scala
- Alphabetic
- By Inheritance
- ConsumerMessage
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
Type Members
- 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()
- 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. - 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()
- 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()
- trait CommittableOffsetMetadata extends CommittableOffset
- Annotations
- @DoNotInherit()
- final case class GroupTopicPartition(groupId: String, topic: String, partition: Int) extends Product with Serializable
groupId, topic, partition key for an offset position.
- sealed class PartitionOffset extends Product2[GroupTopicPartition, Long] with Serializable
Offset position for a groupId, topic, partition.
- final case class PartitionOffsetMetadata(key: GroupTopicPartition, offset: Long, metadata: String) extends Product with Serializable
Offset position and metadata for a groupId, topic, partition.
- 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
- final def !=(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- final def ##: Int
- Definition Classes
- AnyRef → Any
- final def ==(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- final def asInstanceOf[T0]: T0
- Definition Classes
- Any
- def clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.CloneNotSupportedException]) @native()
- def createCommittableOffsetBatch[T <: Committable](offsets: List[T]): CommittableOffsetBatch
Java API: Create an offset batch out of a list of offsets.
- def createCommittableOffsetBatch(first: CommittableOffset): CommittableOffsetBatch
Java API: Create an offset batch out of a first offsets.
- val emptyCommittableOffsetBatch: CommittableOffsetBatch
- final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def equals(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef → Any
- def finalize(): Unit
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.Throwable])
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
- def hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- final def ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- final def notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
- final def notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- def toString(): String
- Definition Classes
- AnyRef → Any
- final def wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- final def wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- final def wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException]) @native()
- object CommittableOffsetBatch
- object PartitionOffset extends AbstractFunction2[GroupTopicPartition, Long, PartitionOffset] with Serializable