Capture

type: "io.kestra.plugin.debezium.mysql.Capture"

Examples

id: "capture"
type: "io.kestra.plugin.debezium.mysql.Capture"
snapshotMode: NEVER
hostname: 127.0.0.1
port: "3306"
username: mysql_user
password: mysql_passwd
maxRecords: 100

Properties

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

serverId

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

snapshotMode

• Type: string
• Dynamic: ❌
• Required: ✔️
• Default: INITIAL
• Possible Values:
  • INITIAL
  • INITIAL_ONLY
  • WHEN_NEEDED
  • NEVER
  • SCHEMA_ONLY
  • SCHEMA_ONLY_RECOVERY

splitTable

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

stateName

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

excludedColumns

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

excludedDatabases

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

excludedTables

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