RealtimeTrigger
yaml
type: "io.kestra.plugin.debezium.oracle.RealtimeTrigger"Consume a message from a Oracle database via change data capture in real-time.
yaml
id: debezium-oracle
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.oracle.RealtimeTrigger
hostname: 127.0.0.1
port: 1521
username: c##dbzuser
password: dbz
sid: ORCLCDB
Dynamic
YES Default
deleted Dynamic
YES Dynamic
YES Default
ADD_FIELD Possible Values
ADD_FIELDDROP Dynamic
YES Default
ADD_FIELD Possible Values
ADD_FIELDDROP Dynamic
YES Dynamic
YES Default
INITIAL Possible Values
ALWAYSINITIALINITIAL_ONLYWHEN_NEEDEDNO_DATARECOVERY Dynamic
YES Default
debezium-state Dynamic
YES Default
ADD_FIELD Possible Values
ADD_FIELDNULLDROP Dynamic
YES Dynamic
YES Dynamic
YES Dynamic
YES Default
INLINE Possible Values
RAWINLINEWRAP Dynamic
YES Default
true Dynamic
YES Dynamic
YES Dynamic
YES Dynamic
YES Default
metadata Dynamic
YES Default
ON_EACH_BATCH Possible Values
ON_EACH_BATCHON_STOP Dynamic
YES Dynamic
YES SubType string
Dynamic
YES Dynamic
YES Dynamic
YES Default
TABLE Possible Values
OFFDATABASETABLE SubType string
Dynamic
NO Possible Values
CREATEDRUNNINGPAUSEDRESTARTEDKILLINGSUCCESSWARNINGFAILEDKILLEDCANCELLEDQUEUEDRETRYINGRETRIEDSKIPPEDList of execution states after which a trigger should be stopped (a.k.a. disabled).
Dynamic
YES