Packages

c

akka.kafka.ConsumerMessage

CommittableMessage

final case class CommittableMessage[K, V](record: ConsumerRecord[K, V], committableOffset: CommittableOffset) extends Product with Serializable

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

Source
ConsumerMessage.scala
Linear Supertypes
Serializable, Product, Equals, AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. CommittableMessage
  2. Serializable
  3. Product
  4. Equals
  5. AnyRef
  6. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Instance Constructors

  1. new CommittableMessage(record: ConsumerRecord[K, V], committableOffset: CommittableOffset)

Value Members

  1. val committableOffset: CommittableOffset
  2. def productElementNames: Iterator[String]
    Definition Classes
    Product
  3. val record: ConsumerRecord[K, V]