CommittableOffset

constructor(numberOfRecords: Int, markProcessed: suspend (R) -> Unit, markBatchFinished: suspend () -> Unit)