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
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( ... ) @native() @HotSpotIntrinsicCandidate()
-
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: Any): Boolean
- Definition Classes
- AnyRef → Any
-
final
def
getClass(): Class[_]
- Definition Classes
- AnyRef → Any
- Annotations
- @native() @HotSpotIntrinsicCandidate()
-
def
hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @native() @HotSpotIntrinsicCandidate()
-
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() @HotSpotIntrinsicCandidate()
-
final
def
notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native() @HotSpotIntrinsicCandidate()
-
final
def
synchronized[T0](arg0: ⇒ T0): T0
- Definition Classes
- AnyRef
-
def
toString(): String
- Definition Classes
- AnyRef → Any
-
final
def
wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
final
def
wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... ) @native()
-
final
def
wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
- object CommittableOffsetBatch
- object PartitionOffset extends AbstractFunction2[GroupTopicPartition, Long, PartitionOffset] with Serializable