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
Default
deleted
Default
ADD_FIELD
Possible Values
ADD_FIELD
DROP
Default
ADD_FIELD
Possible Values
ADD_FIELD
DROP
Default
INITIAL
Possible Values
ALWAYS
INITIAL
INITIAL_ONLY
WHEN_NEEDED
NO_DATA
RECOVERY
Default
debezium-state
Default
ADD_FIELD
Possible Values
ADD_FIELD
NULL
DROP
Default
INLINE
Possible Values
RAW
INLINE
WRAP
Default
true
Default
metadata
Default
ON_EACH_BATCH
Possible Values
ON_EACH_BATCH
ON_STOP
SubType string
Default
TABLE
Possible Values
OFF
DATABASE
TABLE
SubType string
Possible Values
CREATED
RUNNING
PAUSED
RESTARTED
KILLING
SUCCESS
WARNING
FAILED
KILLED
CANCELLED
QUEUED
RETRYING
RETRIED
SKIPPED
List of execution states after which a trigger should be stopped (a.k.a. disabled).