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

Default ADD_FIELD

Possible Values

ADD_FIELDNULLDROP

Dynamic YES

Default deleted

Dynamic YES

Default INLINE

Possible Values

RAWINLINEWRAP

Dynamic YES

Default

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

Default

Dynamic YES

Default INITIAL

Possible Values

INITIALINITIAL_ONLYNO_DATAWHEN_NEEDED

Dynamic YES

Default TABLE

Possible Values

OFFDATABASETABLE

Dynamic YES

Default debezium-state

SubType

Dynamic NO

List of conditions in order to limit the flow trigger.

Dynamic YES

Dynamic NO

Default 60

Format duration

Interval 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

Default PT10S

Format duration

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

SubType string

​Trigger

Trigger