Capture 
Capture
yaml
type: "io.kestra.plugin.debezium.postgres.Capture"Examples
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
database *Requiredstring
hostname *Requiredstring
port *Requiredstring
deleted string
Default
ADD_FIELDPossible Values
ADD_FIELDNULLDROPdeletedFieldName string
Default
deletedexcludedColumns object
excludedDatabases object
excludedTables object
format string
Default
INLINEPossible Values
RAWINLINEWRAPignoreDdl booleanstring
Default
trueincludedColumns object
includedDatabases object
includedTables object
key string
Default
ADD_FIELDPossible Values
ADD_FIELDDROPmaxDuration string
Format
durationmaxRecords integerstring
maxSnapshotDuration string
Default
PT1HFormat
durationmaxWait string
Default
PT10SFormat
durationmetadata string
Default
ADD_FIELDPossible Values
ADD_FIELDDROPmetadataFieldName string
Default
metadataoffsetsCommitMode string
Default
ON_STOPPossible Values
ON_EACH_BATCHON_STOPpassword string
pluginName string
Default
PGOUTPUTPossible Values
DECODERBUFSWAL2JSONWAL2JSON_RDSWAL2JSON_STREAMINGWAL2JSON_RDS_STREAMINGPGOUTPUTproperties object
SubTypestring
publicationName string
Default
kestra_publicationslotName string
Default
kestrasnapshotMode string
Default
INITIALPossible Values
INITIALALWAYSNEVERINITIAL_ONLYsplitTable string
Default
TABLEPossible Values
OFFDATABASETABLEsslCert string
sslKey string
sslKeyPassword string
sslMode string
Default
DISABLEPossible Values
DISABLEREQUIREVERIFY_CAVERIFY_FULLsslRootCert string
stateName string
Default
debezium-stateusername string
Outputs
size integer
stateHistoryKey string
stateOffsetKey string
uris object
SubTypestring
