RealtimeTrigger

type: "io.kestra.plugin.debezium.postgres.RealtimeTrigger"

Examples

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

id: debezium-postgres
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.postgres.RealtimeTrigger
    database: postgres
    hostname: 127.0.0.1
    port: 65432
    username: postgres
    password: pg_passwd

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

pluginName

• Type: string
• Dynamic: ❌
• Required: ✔️
• Default: PGOUTPUT
• Possible Values:
  • DECODERBUFS
  • WAL2JSON
  • WAL2JSON_RDS
  • WAL2JSON_STREAMING
  • WAL2JSON_RDS_STREAMING
  • PGOUTPUT

port

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

publicationName

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

slotName

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

snapshotMode

• Type: string
• Dynamic: ❌
• Required: ✔️
• Default: INITIAL
• Possible Values:
  • INITIAL
  • ALWAYS
  • NEVER
  • INITIAL_ONLY

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

sslCert

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

sslKey

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

sslKeyPassword

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

sslMode

• Type: string
• Dynamic: ❌
• Required: ❌
• Default: DISABLE
• Possible Values:
  • DISABLE
  • REQUIRE
  • VERIFY_CA
  • VERIFY_FULL

sslRootCert

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