Trigger
yaml
type: "io.kestra.plugin.debezium.mongodb.Trigger"Sharded connection
yaml
id: debezium-mongodb
namespace: company.team
tasks:
- id: send_data
type: io.kestra.plugin.core.log.Log
message: "{{ trigger.data }}"
triggers:
- id: trigger
type: io.kestra.plugin.debezium.mongodb.Trigger
snapshotMode: INITIAL
connectionString: mongodb://mongo_user:[email protected]:27017,mongos1.example.com:27017/
Replica set connection
yaml
id: debezium-mongodb
namespace: company.team
tasks:
- id: send_data
type: io.kestra.plugin.core.log.Log
message: "{{ trigger.data }}"
triggers:
- id: trigger
type: io.kestra.plugin.debezium.mongodb.Trigger
snapshotMode: INITIAL
connectionString: mongodb://mongo_user:[email protected]:27017/?replicaSet=rs0
Default
deleted Default
Default
ADD_FIELD Possible Values
ADD_FIELDDROP Default
metadata Default
INITIAL Possible Values
INITIALINITIAL_ONLYNO_DATAWHEN_NEEDED Default
debezium-state Default
ADD_FIELD Possible Values
ADD_FIELDNULLDROP Default
INLINE Possible Values
RAWINLINEWRAP Default
true Default
60 Format
durationInterval between polling.
The interval between 2 different polls of schedule, this can avoid to overload the remote system with too many calls. For most of the triggers that depend on external systems, a minimal interval must be at least PT30S. See ISO_8601 Durations for more information of available interval values.
Format
duration Default
PT10S Format
duration Default
ADD_FIELD Possible Values
ADD_FIELDDROP Default
SubType string
Default
TABLE Possible Values
OFFDATABASETABLE SubType string
Possible Values
CREATEDRUNNINGPAUSEDRESTARTEDKILLINGSUCCESSWARNINGFAILEDKILLEDCANCELLEDQUEUEDRETRYINGRETRIEDSKIPPEDList of execution states after which a trigger should be stopped (a.k.a. disabled).
SubType string