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 Default
deleted Default
ADD_FIELD Possible Values
ADD_FIELDDROP Default
ADD_FIELD Possible Values
ADD_FIELDDROP Default
PGOUTPUT Possible Values
DECODERBUFSWAL2JSONWAL2JSON_RDSWAL2JSON_STREAMINGWAL2JSON_RDS_STREAMINGPGOUTPUT Default
kestra_publication Default
INITIAL Possible Values
INITIALALWAYSNEVERINITIAL_ONLY Default
debezium-state Default
ADD_FIELD Possible Values
ADD_FIELDNULLDROP Default
INLINE Possible Values
RAWINLINEWRAP Default
true Default
metadata Default
ON_EACH_BATCH Possible Values
ON_EACH_BATCHON_STOP SubType string
Default
kestra Default
TABLE Possible Values
OFFDATABASETABLE Default
DISABLE Possible Values
DISABLEREQUIREVERIFY_CAVERIFY_FULL SubType string
Possible Values
CREATEDRUNNINGPAUSEDRESTARTEDKILLINGSUCCESSWARNINGFAILEDKILLEDCANCELLEDQUEUEDRETRYINGRETRIEDSKIPPEDList of execution states after which a trigger should be stopped (a.k.a. disabled).