Debezium Oracle
Certified
Tasks that capture Oracle database change events through Debezium for Kestra flows.

Capture, Trigger, and RealtimeTrigger run the Debezium Oracle connector to stream redo log changes into Kestra. Supply hostname/port, credentials, the database `sid` (and optional `pluggableDatabase` for CDB setups), pick snapshotMode, and apply include/exclude filters; use Trigger to batch records by maxRecords/durations or RealtimeTrigger for per-row executions.

tasks

Capture

Wait for a change data capture event on Oracle server and capture the event as an internal storage file

io.kestra.plugin.debezium.oracle.Capture

triggers

RealtimeTrigger

Trigger a flow via an Oracle change data capture event in real-time and create one execution per row

io.kestra.plugin.debezium.oracle.RealtimeTrigger

Trigger

Trigger a flow via an Oracle change data capture event periodically and create one execution per row

io.kestra.plugin.debezium.oracle.Trigger

How to use the Debezium Oracle plugin

Stream change data capture (CDC) events from Oracle using Debezium and write them to Kestra's internal storage.

Tasks

Capture: run a one-off capture that collects CDC events until a record count, duration, or wait limit is reached, then writes them to internal storage.
Trigger: poll for CDC events on a schedule and start a flow when new events arrive.
RealtimeTrigger: stream CDC events continuously and start one execution per event.

Connection

Provide the Oracle connection details (hostname, port, username, password, database) via Kestra secrets for credentials. Oracle requires LogMiner or XStream access configured for CDC.

Notes

Debezium tracks progress with an offset and database history stored under a state name, so a restarted task resumes from the last committed position rather than re-reading the whole log from the start.