Trigger
yaml
type: "io.kestra.plugin.debezium.mysql.Trigger"
Examples
yaml
id: "trigger"
type: "io.kestra.plugin.debezium.mysql.Trigger"
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: ✔️
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
conditions
- Type: array
- SubType: Condition
- Dynamic: ❌
- Required: ❌
List of conditions in order to limit the flow trigger.
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: ❌
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.
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: ❌
serverId
- Type: 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
size
- Type: integer
- Required: ❌
stateHistoryKey
- Type: string
- Required: ❌
stateOffsetKey
- Type: string
- Required: ❌
uris
- Type: object
- SubType: string
- Required: ❌
Was this page helpful?