PluginsDebezium MongoDBTriggersRealtimeTrigger

RealtimeTrigger​Realtime​Trigger

RealtimeTrigger RealtimeTrigger

yaml
type: "io.kestra.plugin.debezium.mongodb.RealtimeTrigger"

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: 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

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: ✔️

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: ✔️

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: ❌

offsetsCommitMode

  • Type: string
  • Dynamic: ❌
  • Required: ❌
  • Default: ON_EACH_BATCH
  • Possible Values:
    • ON_EACH_BATCH
    • ON_STOP

password

  • Type: string
  • Dynamic: ✔️
  • Required: ❌

properties

  • Type: object
  • SubType: string
  • Dynamic: ✔️
  • Required: ❌

stopAfter

  • Type: array
  • SubType: string
  • Dynamic: ❌
  • Required: ❌

List of execution states after which a trigger should be stopped (a.k.a. disabled).

username

  • Type: string
  • Dynamic: ✔️
  • Required: ❌

Outputs

data

  • Type: object
  • Required: ❌

stream

  • Type: string
  • Required: ❌

Was this page helpful?