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
Dynamic
YES Dynamic
YES Default
deleted Dynamic
YES Default
Dynamic
YES Default
ADD_FIELD Possible Values
ADD_FIELDDROP Dynamic
YES Default
metadata Dynamic
YES Default
INITIAL Possible Values
INITIALINITIAL_ONLYNO_DATAWHEN_NEEDED Dynamic
YES Default
debezium-state Dynamic
YES Default
ADD_FIELD Possible Values
ADD_FIELDNULLDROP Dynamic
YES Dynamic
YES Dynamic
YES Dynamic
YES Dynamic
YES Default
INLINE Possible Values
RAWINLINEWRAP Dynamic
YES Default
true Dynamic
YES Dynamic
YES Dynamic
YES Dynamic
YES Dynamic
NO 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.
Dynamic
YES Format
duration Dynamic
YES Dynamic
YES Default
PT10S Format
duration Dynamic
YES Default
ADD_FIELD Possible Values
ADD_FIELDDROP Dynamic
YES Dynamic
YES Default
SubType string
Dynamic
YES Dynamic
YES Default
TABLE Possible Values
OFFDATABASETABLE SubType string
Dynamic
NO Possible Values
CREATEDRUNNINGPAUSEDRESTARTEDKILLINGSUCCESSWARNINGFAILEDKILLEDCANCELLEDQUEUEDRETRYINGRETRIEDSKIPPEDList of execution states after which a trigger should be stopped (a.k.a. disabled).
Dynamic
YES SubType string