Package-level declarations
Functions
Link copied to clipboard
fun <R> debeziumFlow(maxRecordsInFlight: Int = 250, executor: ExecutorService = Executors.newSingleThreadExecutor(), engineBuilder: () -> DebeziumEngine.Builder<R>): Flow<CommittableRecord<R>>
The debeziumFlow function creates a Kotlin Flow that consumes records from a Debezium engine and emits them as CommittableRecords.