RealtimeTrigger
yaml
type: "io.kestra.plugin.debezium.mongodb.RealtimeTrigger"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: realtime
type: io.kestra.plugin.debezium.mongodb.RealtimeTrigger
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: realtime
type: io.kestra.plugin.debezium.mongodb.RealtimeTrigger
snapshotMode: INITIAL
connectionString: mongodb://mongo_user:[email protected]:27017/?replicaSet=rs0
Dynamic YES
Dynamic YES
Default ADD_FIELD
Possible Values
ADD_FIELDNULLDROP
Dynamic YES
Default deleted
Dynamic YES
Default INLINE
Possible Values
RAWINLINEWRAP
Dynamic YES
Dynamic YES
Default true
Dynamic YES
Default ADD_FIELD
Possible Values
ADD_FIELDDROP
Dynamic YES
Default ADD_FIELD
Possible Values
ADD_FIELDDROP
Dynamic YES
Default metadata
Dynamic YES
Dynamic YES
Default INITIAL
Possible Values
INITIALINITIAL_ONLYNO_DATAWHEN_NEEDED
Dynamic YES
Default TABLE
Possible Values
OFFDATABASETABLE
Dynamic YES
Default debezium-state
Dynamic YES
Dynamic YES
Dynamic YES
Dynamic YES
Dynamic YES
Dynamic YES
Dynamic YES
Dynamic YES
Dynamic YES
Default ON_EACH_BATCH
Possible Values
ON_EACH_BATCHON_STOP
Dynamic YES
SubType string
Dynamic YES
SubType string
Dynamic NO
Possible Values
CREATEDRUNNINGPAUSEDRESTARTEDKILLINGSUCCESSWARNINGFAILEDKILLEDCANCELLEDQUEUEDRETRYINGRETRIEDSKIPPED
List of execution states after which a trigger should be stopped (a.k.a. disabled).
Dynamic YES