Trigger

yaml

type: "io.kestra.plugin.debezium.mongodb.Trigger"

Examples

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

Properties

`connectionString`

Type: string
Dynamic: ✔️
Required: ✔️

`deleted`

Type: string
Dynamic: ❌
Required: ✔️
Default: ADD_FIELD
Possible Values:
- ADD_FIELD
- NULL
- DROP

`deletedFieldName`

Type: string
Dynamic: ❌
Required: ✔️
Default: deleted

`format`

Type: string
Dynamic: ❌
Required: ✔️
Default: INLINE
Possible Values:
- RAW
- INLINE
- WRAP

`hostname`

Type: string
Dynamic: ✔️
Required: ✔️
Default: ``

`ignoreDdl`

Type: boolean
Dynamic: ❌
Required: ✔️
Default: true

`key`

Type: string
Dynamic: ❌
Required: ✔️
Default: ADD_FIELD
Possible Values:
- ADD_FIELD
- DROP

`metadata`

Type: string
Dynamic: ❌
Required: ✔️
Default: ADD_FIELD
Possible Values:
- ADD_FIELD
- DROP

`metadataFieldName`

Type: string
Dynamic: ❌
Required: ✔️
Default: metadata

`port`

Type: string
Dynamic: ✔️
Required: ✔️
Default: ``

`snapshotMode`

Type: string
Dynamic: ❌
Required: ✔️
Default: INITIAL
Possible Values:
- INITIAL
- INITIAL_ONLY
- NO_DATA
- WHEN_NEEDED

`splitTable`

Type: string
Dynamic: ❌
Required: ✔️
Default: TABLE
Possible Values:
- OFF
- DATABASE
- TABLE

`stateName`

Type: string
Dynamic: ❌
Required: ✔️
Default: debezium-state

`conditions`

Type: array
SubType: Condition
Dynamic: ❌
Required: ❌

List of conditions in order to limit the flow trigger.

`excludedCollections`

Type: object
Dynamic: ✔️
Required: ❌

`excludedColumns`

Type: object
Dynamic: ✔️
Required: ❌

`excludedDatabases`

Type: object
Dynamic: ✔️
Required: ❌

`excludedTables`

Type: object
Dynamic: ✔️
Required: ❌

`includedCollections`

Type: object
Dynamic: ✔️
Required: ❌

`includedColumns`

Type: object
Dynamic: ✔️
Required: ❌

`includedDatabases`

Type: object
Dynamic: ✔️
Required: ❌

`includedTables`

Type: object
Dynamic: ✔️
Required: ❌

`interval`

Type: string
Dynamic: ❌
Required: ❌
Default: 60.000000000
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.