Debezium DB2Debezium DB2
Debezium DB2Certified

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

More Plugins in this Category

SQLite
SQLite

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

Database

3 Tasks

1 Blueprints

Snowflake
Snowflake

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

Database

6 Tasks

3 Blueprints

Opensearch (EE)
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

1 Tasks

OVERVIEW

Created by

Kestra Core Team

Managed by

Kestra Core Team
Plugin Type
Database
Links & Resources
GitHub