Debezium PostgreSQL
Certified
Tasks that capture PostgreSQL logical replication changes via Debezium for Kestra workflows.

Use Capture plus batch and real-time triggers built on the Debezium PostgreSQL connector to move WAL changes into Kestra. Set database, logical decoding `pluginName`, `publicationName`, and `slotName`, pick snapshotMode, and optionally TLS settings; choose Trigger for batched polling or RealtimeTrigger to emit an execution per change.

tasks

Capture

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

io.kestra.plugin.debezium.postgres.Capture

triggers

RealtimeTrigger

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

io.kestra.plugin.debezium.postgres.RealtimeTrigger

Trigger

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

io.kestra.plugin.debezium.postgres.Trigger

How to use the Debezium PostgreSQL plugin

Stream change data capture (CDC) events from PostgreSQL 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 PostgreSQL connection details (hostname, port, username, password, database) via Kestra secrets for credentials. PostgreSQL requires a logical replication slot and wal_level set to logical.

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.