Debezium DB2
Certified
Tasks that ingest IBM Db2 change data through Debezium connectors in Kestra.

Includes Capture plus batch and real-time triggers that stream Db2 CDC events into Kestra via Debezium. Configure hostname/port, credentials, target `database`, snapshotMode, and include/exclude filters; Trigger polls and batches records up to maxRecords/duration settings while RealtimeTrigger emits an execution per change.

tasks

Capture

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

io.kestra.plugin.debezium.db2.Capture

triggers

RealtimeTrigger

Trigger a flow on real-time message consumption from a DB2 database via change data capture and create one execution per row

io.kestra.plugin.debezium.db2.RealtimeTrigger

Trigger

Trigger a flow on periodic message consumption from a DB2 database via change data capture and create one execution per batch

io.kestra.plugin.debezium.db2.Trigger

How to use the Debezium Db2 plugin

Stream change data capture (CDC) events from Db2 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 Db2 connection details (hostname, port, username, password, database) via Kestra secrets for credentials. Db2 requires change data capture to be enabled on the captured 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.