Capture
yaml
type: "io.kestra.plugin.debezium.mysql.capture"Examples
yaml
id: mysql_capture
namespace: company.team
tasks:
- id: capture
type: io.kestra.plugin.debezium.mysql.Capture
snapshotMode: NEVER
hostname: 127.0.0.1
port: "3306"
username: "{{ secret('MYSQL_USERNAME') }}"
password: "{{ secret('MYSQL_PASSWORD') }}"
maxRecords: 100
Properties
hostname *Requiredstring
port *Requiredstring
serverId *Requiredstring
deleted string
Default
ADD_FIELD Possible Values
ADD_FIELDNULLDROPdeletedFieldName string
Default
deletedexcludedColumns object
excludedDatabases object
excludedTables object
format string
Default
INLINE Possible Values
RAWINLINEWRAPignoreDdl booleanstring
Default
trueincludedColumns object
includedDatabases object
includedTables object
key string
Default
ADD_FIELD Possible Values
ADD_FIELDDROPmaxDuration string
Format
durationmaxRecords integerstring
maxSnapshotDuration string
Default
PT1H Format
durationmaxWait string
Default
PT10S Format
durationmetadata string
Default
ADD_FIELD Possible Values
ADD_FIELDDROPmetadataFieldName string
Default
metadatapassword string
properties object
SubType string
snapshotMode string
Default
INITIAL Possible Values
INITIALINITIAL_ONLYWHEN_NEEDEDNEVERSCHEMA_ONLYSCHEMA_ONLY_RECOVERYsplitTable string
Default
TABLE Possible Values
OFFDATABASETABLEstateName string
Default
debezium-stateusername string
Outputs
size integer
stateHistoryKey string
stateOffsetKey string
uris object
SubType string