sealed abstract class CommittableConsumerRecord[F[_], +K, +V] extends AnyRef
CommittableConsumerRecord is a Kafka record along with an instance of CommittableOffset,
which can be used commit the record offset to Kafka. Offsets are normally committed in batches,
either using CommittableOffsetBatch or via pipes, like commitBatchWithin. If you are not
committing offsets to Kafka then you can use record to get the underlying record and also
discard the offset.
While normally not necessary, CommittableConsumerRecord#apply can be used to create a new instance.
- Alphabetic
- By Inheritance
- CommittableConsumerRecord
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
Abstract Value Members
- abstract def offset: CommittableOffset[F]
A CommittableOffset instance, providing a way to commit the record offset to Kafka.
A CommittableOffset instance, providing a way to commit the record offset to Kafka. This is normally done in batches as it achieves better performance. Pipes like commitBatchWithin use CommittableOffsetBatch to batch and commit offsets.
- abstract def record: ConsumerRecord[K, V]
The Kafka record for the CommittableConsumerRecord.
The Kafka record for the CommittableConsumerRecord. If you are not committing offsets to Kafka, simply use this to get the ConsumerRecord and discard the offset.
Concrete 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()
- 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()