Debezium PostgreSQL
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

Use Debezium to trigger a flow whenever new entries hit a Postgres database, then send notification to Slack and process data in Python

Mariadb

Tasks that connect to MariaDB via JDBC to run queries and loads.

Database

Opensearch

Enterprise

This sub-group of plugins contains tasks for using Opensearch EE. Opensearch is a distributed, RESTful search and analytics engine capable of addressing a growing number of use cases.

Database

Microsoft SQL Server

Tasks that connect to SQL Server via JDBC to run queries and loads.

Database

tasks

Capture

triggers

RealtimeTrigger

Trigger

Create automations with Postgres Plugins

Use Debezium to trigger a flow whenever new entries hit a Postgres database, then send notification to Slack and process data in Python

More Plugins in this Category

Mariadb

Opensearch

Microsoft SQL Server