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
- All
Type Members
-
trait
Committable extends AnyRef
Commit an offset that is included in a CommittableMessage.
Commit an offset that is included in a CommittableMessage. If you need to store offsets in anything other than Kafka, this API should not be used.
This interface might move into
akka.stream
- 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. -
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.
-
final
case class
PartitionOffset(key: GroupTopicPartition, offset: Long) extends Product 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[java.lang]
- Definition Classes
- AnyRef
- Annotations
- @native() @throws( ... )
-
def
createCommittableOffsetBatch(offsets: List[CommittableOffset]): 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: Any): Boolean
- Definition Classes
- AnyRef → Any
-
def
finalize(): Unit
- Attributes
- protected[java.lang]
- Definition Classes
- AnyRef
- Annotations
- @throws( classOf[java.lang.Throwable] )
-
final
def
getClass(): Class[_]
- 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( ... )
-
final
def
wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
final
def
wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @native() @throws( ... )
- object CommittableOffsetBatch