connector-red-hat-debezium/com.river.connector.red.hat.debezium.model/CommittableOffset

CommittableOffset

data class CommittableOffset<R>(val numberOfRecords: Int, markProcessed: suspend (R) -> Unit, markBatchFinished: suspend () -> Unit)

Constructors

Link copied to clipboard
constructor(numberOfRecords: Int, markProcessed: suspend (R) -> Unit, markBatchFinished: suspend () -> Unit)

Properties

Link copied to clipboard

Functions

Link copied to clipboard
suspend fun markProcessed(record: R)