CommittableRecord

data class CommittableRecord<R>(val record: R, committer: CommittableOffset<R>)

Constructors

Link copied to clipboard
constructor(record: R, committer: CommittableOffset<R>)

Properties

Link copied to clipboard
val record: R

Functions

Link copied to clipboard
suspend fun markProcessed()