Debezium MySQL
CertifiedTasks that ingest MySQL change data capture streams in Kestra using Debezium.
Capture, Trigger, and RealtimeTrigger rely on the Debezium MySQL connector to write CDC records to Kestra storage and start flows. Configure hostname/port, credentials, a unique serverId, snapshotMode, and any include/exclude filters; use Trigger to batch events with maxRecords/duration controls or RealtimeTrigger for one execution per row.
Debezium MySQL
Tasks that ingest MySQL change data capture streams in Kestra using Debezium.
Capture, Trigger, and RealtimeTrigger rely on the Debezium MySQL connector to write CDC records to Kestra storage and start flows. Configure hostname/port, credentials, a unique serverId, snapshotMode, and any include/exclude filters; use Trigger to batch events with maxRecords/duration controls or RealtimeTrigger for one execution per row.
triggers
How to use the Debezium MySQL plugin
Stream change data capture (CDC) events from MySQL 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 MySQL connection details (hostname, port, username, password, database) via Kestra secrets for credentials. MySQL requires binary logging (binlog) enabled in ROW format.
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.
