Debezium MongoDB
Certified
Tasks that stream MongoDB change events into Kestra through Debezium connectors.

Includes Capture plus batch and real-time triggers to ingest MongoDB change data into Kestra flows. Provide a replica set or sharded `connectionString` with credentials, choose snapshotMode, and optionally include or exclude collections; use Trigger to poll in batches or RealtimeTrigger to fire one execution per change.

tasks

Capture

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

io.kestra.plugin.debezium.mongodb.Capture

triggers

RealtimeTrigger

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

io.kestra.plugin.debezium.mongodb.RealtimeTrigger

Trigger

Trigger a flow on a change data capture event in MongoDB and create new execution per batch

io.kestra.plugin.debezium.mongodb.Trigger

How to use the Debezium MongoDB plugin

Stream change data capture (CDC) events from MongoDB 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 MongoDB connection details (hostname, port, username, password, database) via Kestra secrets for credentials. MongoDB requires a replica set or sharded cluster with the oplog available.

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.