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

Package-level declarations

Types

Link copied to clipboard
data class CommittableOffset<R>(val numberOfRecords: Int, markProcessed: suspend (R) -> Unit, markBatchFinished: suspend () -> Unit)
Link copied to clipboard
data class CommittableRecord<R>(val record: R, committer: CommittableOffset<R>)