Trigger Trigger

yaml
type: "io.kestra.plugin.debezium.db2.Trigger"

Examples

yaml
id: "trigger"
type: "io.kestra.plugin.debezium.db2.Trigger"
snapshotMode: INITIAL
hostname: 127.0.0.1
port: "50000"
username: db2inst1
password: my_password
database: my_database
maxRecords: 100

Properties

database

  • 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:
    • ALWAYS
    • INITIAL
    • INITIAL_ONLY
    • WHEN_NEEDED
    • NO_DATA
    • 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:

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?