Plugin Debezium Mongodb

Capture ​Capture

yaml
type: "io.kestra.plugin.debezium.mongodb.capture"
yaml
id: mongo_replica_connection
namespace: company.team

tasks:
  - id: capture
    type: io.kestra.plugin.debezium.mongodb.Capture
    snapshotMode: INITIAL
    connectionString: "mongodb://mongo_user:{{secret('MONGO_PASSWORD')}}@mongodb0.example.com:27017/?replicaSet=rs0"
    maxRecords: 100
yaml
id: mongo_sharded_connection
namespace: company.team

tasks:
  - id: capture
    type: io.kestra.plugin.debezium.mongodb.Capture
    snapshotMode: INITIAL
    connectionString: "mongodb://mongo_user:{{secret('MONGO_PASSWORD')}}@mongos0.example.com:27017,mongos1.example.com:27017/"
    maxRecords: 100
yaml
id: mongo_replica_srv
namespace: company.team

tasks:
  - id: capture
    type: io.kestra.plugin.debezium.mongodb.Capture
    snapshotMode: INITIAL
    connectionString: "mongodb+srv://mongo_user:{{secret('MONGO_PASSWORD')}}@mongos0.example.com/?replicaSet=rs0"
    maxRecords: 100
yaml
id: mongo
namespace: company.team

tasks:
  - id: capture
    type: io.kestra.plugin.debezium.mongodb.Capture
    snapshotMode: INITIAL
    connectionString: "mongodb+srv://mongo_user:{{secret('MONGO_PASSWORD')}}@mongos0.example.com/"
    maxRecords: 100
Properties
Default ADD_FIELD
Possible Values
ADD_FIELDNULLDROP
Default deleted
Default INLINE
Possible Values
RAWINLINEWRAP
Default true
Default ADD_FIELD
Possible Values
ADD_FIELDDROP
Format duration
Default PT1H
Format duration
Default PT10S
Format duration
Default ADD_FIELD
Possible Values
ADD_FIELDDROP
Default metadata
SubType string
Default INITIAL
Possible Values
INITIALINITIAL_ONLYNO_DATAWHEN_NEEDED
Default TABLE
Possible Values
OFFDATABASETABLE
Default debezium-state
SubType string