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