PluginsDebezium MySQLTriggersRealtimeTrigger

RealtimeTrigger​Realtime​Trigger

RealtimeTrigger RealtimeTrigger

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

Examples

Consume a message from a MySQL database via change data capture in real-time.

yaml
id: debezium-mysql
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.mysql.RealtimeTrigger
    serverId: 123456789
    hostname: 127.0.0.1
    port: 63306
    username: mysql_user
    password: mysql_passwd

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

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

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

data

  • Type: object
  • Required: ❌

stream

  • Type: string
  • Required: ❌

Was this page helpful?