PluginsDebezium PostgreSQLTriggersTrigger

Trigger

yaml

type: "io.kestra.plugin.debezium.postgres.Trigger"

Examples

yaml

id: "trigger"
type: "io.kestra.plugin.debezium.postgres.Trigger"
hostname: 127.0.0.1
port: "5432"
username: posgres
password: psql_passwd
maxRecords: 100
database: my_database
pluginName: PGOUTPUT
snapshotMode: ALWAYS

Properties

`database`

Type: string
Dynamic: ✔️
Required: ✔️

`deleted`

Type: string
Dynamic: ❌
Required: ✔️
Default: ADD_FIELD
Possible Values:
- ADD_FIELD
- NULL
- DROP

`deletedFieldName`

Type: string
Dynamic: ❌
Required: ✔️
Default: deleted

`format`

Type: string
Dynamic: ❌
Required: ✔️
Default: INLINE
Possible Values:
- RAW
- INLINE
- WRAP

`hostname`

Type: string
Dynamic: ✔️
Required: ✔️

`ignoreDdl`

Type: boolean
Dynamic: ❌
Required: ✔️
Default: true

`key`

Type: string
Dynamic: ❌
Required: ✔️
Default: ADD_FIELD
Possible Values:
- ADD_FIELD
- DROP

`metadata`

Type: string
Dynamic: ❌
Required: ✔️
Default: ADD_FIELD
Possible Values:
- ADD_FIELD
- DROP

`metadataFieldName`

Type: string
Dynamic: ❌
Required: ✔️
Default: metadata

`pluginName`

Type: string
Dynamic: ❌
Required: ✔️
Default: PGOUTPUT
Possible Values:
- DECODERBUFS
- WAL2JSON
- WAL2JSON_RDS
- WAL2JSON_STREAMING
- WAL2JSON_RDS_STREAMING
- PGOUTPUT

`port`

Type: string
Dynamic: ✔️
Required: ✔️

`publicationName`

Type: string
Dynamic: ✔️
Required: ✔️
Default: kestra_publication

`slotName`

Type: string
Dynamic: ✔️
Required: ✔️
Default: kestra

`snapshotMode`

Type: string
Dynamic: ❌
Required: ✔️
Default: INITIAL
Possible Values:
- INITIAL
- ALWAYS
- NEVER
- INITIAL_ONLY

`splitTable`

Type: string
Dynamic: ❌
Required: ✔️
Default: TABLE
Possible Values:
- OFF
- DATABASE
- TABLE

`stateName`

Type: string
Dynamic: ❌
Required: ✔️
Default: debezium-state

`conditions`

Type: array
SubType: Condition
Dynamic: ❌
Required: ❌

List of conditions in order to limit the flow trigger.

`excludedColumns`

Type: object
Dynamic: ✔️
Required: ❌

`excludedDatabases`

Type: object
Dynamic: ✔️
Required: ❌

`excludedTables`

Type: object
Dynamic: ✔️
Required: ❌

`includedColumns`

Type: object
Dynamic: ✔️
Required: ❌

`includedDatabases`

Type: object
Dynamic: ✔️
Required: ❌

`includedTables`

Type: object
Dynamic: ✔️
Required: ❌

`interval`

Type: string
Dynamic: ❌
Required: ❌
Default: 60.000000000
Format: duration

Interval between polling.

The interval between 2 different polls of schedule, this can avoid to overload the remote system with too many calls. For most of the triggers that depend on external systems, a minimal interval must be at least PT30S. See ISO_8601 Durations for more information of available interval values.