Capture
yaml
type: "io.kestra.plugin.debezium.mongodb.Capture"
Replica set connection
yaml
id: "capture"
type: "io.kestra.plugin.debezium.mongodb.Capture"
snapshotMode: INITIAL
connectionString: mongodb://mongo_user:[email protected]:27017/?replicaSet=rs0
maxRecords: 100
Sharded connection
yaml
id: "capture"
type: "io.kestra.plugin.debezium.mongodb.Capture"
snapshotMode: INITIAL
connectionString: mongodb://mongo_user:[email protected]:27017,mongos1.example.com:27017/
maxRecords: 100
Replica set SRV connection
yaml
id: "capture"
type: "io.kestra.plugin.debezium.mongodb.Capture"
snapshotMode: INITIAL
connectionString: mongodb+srv://mongo_user:[email protected]/?replicaSet=rs0
maxRecords: 100
Sharded SRV connection
yaml
id: "capture"
type: "io.kestra.plugin.debezium.mongodb.Capture"
snapshotMode: INITIAL
connectionString: mongodb+srv://mongo_user:[email protected]/
maxRecords: 100
Default
deleted
Default
ADD_FIELD
Possible Values
ADD_FIELD
DROP
Default
ADD_FIELD
Possible Values
ADD_FIELD
DROP
Default
TABLE
Possible Values
OFF
DATABASE
TABLE
Default
ADD_FIELD
Possible Values
ADD_FIELD
NULL
DROP
Default
INLINE
Possible Values
RAW
INLINE
WRAP
Default
true
Format
duration
Default
PT1H
Format
duration
Default
PT10S
Format
duration
Default
metadata
SubType string
Default
INITIAL
Possible Values
INITIAL
INITIAL_ONLY
NO_DATA
WHEN_NEEDED
Default
debezium-state
SubType string