Capture

yaml
type: "io.kestra.plugin.debezium.db2.Capture"

Examples

yaml
id: db2_capture
namespace: company.team

tasks:
  - id: capture
    type: io.kestra.plugin.debezium.db2.Capture
    snapshotMode: INITIAL
    hostname: 127.0.0.1
    port: "50000"
    username: "{{ secret('DB2_USERNAME') }}"
    password: "{{ secret('DB2_PASSWORD') }}"
    database: my_database
    maxRecords: 100

Properties

database*string

hostname*string

port*string

deletedstring

DefaultADD_FIELD

Possible Values

ADD_FIELDNULLDROP

deletedFieldNamestring

Defaultdeleted

excludedColumnsobject

excludedDatabasesobject

excludedTablesobject

formatstring

DefaultINLINE

Possible Values

RAWINLINEWRAP

ignoreDdlbooleanstring

Defaulttrue

includedColumnsobject

includedDatabasesobject

includedTablesobject

keystring

DefaultADD_FIELD

Possible Values

ADD_FIELDDROP

maxDurationstring

Formatduration

maxRecordsintegerstring

maxSnapshotDurationstring

DefaultPT1H

Formatduration

maxWaitstring

DefaultPT10S

Formatduration

metadatastring

DefaultADD_FIELD

Possible Values

ADD_FIELDDROP

metadataFieldNamestring

Defaultmetadata

offsetsCommitModestring

DefaultON_STOP

Possible Values

ON_EACH_BATCHON_STOP

passwordstring

propertiesobject

SubTypestring

snapshotModestring

DefaultINITIAL

Possible Values

ALWAYSINITIALINITIAL_ONLYWHEN_NEEDEDNO_DATARECOVERY

splitTablestring

DefaultTABLE

Possible Values

OFFDATABASETABLE

stateNamestring

Defaultdebezium-state

usernamestring

Outputs

sizeinteger

stateHistoryKeystring

stateOffsetKeystring

urisobject

SubTypestring

Metrics

recordscounter

Core Plugins and tasks

Tasks that provide Kestra's built-in orchestration, I/O, and observability capabilities.

CoreStorageScript

PostgreSQL

Tasks that connect to PostgreSQL via JDBC to run queries and loads.

Database

SurrealDB

Tasks that run SurrealQL queries against SurrealDB.

Database

Capture

More Plugins in this Category

Core Plugins and tasks

PostgreSQL

SurrealDB