Debezium MySQL

Tasks that ingest MySQL change data capture streams in Kestra using Debezium.

Capture, Trigger, and RealtimeTrigger rely on the Debezium MySQL connector to write CDC records to Kestra storage and start flows. Configure hostname/port, credentials, a unique serverId, snapshotMode, and any include/exclude filters; use Trigger to batch events with maxRecords/duration controls or RealtimeTrigger for one execution per row.

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.

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

Interact with Liquibase to run schema diffs, updates, validations, and other database change management tasks.