sealed abstract class CommittableOffset[F[_]] extends AnyRef
CommittableOffset represents an offsetAndMetadata for a topicPartition, along with
the ability to commit that offset to Kafka with commit. Note that offsets are normally
committed in batches for performance reasons. Pipes like commitBatchWithin use
CommittableOffsetBatch to commit the offsets in batches.
While normally not necessary, CommittableOffset#apply can be used to create a new instance.
- Source
- CommittableOffset.scala
- Alphabetic
- By Inheritance
- CommittableOffset
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
Abstract Value Members
- abstract def batch: CommittableOffsetBatch[F]
The CommittableOffset as a CommittableOffsetBatch.
- abstract def commit: F[Unit]
Commits the offsetAndMetadata for the topicPartition to Kafka.
Commits the offsetAndMetadata for the topicPartition to Kafka. Note that offsets are normally committed in batches for performance reasons. Prefer pipes like commitBatchWithin or CommittableOffsetBatch for that reason.
- abstract def consumerGroupId: Option[String]
The consumer group ID of the consumer that fetched the offsetAndMetadata from the topicPartition from Kafka.
The consumer group ID of the consumer that fetched the offsetAndMetadata from the topicPartition from Kafka.
Required for committing offsets within a transaction.
- abstract def offsetAndMetadata: OffsetAndMetadata
The offset and metadata for the topicPartition, which can be committed using commit.
- abstract def offsets: Map[TopicPartition, OffsetAndMetadata]
The topicPartition and offsetAndMetadata as a
Map
.The topicPartition and offsetAndMetadata as a
Map
. This is provided for convenience and is always guaranteed to be equivalent to the following.Map(topicPartition -> offsetAndMetadata)
- abstract def topicPartition: TopicPartition
The topic and partition for which offsetAndMetadata can be committed using commit.
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()