| Name | Type | Description | Default Value | Required |
|---|---|---|---|---|
| Configuration | String | The name of the configuration to use | x | |
| Table | String | The name of the table to select from | x | |
| Watermark Column | String | The name of the column to use for a watermark. Values taken from this column are used to filter the contents of the next poll, so that only rows with a greater watermark value are processed. | ||
| Id Column | String | The name of the column to consider as the row ID. If provided, this component makes sure that the same row is not processed twice by concurrent polls. | ||
| Transactional Action | Enumeration, one of: ALWAYS_BEGIN NONE |
The type of beginning action that sources can take regarding transactions | NONE |
|
| Transaction Type | Enumeration, one of: LOCAL XA |
The type of transaction to create. Availability depends on the runtime version. | LOCAL |
|
| Primary Node Only | Boolean | Whether this source should be executed only on the primary node when running in a cluster | ||
| Scheduling Strategy | scheduling-strategy | Configures the scheduler that triggers the polling | x | |
| Redelivery Policy | Redelivery Policy | Defines a policy for processing the redelivery of the same message | ||
| Query Timeout | Number | Indicates the minimum amount of time before the JDBC driver attempts to cancel a running statement. By default, no timeout is used. | 0 |
|
| Query Timeout Unit | Enumeration, one of: NANOSECONDS MICROSECONDS MILLISECONDS SECONDS MINUTES HOURS DAYS |
A time unit that qualifies the #queryTimeout. Values specified in nanoseconds, microseconds, or milliseconds are rounded to seconds. |
SECONDS |
|
| Fetch Size | Number | Indicates how many rows to fetch from the database when rows are read from a ResultSet. | 10 | |
| Max Rows | Number | Sets the limit for the maximum number of rows that any ResultSet object generated by this message processor can contain for the given number. If the limit is exceeded, the excess rows are silently dropped. | ||
| Reconnection Strategy | Reconnect Reconnect Forever |
A retry strategy in case of connectivity errors. |