RealtimeTrigger

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

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

yaml
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

Dynamic YES

Default ADD_FIELD

Possible Values

ADD_FIELDNULLDROP

Dynamic YES

Default deleted

Dynamic YES

Default INLINE

Possible Values

RAWINLINEWRAP

Dynamic YES

Default true

Dynamic YES

Default ADD_FIELD

Possible Values

ADD_FIELDDROP

Dynamic YES

Default ADD_FIELD

Possible Values

ADD_FIELDDROP

Dynamic YES

Default metadata

Dynamic YES

Default PGOUTPUT

Possible Values

DECODERBUFSWAL2JSONWAL2JSON_RDSWAL2JSON_STREAMINGWAL2JSON_RDS_STREAMINGPGOUTPUT

Dynamic YES

Default kestra_publication

Dynamic YES

Default kestra

Dynamic YES

Default INITIAL

Possible Values

INITIALALWAYSNEVERINITIAL_ONLY

Dynamic YES

Default TABLE

Possible Values

OFFDATABASETABLE

Dynamic YES

Default debezium-state

SubType

Dynamic NO

List of conditions in order to limit the flow trigger.

Dynamic YES

Default ON_EACH_BATCH

Possible Values

ON_EACH_BATCHON_STOP

Dynamic YES

SubType string

Dynamic YES

Default DISABLE

Possible Values

DISABLEREQUIREVERIFY_CAVERIFY_FULL

Dynamic YES

SubType string

Dynamic NO

Possible Values

CREATEDRUNNINGPAUSEDRESTARTEDKILLINGSUCCESSWARNINGFAILEDKILLEDCANCELLEDQUEUEDRETRYINGRETRIEDSKIPPED

List of execution states after which a trigger should be stopped (a.k.a. disabled).

Dynamic YES

​Realtime​Trigger

RealtimeTrigger