CaptureCapture
CaptureCertified
yaml
type: "io.kestra.plugin.debezium.postgres.Capture"
yaml
id: pg_capture
 namespace: company.team

 tasks:
   - id: capture_data
     type: io.kestra.plugin.debezium.postgres.Capture
     hostname: 127.0.0.1
     port: "5432"
     username: "{{ secret('PG_USERNAME') }}"
     password: "{{ secret('PG_PASSWORD') }}"
     maxRecords: 100
     database: my_database
     pluginName: PGOUTPUT
     snapshotMode: ALWAYS
Properties
DefaultADD_FIELD
Possible Values
ADD_FIELDNULLDROP
Defaultdeleted
DefaultINLINE
Possible Values
RAWINLINEWRAP
Defaulttrue
DefaultADD_FIELD
Possible Values
ADD_FIELDDROP
Formatduration
DefaultPT1H
Formatduration
DefaultPT10S
Formatduration
DefaultADD_FIELD
Possible Values
ADD_FIELDDROP
Defaultmetadata
DefaultON_STOP
Possible Values
ON_EACH_BATCHON_STOP
DefaultPGOUTPUT
Possible Values
DECODERBUFSWAL2JSONWAL2JSON_RDSWAL2JSON_STREAMINGWAL2JSON_RDS_STREAMINGPGOUTPUT
SubTypestring
Defaultkestra_publication
Defaultkestra
DefaultINITIAL
Possible Values
INITIALALWAYSNEVERINITIAL_ONLY
DefaultTABLE
Possible Values
OFFDATABASETABLE
DefaultDISABLE
Possible Values
DISABLEREQUIREVERIFY_CAVERIFY_FULL
Defaultdebezium-state
SubTypestring

More Plugins in this Category

Core Plugins and tasks
Core Plugins and tasks

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

CoreStorageScript

126 Tasks

189 Blueprints

PostgreSQL
PostgreSQL

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

Database

6 Tasks

8 Blueprints

SurrealDB
SurrealDB

Tasks that run SurrealQL queries against SurrealDB.

Database

2 Tasks

2 Blueprints
OVERVIEW

Created by

Kestra Core Team

Managed by

Kestra Core Team
Plugin Type
Database
Links & Resources
GitHub