PluginsDebezium MongoDBTasksCapture

Capture​Capture

Capture Capture

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

Examples

Replica set connection

yaml
id: "capture"
type: "io.kestra.plugin.debezium.mongodb.Capture"
snapshotMode: INITIAL
connectionString: mongodb://mongo_user:[email protected]:27017/?replicaSet=rs0
maxRecords: 100

Sharded connection

yaml
id: "capture"
type: "io.kestra.plugin.debezium.mongodb.Capture"
snapshotMode: INITIAL
connectionString: mongodb://mongo_user:[email protected]:27017,mongos1.example.com:27017/
maxRecords: 100

Replica set SRV connection

yaml
id: "capture"
type: "io.kestra.plugin.debezium.mongodb.Capture"
snapshotMode: INITIAL
connectionString: mongodb+srv://mongo_user:[email protected]/?replicaSet=rs0
maxRecords: 100

Sharded SRV connection

yaml
id: "capture"
type: "io.kestra.plugin.debezium.mongodb.Capture"
snapshotMode: INITIAL
connectionString: mongodb+srv://mongo_user:[email protected]/
maxRecords: 100

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

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

maxDuration

  • Type: string
  • Dynamic: ❌
  • Required: ❌
  • Format: duration

maxRecords

  • Type: integer
  • Dynamic: ❌
  • Required: ❌

maxSnapshotDuration

  • Type: string
  • Dynamic: ❌
  • Required: ❌
  • Default: 3600.000000000
  • Format: duration

maxWait

  • Type: string
  • Dynamic: ❌
  • Required: ❌
  • Default: 10.000000000
  • Format: duration

password

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

properties

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

username

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

Outputs

size

  • Type: integer
  • Required: ❌

stateHistoryKey

  • Type: string
  • Required: ❌

stateOffsetKey

  • Type: string
  • Required: ❌

uris

  • Type: object
  • SubType: string
  • Required: ❌

Was this page helpful?