Debezium Microsoft SQL Server
Certified
Tasks that stream Microsoft SQL Server change data capture events into Kestra with Debezium.

Capture plus batch and real-time triggers use the Debezium SQL Server connector to feed CDC rows into Kestra. Provide hostname/port, credentials, target `database`, snapshotMode, and include/exclude filters; Trigger batches results with maxRecords/duration controls, while RealtimeTrigger fires one execution per change.

tasks

Capture

Wait for change data capture event on Microsoft SQL Server and capture the event as an internal storage file

io.kestra.plugin.debezium.sqlserver.Capture

triggers

RealtimeTrigger

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

io.kestra.plugin.debezium.sqlserver.RealtimeTrigger

Trigger

Trigger a flow via a SQL Server change data capture event periodically and create one execution per row

io.kestra.plugin.debezium.sqlserver.Trigger

How to use the Debezium Microsoft SQL Server plugin

Stream change data capture (CDC) events from Microsoft SQL Server 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 Microsoft SQL Server connection details (hostname, port, username, password, database) via Kestra secrets for credentials. SQL Server requires change data capture enabled on the database and tables.

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.