Capture

yaml
type: "io.kestra.plugin.debezium.oracle.capture"

Examples

yaml
id: non_container_db
namespace: company.team

tasks:
  - id: capture
    type: io.kestra.plugin.debezium.oracle.Capture
    snapshotMode: INITIAL
    hostname: 127.0.0.1
    port: "1521"
    username: "{{ secret('ORACLE_USERNAME') }}"
    password: "{{ secret('ORACLE_PASSWORD') }}"
    sid: ORCLCDB
    maxRecords: 100

yaml
id: container_db
namespace: company.team

tasks:
  - id: capture
    type: io.kestra.plugin.debezium.oracle.Capture
    snapshotMode: INITIAL
    hostname: 127.0.0.1
    port: "1521"
    username: "{{ secret('ORACLE_USERNAME') }}"
    password: "{{ secret('ORACLE_PASSWORD') }}"
    sid: ORCLCDB
    pluggableDatabase: ORCLPDB1
    maxRecords: 100

Properties

hostname *string

port *string

sid *string

deleted string

Default ADD_FIELD

Possible Values

ADD_FIELDNULLDROP

deletedFieldName string

Default deleted

excludedColumns object

excludedDatabases object

excludedTables object

format string

Default INLINE

Possible Values

RAWINLINEWRAP

ignoreDdl booleanstring

Default true

includedColumns object

includedDatabases object

includedTables object

key string

Default ADD_FIELD

Possible Values

ADD_FIELDDROP

maxDuration string

Format duration

maxRecords integerstring

maxSnapshotDuration string

Default PT1H

Format duration

maxWait string

Default PT10S

Format duration

metadata string

Default ADD_FIELD

Possible Values

ADD_FIELDDROP

metadataFieldName string

Default metadata

password string

pluggableDatabase string

properties object

SubType string

snapshotMode string

Default INITIAL

Possible Values

ALWAYSINITIALINITIAL_ONLYWHEN_NEEDEDNO_DATARECOVERY

splitTable string

Default TABLE

Possible Values

OFFDATABASETABLE

stateName string

Default debezium-state

username string

Outputs

size integer

stateHistoryKey string

stateOffsetKey string

uris object

SubType string

​Capture

Capture