You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by da...@apache.org on 2022/04/28 09:55:02 UTC
[camel] branch main updated: Regen for commit 17d6d56d71f33b9f1d291bf7c52a60ad705d73db (#7515)
This is an automated email from the ASF dual-hosted git repository.
davsclaus pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel.git
The following commit(s) were added to refs/heads/main by this push:
new 2788af34195 Regen for commit 17d6d56d71f33b9f1d291bf7c52a60ad705d73db (#7515)
2788af34195 is described below
commit 2788af341950e479848f92242a4ab9eb92423dda
Author: github-actions[bot] <41...@users.noreply.github.com>
AuthorDate: Thu Apr 28 11:54:55 2022 +0200
Regen for commit 17d6d56d71f33b9f1d291bf7c52a60ad705d73db (#7515)
Signed-off-by: GitHub <no...@github.com>
Co-authored-by: essobedo <es...@users.noreply.github.com>
---
.../camel/catalog/components/debezium-db2.json | 52 +-
.../camel/catalog/components/debezium-mongodb.json | 10 +-
.../camel/catalog/components/debezium-mysql.json | 24 +-
.../camel/catalog/components/debezium-oracle.json | 8 +-
.../catalog/components/debezium-postgres.json | 12 +-
.../catalog/components/debezium-sqlserver.json | 8 +-
.../debezium/DebeziumMySqlComponentConfigurer.java | 7 +-
.../dsl/DebeziumDb2ComponentBuilderFactory.java | 451 ++++++++++++++
.../DebeziumMongodbComponentBuilderFactory.java | 29 +-
.../dsl/DebeziumMysqlComponentBuilderFactory.java | 63 +-
.../dsl/DebeziumOracleComponentBuilderFactory.java | 43 +-
.../DebeziumPostgresComponentBuilderFactory.java | 51 +-
.../DebeziumSqlserverComponentBuilderFactory.java | 43 +-
.../dsl/DebeziumDb2EndpointBuilderFactory.java | 666 +++++++++++++++++++++
.../dsl/DebeziumMongodbEndpointBuilderFactory.java | 28 +-
.../dsl/DebeziumMySqlEndpointBuilderFactory.java | 78 ++-
.../dsl/DebeziumOracleEndpointBuilderFactory.java | 58 +-
.../DebeziumPostgresEndpointBuilderFactory.java | 49 +-
.../DebeziumSqlserverEndpointBuilderFactory.java | 58 +-
19 files changed, 1618 insertions(+), 120 deletions(-)
diff --git a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/debezium-db2.json b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/debezium-db2.json
index aae5f027ab4..fc212c74e33 100644
--- a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/debezium-db2.json
+++ b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/debezium-db2.json
@@ -38,27 +38,49 @@
"autowiredEnabled": { "kind": "property", "displayName": "Autowired Enabled", "group": "advanced", "label": "advanced", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": true, "description": "Whether autowiring is enabled. This is used for automatic autowiring options (the option must be marked as autowired) by looking up in the registry to find if there is a single instance of matching type, which t [...]
"columnBlacklist": { "kind": "property", "displayName": "Column Blacklist", "group": "db2", "label": "consumer,db2", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.Db2ConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Regular expressions matching columns to exclude from change events (depr [...]
"columnExcludeList": { "kind": "property", "displayName": "Column Exclude List", "group": "db2", "label": "consumer,db2", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.Db2ConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Regular expressions matching columns to exclude from change events" },
+ "columnIncludeList": { "kind": "property", "displayName": "Column Include List", "group": "db2", "label": "consumer,db2", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.Db2ConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Regular expressions matching columns to include in change events" },
+ "columnPropagateSourceType": { "kind": "property", "displayName": "Column Propagate Source Type", "group": "db2", "label": "consumer,db2", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.Db2ConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "A comma-separated list of regular expressions matc [...]
+ "columnWhitelist": { "kind": "property", "displayName": "Column Whitelist", "group": "db2", "label": "consumer,db2", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.Db2ConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Regular expressions matching columns to include in change events (deprec [...]
+ "converters": { "kind": "property", "displayName": "Converters", "group": "db2", "label": "consumer,db2", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.Db2ConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Optional list of custom converters that would be used instead of default ones. The [...]
"databaseDbname": { "kind": "property", "displayName": "Database Dbname", "group": "db2", "label": "consumer,db2", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.Db2ConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The name of the database from which the connector should capture changes" },
"databaseHistory": { "kind": "property", "displayName": "Database History", "group": "db2", "label": "consumer,db2", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "io.debezium.relational.history.KafkaDatabaseHistory", "configurationClass": "org.apache.camel.component.debezium.configuration.Db2ConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "T [...]
"databaseHistoryFileFilename": { "kind": "property", "displayName": "Database History File Filename", "group": "db2", "label": "consumer,db2", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.Db2ConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The path to the file that will be used to reco [...]
"databaseHistoryKafkaBootstrapServers": { "kind": "property", "displayName": "Database History Kafka Bootstrap Servers", "group": "db2", "label": "consumer,db2", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.Db2ConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "A list of host\/port pairs [...]
+ "databaseHistoryKafkaQueryTimeoutMs": { "kind": "property", "displayName": "Database History Kafka Query Timeout Ms", "group": "db2", "label": "consumer,db2", "required": false, "type": "duration", "javaType": "long", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "3s", "configurationClass": "org.apache.camel.component.debezium.configuration.Db2ConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The number of mill [...]
"databaseHistoryKafkaRecoveryAttempts": { "kind": "property", "displayName": "Database History Kafka Recovery Attempts", "group": "db2", "label": "consumer,db2", "required": false, "type": "integer", "javaType": "int", "deprecated": false, "autowired": false, "secret": false, "defaultValue": 100, "configurationClass": "org.apache.camel.component.debezium.configuration.Db2ConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The number of atte [...]
"databaseHistoryKafkaRecoveryPollIntervalMs": { "kind": "property", "displayName": "Database History Kafka Recovery Poll Interval Ms", "group": "db2", "label": "consumer,db2", "required": false, "type": "duration", "javaType": "int", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "100ms", "configurationClass": "org.apache.camel.component.debezium.configuration.Db2ConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": [...]
"databaseHistoryKafkaTopic": { "kind": "property", "displayName": "Database History Kafka Topic", "group": "db2", "label": "consumer,db2", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.Db2ConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The name of the topic for the database schema history" },
+ "databaseHistorySkipUnparseableDdl": { "kind": "property", "displayName": "Database History Skip Unparseable Ddl", "group": "db2", "label": "consumer,db2", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": false, "configurationClass": "org.apache.camel.component.debezium.configuration.Db2ConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Controls the actio [...]
+ "databaseHistoryStoreOnlyCapturedTablesDdl": { "kind": "property", "displayName": "Database History Store Only Captured Tables Ddl", "group": "db2", "label": "consumer,db2", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": false, "configurationClass": "org.apache.camel.component.debezium.configuration.Db2ConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": " [...]
+ "databaseHistoryStoreOnlyMonitoredTablesDdl": { "kind": "property", "displayName": "Database History Store Only Monitored Tables Ddl", "group": "db2", "label": "consumer,db2", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": false, "configurationClass": "org.apache.camel.component.debezium.configuration.Db2ConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": [...]
"databaseHostname": { "kind": "property", "displayName": "Database Hostname", "group": "db2", "label": "consumer,db2", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.Db2ConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Resolvable hostname or IP address of the database server." },
"databasePassword": { "kind": "property", "displayName": "Database Password", "group": "db2", "label": "consumer,db2", "required": true, "type": "string", "javaType": "java.lang.String", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.Db2ConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Password of the database user to be used when co [...]
"databasePort": { "kind": "property", "displayName": "Database Port", "group": "db2", "label": "consumer,db2", "required": false, "type": "integer", "javaType": "int", "deprecated": false, "autowired": false, "secret": false, "defaultValue": 50000, "configurationClass": "org.apache.camel.component.debezium.configuration.Db2ConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Port of the database server." },
"databaseServerName": { "kind": "property", "displayName": "Database Server Name", "group": "db2", "label": "consumer,db2", "required": true, "type": "string", "javaType": "java.lang.String", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.Db2ConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Unique name that identifies the database se [...]
"databaseUser": { "kind": "property", "displayName": "Database User", "group": "db2", "label": "consumer,db2", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.Db2ConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Name of the database user to be used when connecting to the database." },
+ "datatypePropagateSourceType": { "kind": "property", "displayName": "Datatype Propagate Source Type", "group": "db2", "label": "consumer,db2", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.Db2ConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "A comma-separated list of regular expressions [...]
"decimalHandlingMode": { "kind": "property", "displayName": "Decimal Handling Mode", "group": "db2", "label": "consumer,db2", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "precise", "configurationClass": "org.apache.camel.component.debezium.configuration.Db2ConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Specify how DECIMAL and NUMERIC colu [...]
"eventProcessingFailureHandlingMode": { "kind": "property", "displayName": "Event Processing Failure Handling Mode", "group": "db2", "label": "consumer,db2", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "fail", "configurationClass": "org.apache.camel.component.debezium.configuration.Db2ConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Specify [...]
"heartbeatIntervalMs": { "kind": "property", "displayName": "Heartbeat Interval Ms", "group": "db2", "label": "consumer,db2", "required": false, "type": "duration", "javaType": "int", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "0ms", "configurationClass": "org.apache.camel.component.debezium.configuration.Db2ConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Length of an interval in milli-seconds in in which [...]
"heartbeatTopicsPrefix": { "kind": "property", "displayName": "Heartbeat Topics Prefix", "group": "db2", "label": "consumer,db2", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "__debezium-heartbeat", "configurationClass": "org.apache.camel.component.debezium.configuration.Db2ConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The prefix that is [...]
+ "includeSchemaChanges": { "kind": "property", "displayName": "Include Schema Changes", "group": "db2", "label": "consumer,db2", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": true, "configurationClass": "org.apache.camel.component.debezium.configuration.Db2ConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Whether the connector should publish changes in [...]
+ "incrementalSnapshotChunkSize": { "kind": "property", "displayName": "Incremental Snapshot Chunk Size", "group": "db2", "label": "consumer,db2", "required": false, "type": "integer", "javaType": "int", "deprecated": false, "autowired": false, "secret": false, "defaultValue": 1024, "configurationClass": "org.apache.camel.component.debezium.configuration.Db2ConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The maximum size of chunk for incr [...]
"maxBatchSize": { "kind": "property", "displayName": "Max Batch Size", "group": "db2", "label": "consumer,db2", "required": false, "type": "integer", "javaType": "int", "deprecated": false, "autowired": false, "secret": false, "defaultValue": 2048, "configurationClass": "org.apache.camel.component.debezium.configuration.Db2ConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Maximum size of each batch of source records. Defaults to 2048." },
"maxQueueSize": { "kind": "property", "displayName": "Max Queue Size", "group": "db2", "label": "consumer,db2", "required": false, "type": "integer", "javaType": "int", "deprecated": false, "autowired": false, "secret": false, "defaultValue": 8192, "configurationClass": "org.apache.camel.component.debezium.configuration.Db2ConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Maximum size of the queue for change events read from the database [...]
+ "maxQueueSizeInBytes": { "kind": "property", "displayName": "Max Queue Size In Bytes", "group": "db2", "label": "consumer,db2", "required": false, "type": "integer", "javaType": "long", "deprecated": false, "autowired": false, "secret": false, "defaultValue": 0, "configurationClass": "org.apache.camel.component.debezium.configuration.Db2ConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Maximum size of the queue in bytes for change events [...]
+ "messageKeyColumns": { "kind": "property", "displayName": "Message Key Columns", "group": "db2", "label": "consumer,db2", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.Db2ConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "A semicolon-separated list of expressions that match fully-qualifie [...]
"pollIntervalMs": { "kind": "property", "displayName": "Poll Interval Ms", "group": "db2", "label": "consumer,db2", "required": false, "type": "duration", "javaType": "long", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "500ms", "configurationClass": "org.apache.camel.component.debezium.configuration.Db2ConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Time to wait for new change events to appear after receivi [...]
+ "provideTransactionMetadata": { "kind": "property", "displayName": "Provide Transaction Metadata", "group": "db2", "label": "consumer,db2", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": false, "configurationClass": "org.apache.camel.component.debezium.configuration.Db2ConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Enables transaction metadata extra [...]
+ "queryFetchSize": { "kind": "property", "displayName": "Query Fetch Size", "group": "db2", "label": "consumer,db2", "required": false, "type": "integer", "javaType": "int", "deprecated": false, "autowired": false, "secret": false, "defaultValue": 0, "configurationClass": "org.apache.camel.component.debezium.configuration.Db2ConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The maximum number of records that should be loaded into memory wh [...]
+ "retriableRestartConnectorWaitMs": { "kind": "property", "displayName": "Retriable Restart Connector Wait Ms", "group": "db2", "label": "consumer,db2", "required": false, "type": "duration", "javaType": "long", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "10s", "configurationClass": "org.apache.camel.component.debezium.configuration.Db2ConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Time to wait before rest [...]
+ "sanitizeFieldNames": { "kind": "property", "displayName": "Sanitize Field Names", "group": "db2", "label": "consumer,db2", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": false, "configurationClass": "org.apache.camel.component.debezium.configuration.Db2ConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Whether field names will be sanitized to Avro nami [...]
+ "schemaNameAdjustmentMode": { "kind": "property", "displayName": "Schema Name Adjustment Mode", "group": "db2", "label": "consumer,db2", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "avro", "configurationClass": "org.apache.camel.component.debezium.configuration.Db2ConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Specify how schema names sho [...]
+ "signalDataCollection": { "kind": "property", "displayName": "Signal Data Collection", "group": "db2", "label": "consumer,db2", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.Db2ConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The name of the data collection that is used to send signals\ [...]
+ "skippedOperations": { "kind": "property", "displayName": "Skipped Operations", "group": "db2", "label": "consumer,db2", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.Db2ConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The comma-separated list of operations to skip during streaming, def [...]
"snapshotDelayMs": { "kind": "property", "displayName": "Snapshot Delay Ms", "group": "db2", "label": "consumer,db2", "required": false, "type": "duration", "javaType": "long", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "0ms", "configurationClass": "org.apache.camel.component.debezium.configuration.Db2ConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "A delay period before a snapshot will begin, given in mill [...]
"snapshotFetchSize": { "kind": "property", "displayName": "Snapshot Fetch Size", "group": "db2", "label": "consumer,db2", "required": false, "type": "integer", "javaType": "int", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.Db2ConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The maximum number of records that should be loaded into memory while performin [...]
+ "snapshotIncludeCollectionList": { "kind": "property", "displayName": "Snapshot Include Collection List", "group": "db2", "label": "consumer,db2", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.Db2ConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "this setting must be set to specify a list [...]
+ "snapshotLockTimeoutMs": { "kind": "property", "displayName": "Snapshot Lock Timeout Ms", "group": "db2", "label": "consumer,db2", "required": false, "type": "duration", "javaType": "long", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "10s", "configurationClass": "org.apache.camel.component.debezium.configuration.Db2ConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The maximum number of millis to wait for tabl [...]
"snapshotMode": { "kind": "property", "displayName": "Snapshot Mode", "group": "db2", "label": "consumer,db2", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "initial", "configurationClass": "org.apache.camel.component.debezium.configuration.Db2ConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The criteria for running a snapshot upon startup of [...]
"snapshotSelectStatementOverrides": { "kind": "property", "displayName": "Snapshot Select Statement Overrides", "group": "db2", "label": "consumer,db2", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.Db2ConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "This property contains a comma-separ [...]
"sourceStructVersion": { "kind": "property", "displayName": "Source Struct Version", "group": "db2", "label": "consumer,db2", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "v2", "configurationClass": "org.apache.camel.component.debezium.configuration.Db2ConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "A version of the format of the publicly v [...]
@@ -67,7 +89,9 @@
"tableIgnoreBuiltin": { "kind": "property", "displayName": "Table Ignore Builtin", "group": "db2", "label": "consumer,db2", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": true, "configurationClass": "org.apache.camel.component.debezium.configuration.Db2ConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Flag specifying whether built-in tables should be i [...]
"tableIncludeList": { "kind": "property", "displayName": "Table Include List", "group": "db2", "label": "consumer,db2", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.Db2ConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The tables for which changes are to be captured" },
"tableWhitelist": { "kind": "property", "displayName": "Table Whitelist", "group": "db2", "label": "consumer,db2", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.Db2ConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The tables for which changes are to be captured (deprecated, use table.inc [...]
- "timePrecisionMode": { "kind": "property", "displayName": "Time Precision Mode", "group": "db2", "label": "consumer,db2", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "adaptive", "configurationClass": "org.apache.camel.component.debezium.configuration.Db2ConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Time, date, and timestamps can be repre [...]
+ "timePrecisionMode": { "kind": "property", "displayName": "Time Precision Mode", "group": "db2", "label": "consumer,db2", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "adaptive", "configurationClass": "org.apache.camel.component.debezium.configuration.Db2ConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Time, date, and timestamps can be repre [...]
+ "tombstonesOnDelete": { "kind": "property", "displayName": "Tombstones On Delete", "group": "db2", "label": "consumer,db2", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": false, "configurationClass": "org.apache.camel.component.debezium.configuration.Db2ConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Whether delete operations should be represented by [...]
+ "transactionTopic": { "kind": "property", "displayName": "Transaction Topic", "group": "db2", "label": "consumer,db2", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "${database.server.name}.transaction", "configurationClass": "org.apache.camel.component.debezium.configuration.Db2ConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The name of the [...]
},
"headers": {
"CamelDebeziumSourceMetadata": { "kind": "header", "displayName": "", "group": "consumer", "label": "", "required": false, "javaType": "Map<String, Object>", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "description": "The metadata about the source event, for example table name, database name, log position, etc, please refer to the Debezium documentation for more info.", "constantName": "org.apache.camel.component.debezium.DebeziumConstants#HEADER_ [...]
@@ -96,27 +120,49 @@
"exchangePattern": { "kind": "parameter", "displayName": "Exchange Pattern", "group": "consumer (advanced)", "label": "consumer,advanced", "required": false, "type": "object", "javaType": "org.apache.camel.ExchangePattern", "enum": [ "InOnly", "InOut", "InOptionalOut" ], "deprecated": false, "autowired": false, "secret": false, "description": "Sets the exchange pattern when the consumer creates an exchange." },
"columnBlacklist": { "kind": "parameter", "displayName": "Column Blacklist", "group": "db2", "label": "consumer,db2", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.Db2ConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Regular expressions matching columns to exclude from change events (dep [...]
"columnExcludeList": { "kind": "parameter", "displayName": "Column Exclude List", "group": "db2", "label": "consumer,db2", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.Db2ConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Regular expressions matching columns to exclude from change events" },
+ "columnIncludeList": { "kind": "parameter", "displayName": "Column Include List", "group": "db2", "label": "consumer,db2", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.Db2ConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Regular expressions matching columns to include in change events" },
+ "columnPropagateSourceType": { "kind": "parameter", "displayName": "Column Propagate Source Type", "group": "db2", "label": "consumer,db2", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.Db2ConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "A comma-separated list of regular expressions mat [...]
+ "columnWhitelist": { "kind": "parameter", "displayName": "Column Whitelist", "group": "db2", "label": "consumer,db2", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.Db2ConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Regular expressions matching columns to include in change events (depre [...]
+ "converters": { "kind": "parameter", "displayName": "Converters", "group": "db2", "label": "consumer,db2", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.Db2ConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Optional list of custom converters that would be used instead of default ones. The [...]
"databaseDbname": { "kind": "parameter", "displayName": "Database Dbname", "group": "db2", "label": "consumer,db2", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.Db2ConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The name of the database from which the connector should capture changes" },
"databaseHistory": { "kind": "parameter", "displayName": "Database History", "group": "db2", "label": "consumer,db2", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "io.debezium.relational.history.KafkaDatabaseHistory", "configurationClass": "org.apache.camel.component.debezium.configuration.Db2ConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": " [...]
"databaseHistoryFileFilename": { "kind": "parameter", "displayName": "Database History File Filename", "group": "db2", "label": "consumer,db2", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.Db2ConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The path to the file that will be used to rec [...]
"databaseHistoryKafkaBootstrapServers": { "kind": "parameter", "displayName": "Database History Kafka Bootstrap Servers", "group": "db2", "label": "consumer,db2", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.Db2ConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "A list of host\/port pairs [...]
+ "databaseHistoryKafkaQueryTimeoutMs": { "kind": "parameter", "displayName": "Database History Kafka Query Timeout Ms", "group": "db2", "label": "consumer,db2", "required": false, "type": "duration", "javaType": "long", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "3s", "configurationClass": "org.apache.camel.component.debezium.configuration.Db2ConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The number of mil [...]
"databaseHistoryKafkaRecoveryAttempts": { "kind": "parameter", "displayName": "Database History Kafka Recovery Attempts", "group": "db2", "label": "consumer,db2", "required": false, "type": "integer", "javaType": "int", "deprecated": false, "autowired": false, "secret": false, "defaultValue": 100, "configurationClass": "org.apache.camel.component.debezium.configuration.Db2ConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The number of att [...]
"databaseHistoryKafkaRecoveryPollIntervalMs": { "kind": "parameter", "displayName": "Database History Kafka Recovery Poll Interval Ms", "group": "db2", "label": "consumer,db2", "required": false, "type": "duration", "javaType": "int", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "100ms", "configurationClass": "org.apache.camel.component.debezium.configuration.Db2ConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": [...]
"databaseHistoryKafkaTopic": { "kind": "parameter", "displayName": "Database History Kafka Topic", "group": "db2", "label": "consumer,db2", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.Db2ConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The name of the topic for the database schema his [...]
+ "databaseHistorySkipUnparseableDdl": { "kind": "parameter", "displayName": "Database History Skip Unparseable Ddl", "group": "db2", "label": "consumer,db2", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": false, "configurationClass": "org.apache.camel.component.debezium.configuration.Db2ConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Controls the acti [...]
+ "databaseHistoryStoreOnlyCapturedTablesDdl": { "kind": "parameter", "displayName": "Database History Store Only Captured Tables Ddl", "group": "db2", "label": "consumer,db2", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": false, "configurationClass": "org.apache.camel.component.debezium.configuration.Db2ConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": [...]
+ "databaseHistoryStoreOnlyMonitoredTablesDdl": { "kind": "parameter", "displayName": "Database History Store Only Monitored Tables Ddl", "group": "db2", "label": "consumer,db2", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": false, "configurationClass": "org.apache.camel.component.debezium.configuration.Db2ConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description" [...]
"databaseHostname": { "kind": "parameter", "displayName": "Database Hostname", "group": "db2", "label": "consumer,db2", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.Db2ConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Resolvable hostname or IP address of the database server." },
"databasePassword": { "kind": "parameter", "displayName": "Database Password", "group": "db2", "label": "consumer,db2", "required": true, "type": "string", "javaType": "java.lang.String", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.Db2ConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Password of the database user to be used when c [...]
"databasePort": { "kind": "parameter", "displayName": "Database Port", "group": "db2", "label": "consumer,db2", "required": false, "type": "integer", "javaType": "int", "deprecated": false, "autowired": false, "secret": false, "defaultValue": 50000, "configurationClass": "org.apache.camel.component.debezium.configuration.Db2ConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Port of the database server." },
"databaseServerName": { "kind": "parameter", "displayName": "Database Server Name", "group": "db2", "label": "consumer,db2", "required": true, "type": "string", "javaType": "java.lang.String", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.Db2ConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Unique name that identifies the database s [...]
"databaseUser": { "kind": "parameter", "displayName": "Database User", "group": "db2", "label": "consumer,db2", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.Db2ConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Name of the database user to be used when connecting to the database." },
+ "datatypePropagateSourceType": { "kind": "parameter", "displayName": "Datatype Propagate Source Type", "group": "db2", "label": "consumer,db2", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.Db2ConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "A comma-separated list of regular expressions [...]
"decimalHandlingMode": { "kind": "parameter", "displayName": "Decimal Handling Mode", "group": "db2", "label": "consumer,db2", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "precise", "configurationClass": "org.apache.camel.component.debezium.configuration.Db2ConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Specify how DECIMAL and NUMERIC col [...]
"eventProcessingFailureHandlingMode": { "kind": "parameter", "displayName": "Event Processing Failure Handling Mode", "group": "db2", "label": "consumer,db2", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "fail", "configurationClass": "org.apache.camel.component.debezium.configuration.Db2ConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Specif [...]
"heartbeatIntervalMs": { "kind": "parameter", "displayName": "Heartbeat Interval Ms", "group": "db2", "label": "consumer,db2", "required": false, "type": "duration", "javaType": "int", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "0ms", "configurationClass": "org.apache.camel.component.debezium.configuration.Db2ConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Length of an interval in milli-seconds in in which [...]
"heartbeatTopicsPrefix": { "kind": "parameter", "displayName": "Heartbeat Topics Prefix", "group": "db2", "label": "consumer,db2", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "__debezium-heartbeat", "configurationClass": "org.apache.camel.component.debezium.configuration.Db2ConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The prefix that is [...]
+ "includeSchemaChanges": { "kind": "parameter", "displayName": "Include Schema Changes", "group": "db2", "label": "consumer,db2", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": true, "configurationClass": "org.apache.camel.component.debezium.configuration.Db2ConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Whether the connector should publish changes i [...]
+ "incrementalSnapshotChunkSize": { "kind": "parameter", "displayName": "Incremental Snapshot Chunk Size", "group": "db2", "label": "consumer,db2", "required": false, "type": "integer", "javaType": "int", "deprecated": false, "autowired": false, "secret": false, "defaultValue": 1024, "configurationClass": "org.apache.camel.component.debezium.configuration.Db2ConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The maximum size of chunk for inc [...]
"maxBatchSize": { "kind": "parameter", "displayName": "Max Batch Size", "group": "db2", "label": "consumer,db2", "required": false, "type": "integer", "javaType": "int", "deprecated": false, "autowired": false, "secret": false, "defaultValue": 2048, "configurationClass": "org.apache.camel.component.debezium.configuration.Db2ConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Maximum size of each batch of source records. Defaults to 2048." },
"maxQueueSize": { "kind": "parameter", "displayName": "Max Queue Size", "group": "db2", "label": "consumer,db2", "required": false, "type": "integer", "javaType": "int", "deprecated": false, "autowired": false, "secret": false, "defaultValue": 8192, "configurationClass": "org.apache.camel.component.debezium.configuration.Db2ConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Maximum size of the queue for change events read from the database [...]
+ "maxQueueSizeInBytes": { "kind": "parameter", "displayName": "Max Queue Size In Bytes", "group": "db2", "label": "consumer,db2", "required": false, "type": "integer", "javaType": "long", "deprecated": false, "autowired": false, "secret": false, "defaultValue": 0, "configurationClass": "org.apache.camel.component.debezium.configuration.Db2ConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Maximum size of the queue in bytes for change events [...]
+ "messageKeyColumns": { "kind": "parameter", "displayName": "Message Key Columns", "group": "db2", "label": "consumer,db2", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.Db2ConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "A semicolon-separated list of expressions that match fully-qualifi [...]
"pollIntervalMs": { "kind": "parameter", "displayName": "Poll Interval Ms", "group": "db2", "label": "consumer,db2", "required": false, "type": "duration", "javaType": "long", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "500ms", "configurationClass": "org.apache.camel.component.debezium.configuration.Db2ConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Time to wait for new change events to appear after receiv [...]
+ "provideTransactionMetadata": { "kind": "parameter", "displayName": "Provide Transaction Metadata", "group": "db2", "label": "consumer,db2", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": false, "configurationClass": "org.apache.camel.component.debezium.configuration.Db2ConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Enables transaction metadata extr [...]
+ "queryFetchSize": { "kind": "parameter", "displayName": "Query Fetch Size", "group": "db2", "label": "consumer,db2", "required": false, "type": "integer", "javaType": "int", "deprecated": false, "autowired": false, "secret": false, "defaultValue": 0, "configurationClass": "org.apache.camel.component.debezium.configuration.Db2ConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The maximum number of records that should be loaded into memory w [...]
+ "retriableRestartConnectorWaitMs": { "kind": "parameter", "displayName": "Retriable Restart Connector Wait Ms", "group": "db2", "label": "consumer,db2", "required": false, "type": "duration", "javaType": "long", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "10s", "configurationClass": "org.apache.camel.component.debezium.configuration.Db2ConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Time to wait before res [...]
+ "sanitizeFieldNames": { "kind": "parameter", "displayName": "Sanitize Field Names", "group": "db2", "label": "consumer,db2", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": false, "configurationClass": "org.apache.camel.component.debezium.configuration.Db2ConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Whether field names will be sanitized to Avro nam [...]
+ "schemaNameAdjustmentMode": { "kind": "parameter", "displayName": "Schema Name Adjustment Mode", "group": "db2", "label": "consumer,db2", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "avro", "configurationClass": "org.apache.camel.component.debezium.configuration.Db2ConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Specify how schema names sh [...]
+ "signalDataCollection": { "kind": "parameter", "displayName": "Signal Data Collection", "group": "db2", "label": "consumer,db2", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.Db2ConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The name of the data collection that is used to send signals [...]
+ "skippedOperations": { "kind": "parameter", "displayName": "Skipped Operations", "group": "db2", "label": "consumer,db2", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.Db2ConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The comma-separated list of operations to skip during streaming, de [...]
"snapshotDelayMs": { "kind": "parameter", "displayName": "Snapshot Delay Ms", "group": "db2", "label": "consumer,db2", "required": false, "type": "duration", "javaType": "long", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "0ms", "configurationClass": "org.apache.camel.component.debezium.configuration.Db2ConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "A delay period before a snapshot will begin, given in mil [...]
"snapshotFetchSize": { "kind": "parameter", "displayName": "Snapshot Fetch Size", "group": "db2", "label": "consumer,db2", "required": false, "type": "integer", "javaType": "int", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.Db2ConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The maximum number of records that should be loaded into memory while performi [...]
+ "snapshotIncludeCollectionList": { "kind": "parameter", "displayName": "Snapshot Include Collection List", "group": "db2", "label": "consumer,db2", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.Db2ConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "this setting must be set to specify a lis [...]
+ "snapshotLockTimeoutMs": { "kind": "parameter", "displayName": "Snapshot Lock Timeout Ms", "group": "db2", "label": "consumer,db2", "required": false, "type": "duration", "javaType": "long", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "10s", "configurationClass": "org.apache.camel.component.debezium.configuration.Db2ConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The maximum number of millis to wait for tab [...]
"snapshotMode": { "kind": "parameter", "displayName": "Snapshot Mode", "group": "db2", "label": "consumer,db2", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "initial", "configurationClass": "org.apache.camel.component.debezium.configuration.Db2ConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The criteria for running a snapshot upon startup o [...]
"snapshotSelectStatementOverrides": { "kind": "parameter", "displayName": "Snapshot Select Statement Overrides", "group": "db2", "label": "consumer,db2", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.Db2ConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "This property contains a comma-sepa [...]
"sourceStructVersion": { "kind": "parameter", "displayName": "Source Struct Version", "group": "db2", "label": "consumer,db2", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "v2", "configurationClass": "org.apache.camel.component.debezium.configuration.Db2ConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "A version of the format of the publicly [...]
@@ -125,6 +171,8 @@
"tableIgnoreBuiltin": { "kind": "parameter", "displayName": "Table Ignore Builtin", "group": "db2", "label": "consumer,db2", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": true, "configurationClass": "org.apache.camel.component.debezium.configuration.Db2ConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Flag specifying whether built-in tables should be [...]
"tableIncludeList": { "kind": "parameter", "displayName": "Table Include List", "group": "db2", "label": "consumer,db2", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.Db2ConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The tables for which changes are to be captured" },
"tableWhitelist": { "kind": "parameter", "displayName": "Table Whitelist", "group": "db2", "label": "consumer,db2", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.Db2ConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The tables for which changes are to be captured (deprecated, use table.in [...]
- "timePrecisionMode": { "kind": "parameter", "displayName": "Time Precision Mode", "group": "db2", "label": "consumer,db2", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "adaptive", "configurationClass": "org.apache.camel.component.debezium.configuration.Db2ConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Time, date, and timestamps can be repr [...]
+ "timePrecisionMode": { "kind": "parameter", "displayName": "Time Precision Mode", "group": "db2", "label": "consumer,db2", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "adaptive", "configurationClass": "org.apache.camel.component.debezium.configuration.Db2ConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Time, date, and timestamps can be repr [...]
+ "tombstonesOnDelete": { "kind": "parameter", "displayName": "Tombstones On Delete", "group": "db2", "label": "consumer,db2", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": false, "configurationClass": "org.apache.camel.component.debezium.configuration.Db2ConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Whether delete operations should be represented b [...]
+ "transactionTopic": { "kind": "parameter", "displayName": "Transaction Topic", "group": "db2", "label": "consumer,db2", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "${database.server.name}.transaction", "configurationClass": "org.apache.camel.component.debezium.configuration.Db2ConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The name of th [...]
}
}
diff --git a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/debezium-mongodb.json b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/debezium-mongodb.json
index 2d87f378351..5a1c26326f2 100644
--- a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/debezium-mongodb.json
+++ b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/debezium-mongodb.json
@@ -59,7 +59,7 @@
"mongodbConnectTimeoutMs": { "kind": "property", "displayName": "Mongodb Connect Timeout Ms", "group": "mongodb", "label": "consumer,mongodb", "required": false, "type": "duration", "javaType": "int", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "10s", "configurationClass": "org.apache.camel.component.debezium.configuration.MongoDbConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The connection timeout, given [...]
"mongodbHosts": { "kind": "property", "displayName": "Mongodb Hosts", "group": "mongodb", "label": "consumer,mongodb", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.MongoDbConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The hostname and port pairs (in the form 'host' or 'host:port') of [...]
"mongodbMembersAutoDiscover": { "kind": "property", "displayName": "Mongodb Members Auto Discover", "group": "mongodb", "label": "consumer,mongodb", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": true, "configurationClass": "org.apache.camel.component.debezium.configuration.MongoDbConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Specifies whether the [...]
- "mongodbName": { "kind": "property", "displayName": "Mongodb Name", "group": "mongodb", "label": "consumer,mongodb", "required": true, "type": "string", "javaType": "java.lang.String", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.MongoDbConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Unique name that identifies the MongoDB replic [...]
+ "mongodbName": { "kind": "property", "displayName": "Mongodb Name", "group": "mongodb", "label": "consumer,mongodb", "required": true, "type": "string", "javaType": "java.lang.String", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.MongoDbConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Unique name that identifies the MongoDB replic [...]
"mongodbPassword": { "kind": "property", "displayName": "Mongodb Password", "group": "mongodb", "label": "consumer,mongodb", "required": true, "type": "string", "javaType": "java.lang.String", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.MongoDbConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Password to be used when connecting to [...]
"mongodbPollIntervalMs": { "kind": "property", "displayName": "Mongodb Poll Interval Ms", "group": "mongodb", "label": "consumer,mongodb", "required": false, "type": "duration", "javaType": "long", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "30s", "configurationClass": "org.apache.camel.component.debezium.configuration.MongoDbConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Interval for looking for new, rem [...]
"mongodbServerSelectionTimeoutMs": { "kind": "property", "displayName": "Mongodb Server Selection Timeout Ms", "group": "mongodb", "label": "consumer,mongodb", "required": false, "type": "duration", "javaType": "int", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "30s", "configurationClass": "org.apache.camel.component.debezium.configuration.MongoDbConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The server se [...]
@@ -72,8 +72,9 @@
"queryFetchSize": { "kind": "property", "displayName": "Query Fetch Size", "group": "mongodb", "label": "consumer,mongodb", "required": false, "type": "integer", "javaType": "int", "deprecated": false, "autowired": false, "secret": false, "defaultValue": 0, "configurationClass": "org.apache.camel.component.debezium.configuration.MongoDbConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The maximum number of records that should be loaded in [...]
"retriableRestartConnectorWaitMs": { "kind": "property", "displayName": "Retriable Restart Connector Wait Ms", "group": "mongodb", "label": "consumer,mongodb", "required": false, "type": "duration", "javaType": "long", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "10s", "configurationClass": "org.apache.camel.component.debezium.configuration.MongoDbConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Time to wait [...]
"sanitizeFieldNames": { "kind": "property", "displayName": "Sanitize Field Names", "group": "mongodb", "label": "consumer,mongodb", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": false, "configurationClass": "org.apache.camel.component.debezium.configuration.MongoDbConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Whether field names will be sanitized [...]
+ "schemaNameAdjustmentMode": { "kind": "property", "displayName": "Schema Name Adjustment Mode", "group": "mongodb", "label": "consumer,mongodb", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "avro", "configurationClass": "org.apache.camel.component.debezium.configuration.MongoDbConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Specify how sche [...]
"signalDataCollection": { "kind": "property", "displayName": "Signal Data Collection", "group": "mongodb", "label": "consumer,mongodb", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.MongoDbConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The name of the data collection that is used to s [...]
- "skippedOperations": { "kind": "property", "displayName": "Skipped Operations", "group": "mongodb", "label": "consumer,mongodb", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.MongoDbConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The comma-separated list of operations to skip during st [...]
+ "skippedOperations": { "kind": "property", "displayName": "Skipped Operations", "group": "mongodb", "label": "consumer,mongodb", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.MongoDbConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The comma-separated list of operations to skip during st [...]
"snapshotCollectionFilterOverrides": { "kind": "property", "displayName": "Snapshot Collection Filter Overrides", "group": "mongodb", "label": "consumer,mongodb", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.MongoDbConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "This property contains [...]
"snapshotDelayMs": { "kind": "property", "displayName": "Snapshot Delay Ms", "group": "mongodb", "label": "consumer,mongodb", "required": false, "type": "duration", "javaType": "long", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "0ms", "configurationClass": "org.apache.camel.component.debezium.configuration.MongoDbConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "A delay period before a snapshot will begin, g [...]
"snapshotFetchSize": { "kind": "property", "displayName": "Snapshot Fetch Size", "group": "mongodb", "label": "consumer,mongodb", "required": false, "type": "integer", "javaType": "int", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.MongoDbConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The maximum number of records that should be loaded into memory whi [...]
@@ -132,7 +133,7 @@
"mongodbConnectTimeoutMs": { "kind": "parameter", "displayName": "Mongodb Connect Timeout Ms", "group": "mongodb", "label": "consumer,mongodb", "required": false, "type": "duration", "javaType": "int", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "10s", "configurationClass": "org.apache.camel.component.debezium.configuration.MongoDbConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The connection timeout, given [...]
"mongodbHosts": { "kind": "parameter", "displayName": "Mongodb Hosts", "group": "mongodb", "label": "consumer,mongodb", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.MongoDbConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The hostname and port pairs (in the form 'host' or 'host:port') o [...]
"mongodbMembersAutoDiscover": { "kind": "parameter", "displayName": "Mongodb Members Auto Discover", "group": "mongodb", "label": "consumer,mongodb", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": true, "configurationClass": "org.apache.camel.component.debezium.configuration.MongoDbConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Specifies whether the [...]
- "mongodbName": { "kind": "parameter", "displayName": "Mongodb Name", "group": "mongodb", "label": "consumer,mongodb", "required": true, "type": "string", "javaType": "java.lang.String", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.MongoDbConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Unique name that identifies the MongoDB repli [...]
+ "mongodbName": { "kind": "parameter", "displayName": "Mongodb Name", "group": "mongodb", "label": "consumer,mongodb", "required": true, "type": "string", "javaType": "java.lang.String", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.MongoDbConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Unique name that identifies the MongoDB repli [...]
"mongodbPassword": { "kind": "parameter", "displayName": "Mongodb Password", "group": "mongodb", "label": "consumer,mongodb", "required": true, "type": "string", "javaType": "java.lang.String", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.MongoDbConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Password to be used when connecting t [...]
"mongodbPollIntervalMs": { "kind": "parameter", "displayName": "Mongodb Poll Interval Ms", "group": "mongodb", "label": "consumer,mongodb", "required": false, "type": "duration", "javaType": "long", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "30s", "configurationClass": "org.apache.camel.component.debezium.configuration.MongoDbConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Interval for looking for new, re [...]
"mongodbServerSelectionTimeoutMs": { "kind": "parameter", "displayName": "Mongodb Server Selection Timeout Ms", "group": "mongodb", "label": "consumer,mongodb", "required": false, "type": "duration", "javaType": "int", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "30s", "configurationClass": "org.apache.camel.component.debezium.configuration.MongoDbConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The server s [...]
@@ -145,8 +146,9 @@
"queryFetchSize": { "kind": "parameter", "displayName": "Query Fetch Size", "group": "mongodb", "label": "consumer,mongodb", "required": false, "type": "integer", "javaType": "int", "deprecated": false, "autowired": false, "secret": false, "defaultValue": 0, "configurationClass": "org.apache.camel.component.debezium.configuration.MongoDbConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The maximum number of records that should be loaded i [...]
"retriableRestartConnectorWaitMs": { "kind": "parameter", "displayName": "Retriable Restart Connector Wait Ms", "group": "mongodb", "label": "consumer,mongodb", "required": false, "type": "duration", "javaType": "long", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "10s", "configurationClass": "org.apache.camel.component.debezium.configuration.MongoDbConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Time to wai [...]
"sanitizeFieldNames": { "kind": "parameter", "displayName": "Sanitize Field Names", "group": "mongodb", "label": "consumer,mongodb", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": false, "configurationClass": "org.apache.camel.component.debezium.configuration.MongoDbConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Whether field names will be sanitized [...]
+ "schemaNameAdjustmentMode": { "kind": "parameter", "displayName": "Schema Name Adjustment Mode", "group": "mongodb", "label": "consumer,mongodb", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "avro", "configurationClass": "org.apache.camel.component.debezium.configuration.MongoDbConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Specify how sch [...]
"signalDataCollection": { "kind": "parameter", "displayName": "Signal Data Collection", "group": "mongodb", "label": "consumer,mongodb", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.MongoDbConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The name of the data collection that is used to [...]
- "skippedOperations": { "kind": "parameter", "displayName": "Skipped Operations", "group": "mongodb", "label": "consumer,mongodb", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.MongoDbConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The comma-separated list of operations to skip during s [...]
+ "skippedOperations": { "kind": "parameter", "displayName": "Skipped Operations", "group": "mongodb", "label": "consumer,mongodb", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.MongoDbConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The comma-separated list of operations to skip during s [...]
"snapshotCollectionFilterOverrides": { "kind": "parameter", "displayName": "Snapshot Collection Filter Overrides", "group": "mongodb", "label": "consumer,mongodb", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.MongoDbConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "This property contain [...]
"snapshotDelayMs": { "kind": "parameter", "displayName": "Snapshot Delay Ms", "group": "mongodb", "label": "consumer,mongodb", "required": false, "type": "duration", "javaType": "long", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "0ms", "configurationClass": "org.apache.camel.component.debezium.configuration.MongoDbConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "A delay period before a snapshot will begin, [...]
"snapshotFetchSize": { "kind": "parameter", "displayName": "Snapshot Fetch Size", "group": "mongodb", "label": "consumer,mongodb", "required": false, "type": "integer", "javaType": "int", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.MongoDbConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The maximum number of records that should be loaded into memory wh [...]
diff --git a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/debezium-mysql.json b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/debezium-mysql.json
index 7c2da8f97d0..145313c9df6 100644
--- a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/debezium-mysql.json
+++ b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/debezium-mysql.json
@@ -52,6 +52,7 @@
"databaseHistory": { "kind": "property", "displayName": "Database History", "group": "mysql", "label": "consumer,mysql", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "io.debezium.relational.history.FileDatabaseHistory", "configurationClass": "org.apache.camel.component.debezium.configuration.MySqlConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description [...]
"databaseHistoryFileFilename": { "kind": "property", "displayName": "Database History File Filename", "group": "mysql", "label": "consumer,mysql", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.MySqlConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The path to the file that will be used t [...]
"databaseHistoryKafkaBootstrapServers": { "kind": "property", "displayName": "Database History Kafka Bootstrap Servers", "group": "mysql", "label": "consumer,mysql", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.MySqlConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "A list of host\/port [...]
+ "databaseHistoryKafkaQueryTimeoutMs": { "kind": "property", "displayName": "Database History Kafka Query Timeout Ms", "group": "mysql", "label": "consumer,mysql", "required": false, "type": "duration", "javaType": "long", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "3s", "configurationClass": "org.apache.camel.component.debezium.configuration.MySqlConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The number o [...]
"databaseHistoryKafkaRecoveryAttempts": { "kind": "property", "displayName": "Database History Kafka Recovery Attempts", "group": "mysql", "label": "consumer,mysql", "required": false, "type": "integer", "javaType": "int", "deprecated": false, "autowired": false, "secret": false, "defaultValue": 100, "configurationClass": "org.apache.camel.component.debezium.configuration.MySqlConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The number o [...]
"databaseHistoryKafkaRecoveryPollIntervalMs": { "kind": "property", "displayName": "Database History Kafka Recovery Poll Interval Ms", "group": "mysql", "label": "consumer,mysql", "required": false, "type": "duration", "javaType": "int", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "100ms", "configurationClass": "org.apache.camel.component.debezium.configuration.MySqlConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "descript [...]
"databaseHistoryKafkaTopic": { "kind": "property", "displayName": "Database History Kafka Topic", "group": "mysql", "label": "consumer,mysql", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.MySqlConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The name of the topic for the database schem [...]
@@ -67,11 +68,11 @@
"databaseServerId": { "kind": "property", "displayName": "Database Server Id", "group": "mysql", "label": "consumer,mysql", "required": false, "type": "integer", "javaType": "long", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.MySqlConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "A numeric ID of this database client, which must be unique across all curr [...]
"databaseServerIdOffset": { "kind": "property", "displayName": "Database Server Id Offset", "group": "mysql", "label": "consumer,mysql", "required": false, "type": "integer", "javaType": "long", "deprecated": false, "autowired": false, "secret": false, "defaultValue": 10000, "configurationClass": "org.apache.camel.component.debezium.configuration.MySqlConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Only relevant if parallel snapshotting [...]
"databaseServerName": { "kind": "property", "displayName": "Database Server Name", "group": "mysql", "label": "consumer,mysql", "required": true, "type": "string", "javaType": "java.lang.String", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.MySqlConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Unique name that identifies the datab [...]
- "databaseSslKeystore": { "kind": "property", "displayName": "Database Ssl Keystore", "group": "mysql", "label": "consumer,mysql", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.MySqlConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Location of the Java keystore file containing an applicat [...]
- "databaseSslKeystorePassword": { "kind": "property", "displayName": "Database Ssl Keystore Password", "group": "mysql", "label": "consumer,mysql", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.MySqlConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Password to access the private key from [...]
+ "databaseSslKeystore": { "kind": "property", "displayName": "Database Ssl Keystore", "group": "mysql", "label": "consumer,mysql", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.MySqlConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The location of the key store file. This is optional and [...]
+ "databaseSslKeystorePassword": { "kind": "property", "displayName": "Database Ssl Keystore Password", "group": "mysql", "label": "consumer,mysql", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.MySqlConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The password for the key store file. Thi [...]
"databaseSslMode": { "kind": "property", "displayName": "Database Ssl Mode", "group": "mysql", "label": "consumer,mysql", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "disabled", "configurationClass": "org.apache.camel.component.debezium.configuration.MySqlConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Whether to use an encrypted connectio [...]
- "databaseSslTruststore": { "kind": "property", "displayName": "Database Ssl Truststore", "group": "mysql", "label": "consumer,mysql", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.MySqlConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Location of the Java truststore file containing the c [...]
- "databaseSslTruststorePassword": { "kind": "property", "displayName": "Database Ssl Truststore Password", "group": "mysql", "label": "consumer,mysql", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.MySqlConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Password to unlock the keystore file [...]
+ "databaseSslTruststore": { "kind": "property", "displayName": "Database Ssl Truststore", "group": "mysql", "label": "consumer,mysql", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.MySqlConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The location of the trust store file for the server c [...]
+ "databaseSslTruststorePassword": { "kind": "property", "displayName": "Database Ssl Truststore Password", "group": "mysql", "label": "consumer,mysql", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.MySqlConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The password for the trust store fil [...]
"databaseUser": { "kind": "property", "displayName": "Database User", "group": "mysql", "label": "consumer,mysql", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.MySqlConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Name of the database user to be used when connecting to the database." },
"datatypePropagateSourceType": { "kind": "property", "displayName": "Datatype Propagate Source Type", "group": "mysql", "label": "consumer,mysql", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.MySqlConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "A comma-separated list of regular expres [...]
"decimalHandlingMode": { "kind": "property", "displayName": "Decimal Handling Mode", "group": "mysql", "label": "consumer,mysql", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "precise", "configurationClass": "org.apache.camel.component.debezium.configuration.MySqlConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Specify how DECIMAL and NUMERI [...]
@@ -100,8 +101,9 @@
"queryFetchSize": { "kind": "property", "displayName": "Query Fetch Size", "group": "mysql", "label": "consumer,mysql", "required": false, "type": "integer", "javaType": "int", "deprecated": false, "autowired": false, "secret": false, "defaultValue": 0, "configurationClass": "org.apache.camel.component.debezium.configuration.MySqlConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The maximum number of records that should be loaded into mem [...]
"retriableRestartConnectorWaitMs": { "kind": "property", "displayName": "Retriable Restart Connector Wait Ms", "group": "mysql", "label": "consumer,mysql", "required": false, "type": "duration", "javaType": "long", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "10s", "configurationClass": "org.apache.camel.component.debezium.configuration.MySqlConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Time to wait befor [...]
"sanitizeFieldNames": { "kind": "property", "displayName": "Sanitize Field Names", "group": "mysql", "label": "consumer,mysql", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": false, "configurationClass": "org.apache.camel.component.debezium.configuration.MySqlConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Whether field names will be sanitized to Avr [...]
+ "schemaNameAdjustmentMode": { "kind": "property", "displayName": "Schema Name Adjustment Mode", "group": "mysql", "label": "consumer,mysql", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "avro", "configurationClass": "org.apache.camel.component.debezium.configuration.MySqlConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Specify how schema nam [...]
"signalDataCollection": { "kind": "property", "displayName": "Signal Data Collection", "group": "mysql", "label": "consumer,mysql", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.MySqlConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The name of the data collection that is used to send si [...]
- "skippedOperations": { "kind": "property", "displayName": "Skipped Operations", "group": "mysql", "label": "consumer,mysql", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.MySqlConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The comma-separated list of operations to skip during streamin [...]
+ "skippedOperations": { "kind": "property", "displayName": "Skipped Operations", "group": "mysql", "label": "consumer,mysql", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.MySqlConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The comma-separated list of operations to skip during streamin [...]
"snapshotDelayMs": { "kind": "property", "displayName": "Snapshot Delay Ms", "group": "mysql", "label": "consumer,mysql", "required": false, "type": "duration", "javaType": "long", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "0ms", "configurationClass": "org.apache.camel.component.debezium.configuration.MySqlConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "A delay period before a snapshot will begin, given i [...]
"snapshotFetchSize": { "kind": "property", "displayName": "Snapshot Fetch Size", "group": "mysql", "label": "consumer,mysql", "required": false, "type": "integer", "javaType": "int", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.MySqlConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The maximum number of records that should be loaded into memory while per [...]
"snapshotIncludeCollectionList": { "kind": "property", "displayName": "Snapshot Include Collection List", "group": "mysql", "label": "consumer,mysql", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.MySqlConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "this setting must be set to specify [...]
@@ -162,6 +164,7 @@
"databaseHistory": { "kind": "parameter", "displayName": "Database History", "group": "mysql", "label": "consumer,mysql", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "io.debezium.relational.history.FileDatabaseHistory", "configurationClass": "org.apache.camel.component.debezium.configuration.MySqlConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "descriptio [...]
"databaseHistoryFileFilename": { "kind": "parameter", "displayName": "Database History File Filename", "group": "mysql", "label": "consumer,mysql", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.MySqlConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The path to the file that will be used [...]
"databaseHistoryKafkaBootstrapServers": { "kind": "parameter", "displayName": "Database History Kafka Bootstrap Servers", "group": "mysql", "label": "consumer,mysql", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.MySqlConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "A list of host\/port [...]
+ "databaseHistoryKafkaQueryTimeoutMs": { "kind": "parameter", "displayName": "Database History Kafka Query Timeout Ms", "group": "mysql", "label": "consumer,mysql", "required": false, "type": "duration", "javaType": "long", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "3s", "configurationClass": "org.apache.camel.component.debezium.configuration.MySqlConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The number [...]
"databaseHistoryKafkaRecoveryAttempts": { "kind": "parameter", "displayName": "Database History Kafka Recovery Attempts", "group": "mysql", "label": "consumer,mysql", "required": false, "type": "integer", "javaType": "int", "deprecated": false, "autowired": false, "secret": false, "defaultValue": 100, "configurationClass": "org.apache.camel.component.debezium.configuration.MySqlConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The number [...]
"databaseHistoryKafkaRecoveryPollIntervalMs": { "kind": "parameter", "displayName": "Database History Kafka Recovery Poll Interval Ms", "group": "mysql", "label": "consumer,mysql", "required": false, "type": "duration", "javaType": "int", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "100ms", "configurationClass": "org.apache.camel.component.debezium.configuration.MySqlConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "descrip [...]
"databaseHistoryKafkaTopic": { "kind": "parameter", "displayName": "Database History Kafka Topic", "group": "mysql", "label": "consumer,mysql", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.MySqlConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The name of the topic for the database sche [...]
@@ -177,11 +180,11 @@
"databaseServerId": { "kind": "parameter", "displayName": "Database Server Id", "group": "mysql", "label": "consumer,mysql", "required": false, "type": "integer", "javaType": "long", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.MySqlConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "A numeric ID of this database client, which must be unique across all cur [...]
"databaseServerIdOffset": { "kind": "parameter", "displayName": "Database Server Id Offset", "group": "mysql", "label": "consumer,mysql", "required": false, "type": "integer", "javaType": "long", "deprecated": false, "autowired": false, "secret": false, "defaultValue": 10000, "configurationClass": "org.apache.camel.component.debezium.configuration.MySqlConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Only relevant if parallel snapshottin [...]
"databaseServerName": { "kind": "parameter", "displayName": "Database Server Name", "group": "mysql", "label": "consumer,mysql", "required": true, "type": "string", "javaType": "java.lang.String", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.MySqlConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Unique name that identifies the data [...]
- "databaseSslKeystore": { "kind": "parameter", "displayName": "Database Ssl Keystore", "group": "mysql", "label": "consumer,mysql", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.MySqlConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Location of the Java keystore file containing an applica [...]
- "databaseSslKeystorePassword": { "kind": "parameter", "displayName": "Database Ssl Keystore Password", "group": "mysql", "label": "consumer,mysql", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.MySqlConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Password to access the private key from [...]
+ "databaseSslKeystore": { "kind": "parameter", "displayName": "Database Ssl Keystore", "group": "mysql", "label": "consumer,mysql", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.MySqlConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The location of the key store file. This is optional and [...]
+ "databaseSslKeystorePassword": { "kind": "parameter", "displayName": "Database Ssl Keystore Password", "group": "mysql", "label": "consumer,mysql", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.MySqlConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The password for the key store file. Th [...]
"databaseSslMode": { "kind": "parameter", "displayName": "Database Ssl Mode", "group": "mysql", "label": "consumer,mysql", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "disabled", "configurationClass": "org.apache.camel.component.debezium.configuration.MySqlConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Whether to use an encrypted connecti [...]
- "databaseSslTruststore": { "kind": "parameter", "displayName": "Database Ssl Truststore", "group": "mysql", "label": "consumer,mysql", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.MySqlConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Location of the Java truststore file containing the [...]
- "databaseSslTruststorePassword": { "kind": "parameter", "displayName": "Database Ssl Truststore Password", "group": "mysql", "label": "consumer,mysql", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.MySqlConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Password to unlock the keystore fil [...]
+ "databaseSslTruststore": { "kind": "parameter", "displayName": "Database Ssl Truststore", "group": "mysql", "label": "consumer,mysql", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.MySqlConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The location of the trust store file for the server [...]
+ "databaseSslTruststorePassword": { "kind": "parameter", "displayName": "Database Ssl Truststore Password", "group": "mysql", "label": "consumer,mysql", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.MySqlConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The password for the trust store fi [...]
"databaseUser": { "kind": "parameter", "displayName": "Database User", "group": "mysql", "label": "consumer,mysql", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.MySqlConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Name of the database user to be used when connecting to the database." },
"datatypePropagateSourceType": { "kind": "parameter", "displayName": "Datatype Propagate Source Type", "group": "mysql", "label": "consumer,mysql", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.MySqlConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "A comma-separated list of regular expre [...]
"decimalHandlingMode": { "kind": "parameter", "displayName": "Decimal Handling Mode", "group": "mysql", "label": "consumer,mysql", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "precise", "configurationClass": "org.apache.camel.component.debezium.configuration.MySqlConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Specify how DECIMAL and NUMER [...]
@@ -210,8 +213,9 @@
"queryFetchSize": { "kind": "parameter", "displayName": "Query Fetch Size", "group": "mysql", "label": "consumer,mysql", "required": false, "type": "integer", "javaType": "int", "deprecated": false, "autowired": false, "secret": false, "defaultValue": 0, "configurationClass": "org.apache.camel.component.debezium.configuration.MySqlConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The maximum number of records that should be loaded into me [...]
"retriableRestartConnectorWaitMs": { "kind": "parameter", "displayName": "Retriable Restart Connector Wait Ms", "group": "mysql", "label": "consumer,mysql", "required": false, "type": "duration", "javaType": "long", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "10s", "configurationClass": "org.apache.camel.component.debezium.configuration.MySqlConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Time to wait befo [...]
"sanitizeFieldNames": { "kind": "parameter", "displayName": "Sanitize Field Names", "group": "mysql", "label": "consumer,mysql", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": false, "configurationClass": "org.apache.camel.component.debezium.configuration.MySqlConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Whether field names will be sanitized to Av [...]
+ "schemaNameAdjustmentMode": { "kind": "parameter", "displayName": "Schema Name Adjustment Mode", "group": "mysql", "label": "consumer,mysql", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "avro", "configurationClass": "org.apache.camel.component.debezium.configuration.MySqlConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Specify how schema na [...]
"signalDataCollection": { "kind": "parameter", "displayName": "Signal Data Collection", "group": "mysql", "label": "consumer,mysql", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.MySqlConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The name of the data collection that is used to send s [...]
- "skippedOperations": { "kind": "parameter", "displayName": "Skipped Operations", "group": "mysql", "label": "consumer,mysql", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.MySqlConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The comma-separated list of operations to skip during streami [...]
+ "skippedOperations": { "kind": "parameter", "displayName": "Skipped Operations", "group": "mysql", "label": "consumer,mysql", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.MySqlConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The comma-separated list of operations to skip during streami [...]
"snapshotDelayMs": { "kind": "parameter", "displayName": "Snapshot Delay Ms", "group": "mysql", "label": "consumer,mysql", "required": false, "type": "duration", "javaType": "long", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "0ms", "configurationClass": "org.apache.camel.component.debezium.configuration.MySqlConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "A delay period before a snapshot will begin, given [...]
"snapshotFetchSize": { "kind": "parameter", "displayName": "Snapshot Fetch Size", "group": "mysql", "label": "consumer,mysql", "required": false, "type": "integer", "javaType": "int", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.MySqlConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The maximum number of records that should be loaded into memory while pe [...]
"snapshotIncludeCollectionList": { "kind": "parameter", "displayName": "Snapshot Include Collection List", "group": "mysql", "label": "consumer,mysql", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.MySqlConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "this setting must be set to specify [...]
diff --git a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/debezium-oracle.json b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/debezium-oracle.json
index 043ccffc23b..2d433b0e5f6 100644
--- a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/debezium-oracle.json
+++ b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/debezium-oracle.json
@@ -48,6 +48,7 @@
"databaseHistory": { "kind": "property", "displayName": "Database History", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "io.debezium.relational.history.KafkaDatabaseHistory", "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "descrip [...]
"databaseHistoryFileFilename": { "kind": "property", "displayName": "Database History File Filename", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The path to the file that will be use [...]
"databaseHistoryKafkaBootstrapServers": { "kind": "property", "displayName": "Database History Kafka Bootstrap Servers", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "A list of host\/po [...]
+ "databaseHistoryKafkaQueryTimeoutMs": { "kind": "property", "displayName": "Database History Kafka Query Timeout Ms", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "duration", "javaType": "long", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "3s", "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The numbe [...]
"databaseHistoryKafkaRecoveryAttempts": { "kind": "property", "displayName": "Database History Kafka Recovery Attempts", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "integer", "javaType": "int", "deprecated": false, "autowired": false, "secret": false, "defaultValue": 100, "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The numbe [...]
"databaseHistoryKafkaRecoveryPollIntervalMs": { "kind": "property", "displayName": "Database History Kafka Recovery Poll Interval Ms", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "duration", "javaType": "int", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "100ms", "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "descr [...]
"databaseHistoryKafkaTopic": { "kind": "property", "displayName": "Database History Kafka Topic", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The name of the topic for the database sc [...]
@@ -104,8 +105,9 @@
"racNodes": { "kind": "property", "displayName": "Rac Nodes", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "A comma-separated list of RAC node hostnames or ip addresses" },
"retriableRestartConnectorWaitMs": { "kind": "property", "displayName": "Retriable Restart Connector Wait Ms", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "duration", "javaType": "long", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "10s", "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Time to wait be [...]
"sanitizeFieldNames": { "kind": "property", "displayName": "Sanitize Field Names", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": false, "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Whether field names will be sanitized to [...]
+ "schemaNameAdjustmentMode": { "kind": "property", "displayName": "Schema Name Adjustment Mode", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "avro", "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Specify how schema [...]
"signalDataCollection": { "kind": "property", "displayName": "Signal Data Collection", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The name of the data collection that is used to send [...]
- "skippedOperations": { "kind": "property", "displayName": "Skipped Operations", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The comma-separated list of operations to skip during strea [...]
+ "skippedOperations": { "kind": "property", "displayName": "Skipped Operations", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The comma-separated list of operations to skip during strea [...]
"snapshotDelayMs": { "kind": "property", "displayName": "Snapshot Delay Ms", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "duration", "javaType": "long", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "0ms", "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "A delay period before a snapshot will begin, give [...]
"snapshotEnhancePredicateScn": { "kind": "property", "displayName": "Snapshot Enhance Predicate Scn", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "A token to replace on snapshot predic [...]
"snapshotFetchSize": { "kind": "property", "displayName": "Snapshot Fetch Size", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "integer", "javaType": "int", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The maximum number of records that should be loaded into memory while [...]
@@ -162,6 +164,7 @@
"databaseHistory": { "kind": "parameter", "displayName": "Database History", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "io.debezium.relational.history.KafkaDatabaseHistory", "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "descri [...]
"databaseHistoryFileFilename": { "kind": "parameter", "displayName": "Database History File Filename", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The path to the file that will be us [...]
"databaseHistoryKafkaBootstrapServers": { "kind": "parameter", "displayName": "Database History Kafka Bootstrap Servers", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "A list of host\/p [...]
+ "databaseHistoryKafkaQueryTimeoutMs": { "kind": "parameter", "displayName": "Database History Kafka Query Timeout Ms", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "duration", "javaType": "long", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "3s", "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The numb [...]
"databaseHistoryKafkaRecoveryAttempts": { "kind": "parameter", "displayName": "Database History Kafka Recovery Attempts", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "integer", "javaType": "int", "deprecated": false, "autowired": false, "secret": false, "defaultValue": 100, "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The numb [...]
"databaseHistoryKafkaRecoveryPollIntervalMs": { "kind": "parameter", "displayName": "Database History Kafka Recovery Poll Interval Ms", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "duration", "javaType": "int", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "100ms", "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "desc [...]
"databaseHistoryKafkaTopic": { "kind": "parameter", "displayName": "Database History Kafka Topic", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The name of the topic for the database s [...]
@@ -218,8 +221,9 @@
"racNodes": { "kind": "parameter", "displayName": "Rac Nodes", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "A comma-separated list of RAC node hostnames or ip addresses" },
"retriableRestartConnectorWaitMs": { "kind": "parameter", "displayName": "Retriable Restart Connector Wait Ms", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "duration", "javaType": "long", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "10s", "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Time to wait b [...]
"sanitizeFieldNames": { "kind": "parameter", "displayName": "Sanitize Field Names", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": false, "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Whether field names will be sanitized to [...]
+ "schemaNameAdjustmentMode": { "kind": "parameter", "displayName": "Schema Name Adjustment Mode", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "avro", "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Specify how schema [...]
"signalDataCollection": { "kind": "parameter", "displayName": "Signal Data Collection", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The name of the data collection that is used to sen [...]
- "skippedOperations": { "kind": "parameter", "displayName": "Skipped Operations", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The comma-separated list of operations to skip during stre [...]
+ "skippedOperations": { "kind": "parameter", "displayName": "Skipped Operations", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The comma-separated list of operations to skip during stre [...]
"snapshotDelayMs": { "kind": "parameter", "displayName": "Snapshot Delay Ms", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "duration", "javaType": "long", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "0ms", "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "A delay period before a snapshot will begin, giv [...]
"snapshotEnhancePredicateScn": { "kind": "parameter", "displayName": "Snapshot Enhance Predicate Scn", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "A token to replace on snapshot predi [...]
"snapshotFetchSize": { "kind": "parameter", "displayName": "Snapshot Fetch Size", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "integer", "javaType": "int", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The maximum number of records that should be loaded into memory while [...]
diff --git a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/debezium-postgres.json b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/debezium-postgres.json
index a7d5078f5e6..0c4951ec650 100644
--- a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/debezium-postgres.json
+++ b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/debezium-postgres.json
@@ -75,7 +75,7 @@
"messageKeyColumns": { "kind": "property", "displayName": "Message Key Columns", "group": "postgres", "label": "consumer,postgres", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.PostgresConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "A semicolon-separated list of expressions that match [...]
"messagePrefixExcludeList": { "kind": "property", "displayName": "Message Prefix Exclude List", "group": "postgres", "label": "consumer,postgres", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.PostgresConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "A comma-separated list of regular exp [...]
"messagePrefixIncludeList": { "kind": "property", "displayName": "Message Prefix Include List", "group": "postgres", "label": "consumer,postgres", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.PostgresConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "A comma-separated list of regular exp [...]
- "pluginName": { "kind": "property", "displayName": "Plugin Name", "group": "postgres", "label": "consumer,postgres", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "decoderbufs", "configurationClass": "org.apache.camel.component.debezium.configuration.PostgresConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The name of the Postgres logical dec [...]
+ "pluginName": { "kind": "property", "displayName": "Plugin Name", "group": "postgres", "label": "consumer,postgres", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "decoderbufs", "configurationClass": "org.apache.camel.component.debezium.configuration.PostgresConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The name of the Postgres logical dec [...]
"pollIntervalMs": { "kind": "property", "displayName": "Poll Interval Ms", "group": "postgres", "label": "consumer,postgres", "required": false, "type": "duration", "javaType": "long", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "500ms", "configurationClass": "org.apache.camel.component.debezium.configuration.PostgresConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Time to wait for new change events to appea [...]
"provideTransactionMetadata": { "kind": "property", "displayName": "Provide Transaction Metadata", "group": "postgres", "label": "consumer,postgres", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": false, "configurationClass": "org.apache.camel.component.debezium.configuration.PostgresConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Enables transaction [...]
"publicationAutocreateMode": { "kind": "property", "displayName": "Publication Autocreate Mode", "group": "postgres", "label": "consumer,postgres", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "all_tables", "configurationClass": "org.apache.camel.component.debezium.configuration.PostgresConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Applie [...]
@@ -86,10 +86,11 @@
"schemaBlacklist": { "kind": "property", "displayName": "Schema Blacklist", "group": "postgres", "label": "consumer,postgres", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.PostgresConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The schemas for which events must not be captured (deprec [...]
"schemaExcludeList": { "kind": "property", "displayName": "Schema Exclude List", "group": "postgres", "label": "consumer,postgres", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.PostgresConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The schemas for which events must not be captured" },
"schemaIncludeList": { "kind": "property", "displayName": "Schema Include List", "group": "postgres", "label": "consumer,postgres", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.PostgresConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The schemas for which events should be captured" },
+ "schemaNameAdjustmentMode": { "kind": "property", "displayName": "Schema Name Adjustment Mode", "group": "postgres", "label": "consumer,postgres", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "avro", "configurationClass": "org.apache.camel.component.debezium.configuration.PostgresConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Specify how s [...]
"schemaRefreshMode": { "kind": "property", "displayName": "Schema Refresh Mode", "group": "postgres", "label": "consumer,postgres", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "columns_diff", "configurationClass": "org.apache.camel.component.debezium.configuration.PostgresConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Specify the conditio [...]
"schemaWhitelist": { "kind": "property", "displayName": "Schema Whitelist", "group": "postgres", "label": "consumer,postgres", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.PostgresConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The schemas for which events should be captured (deprecat [...]
"signalDataCollection": { "kind": "property", "displayName": "Signal Data Collection", "group": "postgres", "label": "consumer,postgres", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.PostgresConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The name of the data collection that is used t [...]
- "skippedOperations": { "kind": "property", "displayName": "Skipped Operations", "group": "postgres", "label": "consumer,postgres", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.PostgresConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The comma-separated list of operations to skip during [...]
+ "skippedOperations": { "kind": "property", "displayName": "Skipped Operations", "group": "postgres", "label": "consumer,postgres", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "t", "configurationClass": "org.apache.camel.component.debezium.configuration.PostgresConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The comma-separated list of oper [...]
"slotDropOnStop": { "kind": "property", "displayName": "Slot Drop On Stop", "group": "postgres", "label": "consumer,postgres", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": false, "configurationClass": "org.apache.camel.component.debezium.configuration.PostgresConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Whether or not to drop the logical replica [...]
"slotMaxRetries": { "kind": "property", "displayName": "Slot Max Retries", "group": "postgres", "label": "consumer,postgres", "required": false, "type": "integer", "javaType": "int", "deprecated": false, "autowired": false, "secret": false, "defaultValue": 6, "configurationClass": "org.apache.camel.component.debezium.configuration.PostgresConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "How many times to retry connecting to a replication [...]
"slotName": { "kind": "property", "displayName": "Slot Name", "group": "postgres", "label": "consumer,postgres", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "debezium", "configurationClass": "org.apache.camel.component.debezium.configuration.PostgresConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The name of the Postgres logical decoding s [...]
@@ -113,7 +114,6 @@
"timePrecisionMode": { "kind": "property", "displayName": "Time Precision Mode", "group": "postgres", "label": "consumer,postgres", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "adaptive", "configurationClass": "org.apache.camel.component.debezium.configuration.PostgresConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Time, date, and timestam [...]
"tombstonesOnDelete": { "kind": "property", "displayName": "Tombstones On Delete", "group": "postgres", "label": "consumer,postgres", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": false, "configurationClass": "org.apache.camel.component.debezium.configuration.PostgresConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Whether delete operations should be [...]
"transactionTopic": { "kind": "property", "displayName": "Transaction Topic", "group": "postgres", "label": "consumer,postgres", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "${database.server.name}.transaction", "configurationClass": "org.apache.camel.component.debezium.configuration.PostgresConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": " [...]
- "truncateHandlingMode": { "kind": "property", "displayName": "Truncate Handling Mode", "group": "postgres", "label": "consumer,postgres", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "skip", "configurationClass": "org.apache.camel.component.debezium.configuration.PostgresConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Specify how TRUNCATE o [...]
"unavailableValuePlaceholder": { "kind": "property", "displayName": "Unavailable Value Placeholder", "group": "postgres", "label": "consumer,postgres", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "__debezium_unavailable_value", "configurationClass": "org.apache.camel.component.debezium.configuration.PostgresConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", [...]
"xminFetchIntervalMs": { "kind": "property", "displayName": "Xmin Fetch Interval Ms", "group": "postgres", "label": "consumer,postgres", "required": false, "type": "duration", "javaType": "long", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "0ms", "configurationClass": "org.apache.camel.component.debezium.configuration.PostgresConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Specify how often (in ms) the xmin [...]
},
@@ -181,7 +181,7 @@
"messageKeyColumns": { "kind": "parameter", "displayName": "Message Key Columns", "group": "postgres", "label": "consumer,postgres", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.PostgresConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "A semicolon-separated list of expressions that matc [...]
"messagePrefixExcludeList": { "kind": "parameter", "displayName": "Message Prefix Exclude List", "group": "postgres", "label": "consumer,postgres", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.PostgresConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "A comma-separated list of regular ex [...]
"messagePrefixIncludeList": { "kind": "parameter", "displayName": "Message Prefix Include List", "group": "postgres", "label": "consumer,postgres", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.PostgresConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "A comma-separated list of regular ex [...]
- "pluginName": { "kind": "parameter", "displayName": "Plugin Name", "group": "postgres", "label": "consumer,postgres", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "decoderbufs", "configurationClass": "org.apache.camel.component.debezium.configuration.PostgresConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The name of the Postgres logical de [...]
+ "pluginName": { "kind": "parameter", "displayName": "Plugin Name", "group": "postgres", "label": "consumer,postgres", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "decoderbufs", "configurationClass": "org.apache.camel.component.debezium.configuration.PostgresConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The name of the Postgres logical de [...]
"pollIntervalMs": { "kind": "parameter", "displayName": "Poll Interval Ms", "group": "postgres", "label": "consumer,postgres", "required": false, "type": "duration", "javaType": "long", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "500ms", "configurationClass": "org.apache.camel.component.debezium.configuration.PostgresConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Time to wait for new change events to appe [...]
"provideTransactionMetadata": { "kind": "parameter", "displayName": "Provide Transaction Metadata", "group": "postgres", "label": "consumer,postgres", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": false, "configurationClass": "org.apache.camel.component.debezium.configuration.PostgresConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Enables transactio [...]
"publicationAutocreateMode": { "kind": "parameter", "displayName": "Publication Autocreate Mode", "group": "postgres", "label": "consumer,postgres", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "all_tables", "configurationClass": "org.apache.camel.component.debezium.configuration.PostgresConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Appli [...]
@@ -192,10 +192,11 @@
"schemaBlacklist": { "kind": "parameter", "displayName": "Schema Blacklist", "group": "postgres", "label": "consumer,postgres", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.PostgresConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The schemas for which events must not be captured (depre [...]
"schemaExcludeList": { "kind": "parameter", "displayName": "Schema Exclude List", "group": "postgres", "label": "consumer,postgres", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.PostgresConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The schemas for which events must not be captured" },
"schemaIncludeList": { "kind": "parameter", "displayName": "Schema Include List", "group": "postgres", "label": "consumer,postgres", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.PostgresConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The schemas for which events should be captured" },
+ "schemaNameAdjustmentMode": { "kind": "parameter", "displayName": "Schema Name Adjustment Mode", "group": "postgres", "label": "consumer,postgres", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "avro", "configurationClass": "org.apache.camel.component.debezium.configuration.PostgresConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Specify how [...]
"schemaRefreshMode": { "kind": "parameter", "displayName": "Schema Refresh Mode", "group": "postgres", "label": "consumer,postgres", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "columns_diff", "configurationClass": "org.apache.camel.component.debezium.configuration.PostgresConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Specify the conditi [...]
"schemaWhitelist": { "kind": "parameter", "displayName": "Schema Whitelist", "group": "postgres", "label": "consumer,postgres", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.PostgresConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The schemas for which events should be captured (depreca [...]
"signalDataCollection": { "kind": "parameter", "displayName": "Signal Data Collection", "group": "postgres", "label": "consumer,postgres", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.PostgresConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The name of the data collection that is used [...]
- "skippedOperations": { "kind": "parameter", "displayName": "Skipped Operations", "group": "postgres", "label": "consumer,postgres", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.PostgresConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The comma-separated list of operations to skip durin [...]
+ "skippedOperations": { "kind": "parameter", "displayName": "Skipped Operations", "group": "postgres", "label": "consumer,postgres", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "t", "configurationClass": "org.apache.camel.component.debezium.configuration.PostgresConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The comma-separated list of ope [...]
"slotDropOnStop": { "kind": "parameter", "displayName": "Slot Drop On Stop", "group": "postgres", "label": "consumer,postgres", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": false, "configurationClass": "org.apache.camel.component.debezium.configuration.PostgresConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Whether or not to drop the logical replic [...]
"slotMaxRetries": { "kind": "parameter", "displayName": "Slot Max Retries", "group": "postgres", "label": "consumer,postgres", "required": false, "type": "integer", "javaType": "int", "deprecated": false, "autowired": false, "secret": false, "defaultValue": 6, "configurationClass": "org.apache.camel.component.debezium.configuration.PostgresConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "How many times to retry connecting to a replicatio [...]
"slotName": { "kind": "parameter", "displayName": "Slot Name", "group": "postgres", "label": "consumer,postgres", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "debezium", "configurationClass": "org.apache.camel.component.debezium.configuration.PostgresConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The name of the Postgres logical decoding [...]
@@ -219,7 +220,6 @@
"timePrecisionMode": { "kind": "parameter", "displayName": "Time Precision Mode", "group": "postgres", "label": "consumer,postgres", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "adaptive", "configurationClass": "org.apache.camel.component.debezium.configuration.PostgresConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Time, date, and timesta [...]
"tombstonesOnDelete": { "kind": "parameter", "displayName": "Tombstones On Delete", "group": "postgres", "label": "consumer,postgres", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": false, "configurationClass": "org.apache.camel.component.debezium.configuration.PostgresConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Whether delete operations should b [...]
"transactionTopic": { "kind": "parameter", "displayName": "Transaction Topic", "group": "postgres", "label": "consumer,postgres", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "${database.server.name}.transaction", "configurationClass": "org.apache.camel.component.debezium.configuration.PostgresConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": [...]
- "truncateHandlingMode": { "kind": "parameter", "displayName": "Truncate Handling Mode", "group": "postgres", "label": "consumer,postgres", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "skip", "configurationClass": "org.apache.camel.component.debezium.configuration.PostgresConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Specify how TRUNCATE [...]
"unavailableValuePlaceholder": { "kind": "parameter", "displayName": "Unavailable Value Placeholder", "group": "postgres", "label": "consumer,postgres", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "__debezium_unavailable_value", "configurationClass": "org.apache.camel.component.debezium.configuration.PostgresConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", [...]
"xminFetchIntervalMs": { "kind": "parameter", "displayName": "Xmin Fetch Interval Ms", "group": "postgres", "label": "consumer,postgres", "required": false, "type": "duration", "javaType": "long", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "0ms", "configurationClass": "org.apache.camel.component.debezium.configuration.PostgresConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Specify how often (in ms) the xmi [...]
}
diff --git a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/debezium-sqlserver.json b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/debezium-sqlserver.json
index 22831b9a69b..22334d1f341 100644
--- a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/debezium-sqlserver.json
+++ b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/debezium-sqlserver.json
@@ -47,6 +47,7 @@
"databaseHistory": { "kind": "property", "displayName": "Database History", "group": "sqlserver", "label": "consumer,sqlserver", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "io.debezium.relational.history.FileDatabaseHistory", "configurationClass": "org.apache.camel.component.debezium.configuration.SqlServerConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", [...]
"databaseHistoryFileFilename": { "kind": "property", "displayName": "Database History File Filename", "group": "sqlserver", "label": "consumer,sqlserver", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.SqlServerConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The path to the file that wi [...]
"databaseHistoryKafkaBootstrapServers": { "kind": "property", "displayName": "Database History Kafka Bootstrap Servers", "group": "sqlserver", "label": "consumer,sqlserver", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.SqlServerConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "A list of [...]
+ "databaseHistoryKafkaQueryTimeoutMs": { "kind": "property", "displayName": "Database History Kafka Query Timeout Ms", "group": "sqlserver", "label": "consumer,sqlserver", "required": false, "type": "duration", "javaType": "long", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "3s", "configurationClass": "org.apache.camel.component.debezium.configuration.SqlServerConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": " [...]
"databaseHistoryKafkaRecoveryAttempts": { "kind": "property", "displayName": "Database History Kafka Recovery Attempts", "group": "sqlserver", "label": "consumer,sqlserver", "required": false, "type": "integer", "javaType": "int", "deprecated": false, "autowired": false, "secret": false, "defaultValue": 100, "configurationClass": "org.apache.camel.component.debezium.configuration.SqlServerConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": " [...]
"databaseHistoryKafkaRecoveryPollIntervalMs": { "kind": "property", "displayName": "Database History Kafka Recovery Poll Interval Ms", "group": "sqlserver", "label": "consumer,sqlserver", "required": false, "type": "duration", "javaType": "int", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "100ms", "configurationClass": "org.apache.camel.component.debezium.configuration.SqlServerConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration [...]
"databaseHistoryKafkaTopic": { "kind": "property", "displayName": "Database History Kafka Topic", "group": "sqlserver", "label": "consumer,sqlserver", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.SqlServerConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The name of the topic for the da [...]
@@ -81,8 +82,9 @@
"queryFetchSize": { "kind": "property", "displayName": "Query Fetch Size", "group": "sqlserver", "label": "consumer,sqlserver", "required": false, "type": "integer", "javaType": "int", "deprecated": false, "autowired": false, "secret": false, "defaultValue": 0, "configurationClass": "org.apache.camel.component.debezium.configuration.SqlServerConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The maximum number of records that should be loa [...]
"retriableRestartConnectorWaitMs": { "kind": "property", "displayName": "Retriable Restart Connector Wait Ms", "group": "sqlserver", "label": "consumer,sqlserver", "required": false, "type": "duration", "javaType": "long", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "10s", "configurationClass": "org.apache.camel.component.debezium.configuration.SqlServerConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Time t [...]
"sanitizeFieldNames": { "kind": "property", "displayName": "Sanitize Field Names", "group": "sqlserver", "label": "consumer,sqlserver", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": false, "configurationClass": "org.apache.camel.component.debezium.configuration.SqlServerConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Whether field names will be sani [...]
+ "schemaNameAdjustmentMode": { "kind": "property", "displayName": "Schema Name Adjustment Mode", "group": "sqlserver", "label": "consumer,sqlserver", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "avro", "configurationClass": "org.apache.camel.component.debezium.configuration.SqlServerConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Specify ho [...]
"signalDataCollection": { "kind": "property", "displayName": "Signal Data Collection", "group": "sqlserver", "label": "consumer,sqlserver", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.SqlServerConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The name of the data collection that is use [...]
- "skippedOperations": { "kind": "property", "displayName": "Skipped Operations", "group": "sqlserver", "label": "consumer,sqlserver", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.SqlServerConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The comma-separated list of operations to skip dur [...]
+ "skippedOperations": { "kind": "property", "displayName": "Skipped Operations", "group": "sqlserver", "label": "consumer,sqlserver", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.SqlServerConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The comma-separated list of operations to skip dur [...]
"snapshotDelayMs": { "kind": "property", "displayName": "Snapshot Delay Ms", "group": "sqlserver", "label": "consumer,sqlserver", "required": false, "type": "duration", "javaType": "long", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "0ms", "configurationClass": "org.apache.camel.component.debezium.configuration.SqlServerConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "A delay period before a snapshot will be [...]
"snapshotFetchSize": { "kind": "property", "displayName": "Snapshot Fetch Size", "group": "sqlserver", "label": "consumer,sqlserver", "required": false, "type": "integer", "javaType": "int", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.SqlServerConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The maximum number of records that should be loaded into memo [...]
"snapshotIncludeCollectionList": { "kind": "property", "displayName": "Snapshot Include Collection List", "group": "sqlserver", "label": "consumer,sqlserver", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.SqlServerConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "this setting must be set [...]
@@ -138,6 +140,7 @@
"databaseHistory": { "kind": "parameter", "displayName": "Database History", "group": "sqlserver", "label": "consumer,sqlserver", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "io.debezium.relational.history.FileDatabaseHistory", "configurationClass": "org.apache.camel.component.debezium.configuration.SqlServerConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", [...]
"databaseHistoryFileFilename": { "kind": "parameter", "displayName": "Database History File Filename", "group": "sqlserver", "label": "consumer,sqlserver", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.SqlServerConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The path to the file that w [...]
"databaseHistoryKafkaBootstrapServers": { "kind": "parameter", "displayName": "Database History Kafka Bootstrap Servers", "group": "sqlserver", "label": "consumer,sqlserver", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.SqlServerConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "A list o [...]
+ "databaseHistoryKafkaQueryTimeoutMs": { "kind": "parameter", "displayName": "Database History Kafka Query Timeout Ms", "group": "sqlserver", "label": "consumer,sqlserver", "required": false, "type": "duration", "javaType": "long", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "3s", "configurationClass": "org.apache.camel.component.debezium.configuration.SqlServerConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": [...]
"databaseHistoryKafkaRecoveryAttempts": { "kind": "parameter", "displayName": "Database History Kafka Recovery Attempts", "group": "sqlserver", "label": "consumer,sqlserver", "required": false, "type": "integer", "javaType": "int", "deprecated": false, "autowired": false, "secret": false, "defaultValue": 100, "configurationClass": "org.apache.camel.component.debezium.configuration.SqlServerConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": [...]
"databaseHistoryKafkaRecoveryPollIntervalMs": { "kind": "parameter", "displayName": "Database History Kafka Recovery Poll Interval Ms", "group": "sqlserver", "label": "consumer,sqlserver", "required": false, "type": "duration", "javaType": "int", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "100ms", "configurationClass": "org.apache.camel.component.debezium.configuration.SqlServerConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuratio [...]
"databaseHistoryKafkaTopic": { "kind": "parameter", "displayName": "Database History Kafka Topic", "group": "sqlserver", "label": "consumer,sqlserver", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.SqlServerConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The name of the topic for the d [...]
@@ -172,8 +175,9 @@
"queryFetchSize": { "kind": "parameter", "displayName": "Query Fetch Size", "group": "sqlserver", "label": "consumer,sqlserver", "required": false, "type": "integer", "javaType": "int", "deprecated": false, "autowired": false, "secret": false, "defaultValue": 0, "configurationClass": "org.apache.camel.component.debezium.configuration.SqlServerConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The maximum number of records that should be lo [...]
"retriableRestartConnectorWaitMs": { "kind": "parameter", "displayName": "Retriable Restart Connector Wait Ms", "group": "sqlserver", "label": "consumer,sqlserver", "required": false, "type": "duration", "javaType": "long", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "10s", "configurationClass": "org.apache.camel.component.debezium.configuration.SqlServerConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Time [...]
"sanitizeFieldNames": { "kind": "parameter", "displayName": "Sanitize Field Names", "group": "sqlserver", "label": "consumer,sqlserver", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": false, "configurationClass": "org.apache.camel.component.debezium.configuration.SqlServerConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Whether field names will be san [...]
+ "schemaNameAdjustmentMode": { "kind": "parameter", "displayName": "Schema Name Adjustment Mode", "group": "sqlserver", "label": "consumer,sqlserver", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "avro", "configurationClass": "org.apache.camel.component.debezium.configuration.SqlServerConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Specify h [...]
"signalDataCollection": { "kind": "parameter", "displayName": "Signal Data Collection", "group": "sqlserver", "label": "consumer,sqlserver", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.SqlServerConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The name of the data collection that is us [...]
- "skippedOperations": { "kind": "parameter", "displayName": "Skipped Operations", "group": "sqlserver", "label": "consumer,sqlserver", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.SqlServerConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The comma-separated list of operations to skip du [...]
+ "skippedOperations": { "kind": "parameter", "displayName": "Skipped Operations", "group": "sqlserver", "label": "consumer,sqlserver", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.SqlServerConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The comma-separated list of operations to skip du [...]
"snapshotDelayMs": { "kind": "parameter", "displayName": "Snapshot Delay Ms", "group": "sqlserver", "label": "consumer,sqlserver", "required": false, "type": "duration", "javaType": "long", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "0ms", "configurationClass": "org.apache.camel.component.debezium.configuration.SqlServerConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "A delay period before a snapshot will b [...]
"snapshotFetchSize": { "kind": "parameter", "displayName": "Snapshot Fetch Size", "group": "sqlserver", "label": "consumer,sqlserver", "required": false, "type": "integer", "javaType": "int", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.SqlServerConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The maximum number of records that should be loaded into mem [...]
"snapshotIncludeCollectionList": { "kind": "parameter", "displayName": "Snapshot Include Collection List", "group": "sqlserver", "label": "consumer,sqlserver", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.SqlServerConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "this setting must be se [...]
diff --git a/components/camel-debezium/camel-debezium-mysql/src/generated/java/org/apache/camel/component/debezium/DebeziumMySqlComponentConfigurer.java b/components/camel-debezium/camel-debezium-mysql/src/generated/java/org/apache/camel/component/debezium/DebeziumMySqlComponentConfigurer.java
index cf68d1d81d3..1ea269abc88 100644
--- a/components/camel-debezium/camel-debezium-mysql/src/generated/java/org/apache/camel/component/debezium/DebeziumMySqlComponentConfigurer.java
+++ b/components/camel-debezium/camel-debezium-mysql/src/generated/java/org/apache/camel/component/debezium/DebeziumMySqlComponentConfigurer.java
@@ -1,9 +1,14 @@
/* Generated by camel build tools - do NOT edit this file! */
package org.apache.camel.component.debezium;
+import java.util.Map;
+
import org.apache.camel.CamelContext;
-import org.apache.camel.spi.GeneratedPropertyConfigurer;
+import org.apache.camel.spi.ExtendedPropertyConfigurerGetter;
import org.apache.camel.spi.PropertyConfigurerGetter;
+import org.apache.camel.spi.ConfigurerStrategy;
+import org.apache.camel.spi.GeneratedPropertyConfigurer;
+import org.apache.camel.util.CaseInsensitiveMap;
import org.apache.camel.support.component.PropertyConfigurerSupport;
/**
diff --git a/dsl/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/DebeziumDb2ComponentBuilderFactory.java b/dsl/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/DebeziumDb2ComponentBuilderFactory.java
index 0583129ef80..b9fa201c35d 100644
--- a/dsl/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/DebeziumDb2ComponentBuilderFactory.java
+++ b/dsl/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/DebeziumDb2ComponentBuilderFactory.java
@@ -332,6 +332,72 @@ public interface DebeziumDb2ComponentBuilderFactory {
doSetProperty("columnExcludeList", columnExcludeList);
return this;
}
+ /**
+ * Regular expressions matching columns to include in change events.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: db2
+ *
+ * @param columnIncludeList the value to set
+ * @return the dsl builder
+ */
+ default DebeziumDb2ComponentBuilder columnIncludeList(
+ java.lang.String columnIncludeList) {
+ doSetProperty("columnIncludeList", columnIncludeList);
+ return this;
+ }
+ /**
+ * A comma-separated list of regular expressions matching
+ * fully-qualified names of columns that adds the columns original type
+ * and original length as parameters to the corresponding field schemas
+ * in the emitted change records.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: db2
+ *
+ * @param columnPropagateSourceType the value to set
+ * @return the dsl builder
+ */
+ default DebeziumDb2ComponentBuilder columnPropagateSourceType(
+ java.lang.String columnPropagateSourceType) {
+ doSetProperty("columnPropagateSourceType", columnPropagateSourceType);
+ return this;
+ }
+ /**
+ * Regular expressions matching columns to include in change events
+ * (deprecated, use column.include.list instead).
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: db2
+ *
+ * @param columnWhitelist the value to set
+ * @return the dsl builder
+ */
+ default DebeziumDb2ComponentBuilder columnWhitelist(
+ java.lang.String columnWhitelist) {
+ doSetProperty("columnWhitelist", columnWhitelist);
+ return this;
+ }
+ /**
+ * Optional list of custom converters that would be used instead of
+ * default ones. The converters are defined using '.type' config option
+ * and configured using options '.'.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: db2
+ *
+ * @param converters the value to set
+ * @return the dsl builder
+ */
+ default DebeziumDb2ComponentBuilder converters(
+ java.lang.String converters) {
+ doSetProperty("converters", converters);
+ return this;
+ }
/**
* The name of the database from which the connector should capture
* changes.
@@ -401,6 +467,23 @@ public interface DebeziumDb2ComponentBuilderFactory {
doSetProperty("databaseHistoryKafkaBootstrapServers", databaseHistoryKafkaBootstrapServers);
return this;
}
+ /**
+ * The number of milliseconds to wait while fetching cluster information
+ * using Kafka admin client.
+ *
+ * The option is a: <code>long</code> type.
+ *
+ * Default: 3s
+ * Group: db2
+ *
+ * @param databaseHistoryKafkaQueryTimeoutMs the value to set
+ * @return the dsl builder
+ */
+ default DebeziumDb2ComponentBuilder databaseHistoryKafkaQueryTimeoutMs(
+ long databaseHistoryKafkaQueryTimeoutMs) {
+ doSetProperty("databaseHistoryKafkaQueryTimeoutMs", databaseHistoryKafkaQueryTimeoutMs);
+ return this;
+ }
/**
* The number of attempts in a row that no data are returned from Kafka
* before recover completes. The maximum amount of time to wait after
@@ -452,6 +535,64 @@ public interface DebeziumDb2ComponentBuilderFactory {
doSetProperty("databaseHistoryKafkaTopic", databaseHistoryKafkaTopic);
return this;
}
+ /**
+ * Controls the action Debezium will take when it meets a DDL statement
+ * in binlog, that it cannot parse.By default the connector will stop
+ * operating but by changing the setting it can ignore the statements
+ * which it cannot parse. If skipping is enabled then Debezium can miss
+ * metadata changes.
+ *
+ * The option is a: <code>boolean</code> type.
+ *
+ * Default: false
+ * Group: db2
+ *
+ * @param databaseHistorySkipUnparseableDdl the value to set
+ * @return the dsl builder
+ */
+ default DebeziumDb2ComponentBuilder databaseHistorySkipUnparseableDdl(
+ boolean databaseHistorySkipUnparseableDdl) {
+ doSetProperty("databaseHistorySkipUnparseableDdl", databaseHistorySkipUnparseableDdl);
+ return this;
+ }
+ /**
+ * Controls what DDL will Debezium store in database history. By default
+ * (false) Debezium will store all incoming DDL statements. If set to
+ * true, then only DDL that manipulates a captured table will be stored.
+ *
+ * The option is a: <code>boolean</code> type.
+ *
+ * Default: false
+ * Group: db2
+ *
+ * @param databaseHistoryStoreOnlyCapturedTablesDdl the value to set
+ * @return the dsl builder
+ */
+ default DebeziumDb2ComponentBuilder databaseHistoryStoreOnlyCapturedTablesDdl(
+ boolean databaseHistoryStoreOnlyCapturedTablesDdl) {
+ doSetProperty("databaseHistoryStoreOnlyCapturedTablesDdl", databaseHistoryStoreOnlyCapturedTablesDdl);
+ return this;
+ }
+ /**
+ * Controls what DDL will Debezium store in database history. By default
+ * (false) Debezium will store all incoming DDL statements. If set to
+ * true, then only DDL that manipulates a monitored table will be stored
+ * (deprecated, use database.history.store.only.captured.tables.ddl
+ * instead).
+ *
+ * The option is a: <code>boolean</code> type.
+ *
+ * Default: false
+ * Group: db2
+ *
+ * @param databaseHistoryStoreOnlyMonitoredTablesDdl the value to set
+ * @return the dsl builder
+ */
+ default DebeziumDb2ComponentBuilder databaseHistoryStoreOnlyMonitoredTablesDdl(
+ boolean databaseHistoryStoreOnlyMonitoredTablesDdl) {
+ doSetProperty("databaseHistoryStoreOnlyMonitoredTablesDdl", databaseHistoryStoreOnlyMonitoredTablesDdl);
+ return this;
+ }
/**
* Resolvable hostname or IP address of the database server.
*
@@ -531,6 +672,24 @@ public interface DebeziumDb2ComponentBuilderFactory {
doSetProperty("databaseUser", databaseUser);
return this;
}
+ /**
+ * A comma-separated list of regular expressions matching the
+ * database-specific data type names that adds the data type's original
+ * type and original length as parameters to the corresponding field
+ * schemas in the emitted change records.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: db2
+ *
+ * @param datatypePropagateSourceType the value to set
+ * @return the dsl builder
+ */
+ default DebeziumDb2ComponentBuilder datatypePropagateSourceType(
+ java.lang.String datatypePropagateSourceType) {
+ doSetProperty("datatypePropagateSourceType", datatypePropagateSourceType);
+ return this;
+ }
/**
* Specify how DECIMAL and NUMERIC columns should be represented in
* change events, including:'precise' (the default) uses
@@ -610,6 +769,43 @@ public interface DebeziumDb2ComponentBuilderFactory {
doSetProperty("heartbeatTopicsPrefix", heartbeatTopicsPrefix);
return this;
}
+ /**
+ * Whether the connector should publish changes in the database schema
+ * to a Kafka topic with the same name as the database server ID. Each
+ * schema change will be recorded using a key that contains the database
+ * name and whose value include logical description of the new schema
+ * and optionally the DDL statement(s).The default is 'true'. This is
+ * independent of how the connector internally records database history.
+ *
+ * The option is a: <code>boolean</code> type.
+ *
+ * Default: true
+ * Group: db2
+ *
+ * @param includeSchemaChanges the value to set
+ * @return the dsl builder
+ */
+ default DebeziumDb2ComponentBuilder includeSchemaChanges(
+ boolean includeSchemaChanges) {
+ doSetProperty("includeSchemaChanges", includeSchemaChanges);
+ return this;
+ }
+ /**
+ * The maximum size of chunk for incremental snapshotting.
+ *
+ * The option is a: <code>int</code> type.
+ *
+ * Default: 1024
+ * Group: db2
+ *
+ * @param incrementalSnapshotChunkSize the value to set
+ * @return the dsl builder
+ */
+ default DebeziumDb2ComponentBuilder incrementalSnapshotChunkSize(
+ int incrementalSnapshotChunkSize) {
+ doSetProperty("incrementalSnapshotChunkSize", incrementalSnapshotChunkSize);
+ return this;
+ }
/**
* Maximum size of each batch of source records. Defaults to 2048.
*
@@ -642,6 +838,47 @@ public interface DebeziumDb2ComponentBuilderFactory {
doSetProperty("maxQueueSize", maxQueueSize);
return this;
}
+ /**
+ * Maximum size of the queue in bytes for change events read from the
+ * database log but not yet recorded or forwarded. Defaults to 0. Mean
+ * the feature is not enabled.
+ *
+ * The option is a: <code>long</code> type.
+ *
+ * Default: 0
+ * Group: db2
+ *
+ * @param maxQueueSizeInBytes the value to set
+ * @return the dsl builder
+ */
+ default DebeziumDb2ComponentBuilder maxQueueSizeInBytes(
+ long maxQueueSizeInBytes) {
+ doSetProperty("maxQueueSizeInBytes", maxQueueSizeInBytes);
+ return this;
+ }
+ /**
+ * A semicolon-separated list of expressions that match fully-qualified
+ * tables and column(s) to be used as message key. Each expression must
+ * match the pattern ':',where the table names could be defined as
+ * (DB_NAME.TABLE_NAME) or (SCHEMA_NAME.TABLE_NAME), depending on the
+ * specific connector,and the key columns are a comma-separated list of
+ * columns representing the custom key. For any table without an
+ * explicit key configuration the table's primary key column(s) will be
+ * used as message key.Example:
+ * dbserver1.inventory.orderlines:orderId,orderLineId;dbserver1.inventory.orders:id.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: db2
+ *
+ * @param messageKeyColumns the value to set
+ * @return the dsl builder
+ */
+ default DebeziumDb2ComponentBuilder messageKeyColumns(
+ java.lang.String messageKeyColumns) {
+ doSetProperty("messageKeyColumns", messageKeyColumns);
+ return this;
+ }
/**
* Time to wait for new change events to appear after receiving no
* events, given in milliseconds. Defaults to 500 ms.
@@ -658,6 +895,124 @@ public interface DebeziumDb2ComponentBuilderFactory {
doSetProperty("pollIntervalMs", pollIntervalMs);
return this;
}
+ /**
+ * Enables transaction metadata extraction together with event counting.
+ *
+ * The option is a: <code>boolean</code> type.
+ *
+ * Default: false
+ * Group: db2
+ *
+ * @param provideTransactionMetadata the value to set
+ * @return the dsl builder
+ */
+ default DebeziumDb2ComponentBuilder provideTransactionMetadata(
+ boolean provideTransactionMetadata) {
+ doSetProperty("provideTransactionMetadata", provideTransactionMetadata);
+ return this;
+ }
+ /**
+ * The maximum number of records that should be loaded into memory while
+ * streaming. A value of 0 uses the default JDBC fetch size.
+ *
+ * The option is a: <code>int</code> type.
+ *
+ * Default: 0
+ * Group: db2
+ *
+ * @param queryFetchSize the value to set
+ * @return the dsl builder
+ */
+ default DebeziumDb2ComponentBuilder queryFetchSize(int queryFetchSize) {
+ doSetProperty("queryFetchSize", queryFetchSize);
+ return this;
+ }
+ /**
+ * Time to wait before restarting connector after retriable exception
+ * occurs. Defaults to 10000ms.
+ *
+ * The option is a: <code>long</code> type.
+ *
+ * Default: 10s
+ * Group: db2
+ *
+ * @param retriableRestartConnectorWaitMs the value to set
+ * @return the dsl builder
+ */
+ default DebeziumDb2ComponentBuilder retriableRestartConnectorWaitMs(
+ long retriableRestartConnectorWaitMs) {
+ doSetProperty("retriableRestartConnectorWaitMs", retriableRestartConnectorWaitMs);
+ return this;
+ }
+ /**
+ * Whether field names will be sanitized to Avro naming conventions.
+ *
+ * The option is a: <code>boolean</code> type.
+ *
+ * Default: false
+ * Group: db2
+ *
+ * @param sanitizeFieldNames the value to set
+ * @return the dsl builder
+ */
+ default DebeziumDb2ComponentBuilder sanitizeFieldNames(
+ boolean sanitizeFieldNames) {
+ doSetProperty("sanitizeFieldNames", sanitizeFieldNames);
+ return this;
+ }
+ /**
+ * Specify how schema names should be adjusted for compatibility with
+ * the message converter used by the connector, including:'avro'
+ * replaces the characters that cannot be used in the Avro type name
+ * with underscore (default)'none' does not apply any adjustment.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Default: avro
+ * Group: db2
+ *
+ * @param schemaNameAdjustmentMode the value to set
+ * @return the dsl builder
+ */
+ default DebeziumDb2ComponentBuilder schemaNameAdjustmentMode(
+ java.lang.String schemaNameAdjustmentMode) {
+ doSetProperty("schemaNameAdjustmentMode", schemaNameAdjustmentMode);
+ return this;
+ }
+ /**
+ * The name of the data collection that is used to send signals/commands
+ * to Debezium. Signaling is disabled when not set.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: db2
+ *
+ * @param signalDataCollection the value to set
+ * @return the dsl builder
+ */
+ default DebeziumDb2ComponentBuilder signalDataCollection(
+ java.lang.String signalDataCollection) {
+ doSetProperty("signalDataCollection", signalDataCollection);
+ return this;
+ }
+ /**
+ * The comma-separated list of operations to skip during streaming,
+ * defined as: 'c' for inserts/create; 'u' for updates; 'd' for deletes,
+ * 't' for truncates, and 'none' to indicate nothing skipped. By
+ * default, no operations will be skipped.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: db2
+ *
+ * @param skippedOperations the value to set
+ * @return the dsl builder
+ */
+ default DebeziumDb2ComponentBuilder skippedOperations(
+ java.lang.String skippedOperations) {
+ doSetProperty("skippedOperations", skippedOperations);
+ return this;
+ }
/**
* A delay period before a snapshot will begin, given in milliseconds.
* Defaults to 0 ms.
@@ -690,6 +1045,40 @@ public interface DebeziumDb2ComponentBuilderFactory {
doSetProperty("snapshotFetchSize", snapshotFetchSize);
return this;
}
+ /**
+ * this setting must be set to specify a list of tables/collections
+ * whose snapshot must be taken on creating or restarting the connector.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: db2
+ *
+ * @param snapshotIncludeCollectionList the value to set
+ * @return the dsl builder
+ */
+ default DebeziumDb2ComponentBuilder snapshotIncludeCollectionList(
+ java.lang.String snapshotIncludeCollectionList) {
+ doSetProperty("snapshotIncludeCollectionList", snapshotIncludeCollectionList);
+ return this;
+ }
+ /**
+ * The maximum number of millis to wait for table locks at the beginning
+ * of a snapshot. If locks cannot be acquired in this time frame, the
+ * snapshot will be aborted. Defaults to 10 seconds.
+ *
+ * The option is a: <code>long</code> type.
+ *
+ * Default: 10s
+ * Group: db2
+ *
+ * @param snapshotLockTimeoutMs the value to set
+ * @return the dsl builder
+ */
+ default DebeziumDb2ComponentBuilder snapshotLockTimeoutMs(
+ long snapshotLockTimeoutMs) {
+ doSetProperty("snapshotLockTimeoutMs", snapshotLockTimeoutMs);
+ return this;
+ }
/**
* The criteria for running a snapshot upon startup of the connector.
* Options include: 'initial' (the default) to specify the connector
@@ -857,6 +1246,44 @@ public interface DebeziumDb2ComponentBuilderFactory {
doSetProperty("timePrecisionMode", timePrecisionMode);
return this;
}
+ /**
+ * Whether delete operations should be represented by a delete event and
+ * a subsquenttombstone event (true) or only by a delete event (false).
+ * Emitting the tombstone event (the default behavior) allows Kafka to
+ * completely delete all events pertaining to the given key once the
+ * source record got deleted.
+ *
+ * The option is a: <code>boolean</code> type.
+ *
+ * Default: false
+ * Group: db2
+ *
+ * @param tombstonesOnDelete the value to set
+ * @return the dsl builder
+ */
+ default DebeziumDb2ComponentBuilder tombstonesOnDelete(
+ boolean tombstonesOnDelete) {
+ doSetProperty("tombstonesOnDelete", tombstonesOnDelete);
+ return this;
+ }
+ /**
+ * The name of the transaction metadata topic. The placeholder
+ * ${database.server.name} can be used for referring to the connector's
+ * logical name; defaults to ${database.server.name}.transaction.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Default: ${database.server.name}.transaction
+ * Group: db2
+ *
+ * @param transactionTopic the value to set
+ * @return the dsl builder
+ */
+ default DebeziumDb2ComponentBuilder transactionTopic(
+ java.lang.String transactionTopic) {
+ doSetProperty("transactionTopic", transactionTopic);
+ return this;
+ }
}
class DebeziumDb2ComponentBuilderImpl
@@ -897,27 +1324,49 @@ public interface DebeziumDb2ComponentBuilderFactory {
case "autowiredEnabled": ((DebeziumDb2Component) component).setAutowiredEnabled((boolean) value); return true;
case "columnBlacklist": getOrCreateConfiguration((DebeziumDb2Component) component).setColumnBlacklist((java.lang.String) value); return true;
case "columnExcludeList": getOrCreateConfiguration((DebeziumDb2Component) component).setColumnExcludeList((java.lang.String) value); return true;
+ case "columnIncludeList": getOrCreateConfiguration((DebeziumDb2Component) component).setColumnIncludeList((java.lang.String) value); return true;
+ case "columnPropagateSourceType": getOrCreateConfiguration((DebeziumDb2Component) component).setColumnPropagateSourceType((java.lang.String) value); return true;
+ case "columnWhitelist": getOrCreateConfiguration((DebeziumDb2Component) component).setColumnWhitelist((java.lang.String) value); return true;
+ case "converters": getOrCreateConfiguration((DebeziumDb2Component) component).setConverters((java.lang.String) value); return true;
case "databaseDbname": getOrCreateConfiguration((DebeziumDb2Component) component).setDatabaseDbname((java.lang.String) value); return true;
case "databaseHistory": getOrCreateConfiguration((DebeziumDb2Component) component).setDatabaseHistory((java.lang.String) value); return true;
case "databaseHistoryFileFilename": getOrCreateConfiguration((DebeziumDb2Component) component).setDatabaseHistoryFileFilename((java.lang.String) value); return true;
case "databaseHistoryKafkaBootstrapServers": getOrCreateConfiguration((DebeziumDb2Component) component).setDatabaseHistoryKafkaBootstrapServers((java.lang.String) value); return true;
+ case "databaseHistoryKafkaQueryTimeoutMs": getOrCreateConfiguration((DebeziumDb2Component) component).setDatabaseHistoryKafkaQueryTimeoutMs((long) value); return true;
case "databaseHistoryKafkaRecoveryAttempts": getOrCreateConfiguration((DebeziumDb2Component) component).setDatabaseHistoryKafkaRecoveryAttempts((int) value); return true;
case "databaseHistoryKafkaRecoveryPollIntervalMs": getOrCreateConfiguration((DebeziumDb2Component) component).setDatabaseHistoryKafkaRecoveryPollIntervalMs((int) value); return true;
case "databaseHistoryKafkaTopic": getOrCreateConfiguration((DebeziumDb2Component) component).setDatabaseHistoryKafkaTopic((java.lang.String) value); return true;
+ case "databaseHistorySkipUnparseableDdl": getOrCreateConfiguration((DebeziumDb2Component) component).setDatabaseHistorySkipUnparseableDdl((boolean) value); return true;
+ case "databaseHistoryStoreOnlyCapturedTablesDdl": getOrCreateConfiguration((DebeziumDb2Component) component).setDatabaseHistoryStoreOnlyCapturedTablesDdl((boolean) value); return true;
+ case "databaseHistoryStoreOnlyMonitoredTablesDdl": getOrCreateConfiguration((DebeziumDb2Component) component).setDatabaseHistoryStoreOnlyMonitoredTablesDdl((boolean) value); return true;
case "databaseHostname": getOrCreateConfiguration((DebeziumDb2Component) component).setDatabaseHostname((java.lang.String) value); return true;
case "databasePassword": getOrCreateConfiguration((DebeziumDb2Component) component).setDatabasePassword((java.lang.String) value); return true;
case "databasePort": getOrCreateConfiguration((DebeziumDb2Component) component).setDatabasePort((int) value); return true;
case "databaseServerName": getOrCreateConfiguration((DebeziumDb2Component) component).setDatabaseServerName((java.lang.String) value); return true;
case "databaseUser": getOrCreateConfiguration((DebeziumDb2Component) component).setDatabaseUser((java.lang.String) value); return true;
+ case "datatypePropagateSourceType": getOrCreateConfiguration((DebeziumDb2Component) component).setDatatypePropagateSourceType((java.lang.String) value); return true;
case "decimalHandlingMode": getOrCreateConfiguration((DebeziumDb2Component) component).setDecimalHandlingMode((java.lang.String) value); return true;
case "eventProcessingFailureHandlingMode": getOrCreateConfiguration((DebeziumDb2Component) component).setEventProcessingFailureHandlingMode((java.lang.String) value); return true;
case "heartbeatIntervalMs": getOrCreateConfiguration((DebeziumDb2Component) component).setHeartbeatIntervalMs((int) value); return true;
case "heartbeatTopicsPrefix": getOrCreateConfiguration((DebeziumDb2Component) component).setHeartbeatTopicsPrefix((java.lang.String) value); return true;
+ case "includeSchemaChanges": getOrCreateConfiguration((DebeziumDb2Component) component).setIncludeSchemaChanges((boolean) value); return true;
+ case "incrementalSnapshotChunkSize": getOrCreateConfiguration((DebeziumDb2Component) component).setIncrementalSnapshotChunkSize((int) value); return true;
case "maxBatchSize": getOrCreateConfiguration((DebeziumDb2Component) component).setMaxBatchSize((int) value); return true;
case "maxQueueSize": getOrCreateConfiguration((DebeziumDb2Component) component).setMaxQueueSize((int) value); return true;
+ case "maxQueueSizeInBytes": getOrCreateConfiguration((DebeziumDb2Component) component).setMaxQueueSizeInBytes((long) value); return true;
+ case "messageKeyColumns": getOrCreateConfiguration((DebeziumDb2Component) component).setMessageKeyColumns((java.lang.String) value); return true;
case "pollIntervalMs": getOrCreateConfiguration((DebeziumDb2Component) component).setPollIntervalMs((long) value); return true;
+ case "provideTransactionMetadata": getOrCreateConfiguration((DebeziumDb2Component) component).setProvideTransactionMetadata((boolean) value); return true;
+ case "queryFetchSize": getOrCreateConfiguration((DebeziumDb2Component) component).setQueryFetchSize((int) value); return true;
+ case "retriableRestartConnectorWaitMs": getOrCreateConfiguration((DebeziumDb2Component) component).setRetriableRestartConnectorWaitMs((long) value); return true;
+ case "sanitizeFieldNames": getOrCreateConfiguration((DebeziumDb2Component) component).setSanitizeFieldNames((boolean) value); return true;
+ case "schemaNameAdjustmentMode": getOrCreateConfiguration((DebeziumDb2Component) component).setSchemaNameAdjustmentMode((java.lang.String) value); return true;
+ case "signalDataCollection": getOrCreateConfiguration((DebeziumDb2Component) component).setSignalDataCollection((java.lang.String) value); return true;
+ case "skippedOperations": getOrCreateConfiguration((DebeziumDb2Component) component).setSkippedOperations((java.lang.String) value); return true;
case "snapshotDelayMs": getOrCreateConfiguration((DebeziumDb2Component) component).setSnapshotDelayMs((long) value); return true;
case "snapshotFetchSize": getOrCreateConfiguration((DebeziumDb2Component) component).setSnapshotFetchSize((int) value); return true;
+ case "snapshotIncludeCollectionList": getOrCreateConfiguration((DebeziumDb2Component) component).setSnapshotIncludeCollectionList((java.lang.String) value); return true;
+ case "snapshotLockTimeoutMs": getOrCreateConfiguration((DebeziumDb2Component) component).setSnapshotLockTimeoutMs((long) value); return true;
case "snapshotMode": getOrCreateConfiguration((DebeziumDb2Component) component).setSnapshotMode((java.lang.String) value); return true;
case "snapshotSelectStatementOverrides": getOrCreateConfiguration((DebeziumDb2Component) component).setSnapshotSelectStatementOverrides((java.lang.String) value); return true;
case "sourceStructVersion": getOrCreateConfiguration((DebeziumDb2Component) component).setSourceStructVersion((java.lang.String) value); return true;
@@ -927,6 +1376,8 @@ public interface DebeziumDb2ComponentBuilderFactory {
case "tableIncludeList": getOrCreateConfiguration((DebeziumDb2Component) component).setTableIncludeList((java.lang.String) value); return true;
case "tableWhitelist": getOrCreateConfiguration((DebeziumDb2Component) component).setTableWhitelist((java.lang.String) value); return true;
case "timePrecisionMode": getOrCreateConfiguration((DebeziumDb2Component) component).setTimePrecisionMode((java.lang.String) value); return true;
+ case "tombstonesOnDelete": getOrCreateConfiguration((DebeziumDb2Component) component).setTombstonesOnDelete((boolean) value); return true;
+ case "transactionTopic": getOrCreateConfiguration((DebeziumDb2Component) component).setTransactionTopic((java.lang.String) value); return true;
default: return false;
}
}
diff --git a/dsl/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/DebeziumMongodbComponentBuilderFactory.java b/dsl/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/DebeziumMongodbComponentBuilderFactory.java
index 75a8ec85fc0..9036d94fb7b 100644
--- a/dsl/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/DebeziumMongodbComponentBuilderFactory.java
+++ b/dsl/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/DebeziumMongodbComponentBuilderFactory.java
@@ -701,8 +701,8 @@ public interface DebeziumMongodbComponentBuilderFactory {
}
/**
* Unique name that identifies the MongoDB replica set or cluster and
- * all recorded offsets, andthat is used as a prefix for all schemas and
- * topics. Each distinct MongoDB installation should have a separate
+ * all recorded offsets, and that is used as a prefix for all schemas
+ * and topics. Each distinct MongoDB installation should have a separate
* namespace and monitored by at most one Debezium connector.
*
* The option is a: <code>java.lang.String</code> type.
@@ -913,6 +913,25 @@ public interface DebeziumMongodbComponentBuilderFactory {
doSetProperty("sanitizeFieldNames", sanitizeFieldNames);
return this;
}
+ /**
+ * Specify how schema names should be adjusted for compatibility with
+ * the message converter used by the connector, including:'avro'
+ * replaces the characters that cannot be used in the Avro type name
+ * with underscore (default)'none' does not apply any adjustment.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Default: avro
+ * Group: mongodb
+ *
+ * @param schemaNameAdjustmentMode the value to set
+ * @return the dsl builder
+ */
+ default DebeziumMongodbComponentBuilder schemaNameAdjustmentMode(
+ java.lang.String schemaNameAdjustmentMode) {
+ doSetProperty("schemaNameAdjustmentMode", schemaNameAdjustmentMode);
+ return this;
+ }
/**
* The name of the data collection that is used to send signals/commands
* to Debezium. Signaling is disabled when not set.
@@ -931,8 +950,9 @@ public interface DebeziumMongodbComponentBuilderFactory {
}
/**
* The comma-separated list of operations to skip during streaming,
- * defined as: 'c' for inserts/create; 'u' for updates; 'd' for deletes.
- * By default, no operations will be skipped.
+ * defined as: 'c' for inserts/create; 'u' for updates; 'd' for deletes,
+ * 't' for truncates, and 'none' to indicate nothing skipped. By
+ * default, no operations will be skipped.
*
* The option is a: <code>java.lang.String</code> type.
*
@@ -1178,6 +1198,7 @@ public interface DebeziumMongodbComponentBuilderFactory {
case "queryFetchSize": getOrCreateConfiguration((DebeziumMongodbComponent) component).setQueryFetchSize((int) value); return true;
case "retriableRestartConnectorWaitMs": getOrCreateConfiguration((DebeziumMongodbComponent) component).setRetriableRestartConnectorWaitMs((long) value); return true;
case "sanitizeFieldNames": getOrCreateConfiguration((DebeziumMongodbComponent) component).setSanitizeFieldNames((boolean) value); return true;
+ case "schemaNameAdjustmentMode": getOrCreateConfiguration((DebeziumMongodbComponent) component).setSchemaNameAdjustmentMode((java.lang.String) value); return true;
case "signalDataCollection": getOrCreateConfiguration((DebeziumMongodbComponent) component).setSignalDataCollection((java.lang.String) value); return true;
case "skippedOperations": getOrCreateConfiguration((DebeziumMongodbComponent) component).setSkippedOperations((java.lang.String) value); return true;
case "snapshotCollectionFilterOverrides": getOrCreateConfiguration((DebeziumMongodbComponent) component).setSnapshotCollectionFilterOverrides((java.lang.String) value); return true;
diff --git a/dsl/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/DebeziumMysqlComponentBuilderFactory.java b/dsl/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/DebeziumMysqlComponentBuilderFactory.java
index fca0de46e26..221da23359e 100644
--- a/dsl/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/DebeziumMysqlComponentBuilderFactory.java
+++ b/dsl/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/DebeziumMysqlComponentBuilderFactory.java
@@ -579,6 +579,23 @@ public interface DebeziumMysqlComponentBuilderFactory {
doSetProperty("databaseHistoryKafkaBootstrapServers", databaseHistoryKafkaBootstrapServers);
return this;
}
+ /**
+ * The number of milliseconds to wait while fetching cluster information
+ * using Kafka admin client.
+ *
+ * The option is a: <code>long</code> type.
+ *
+ * Default: 3s
+ * Group: mysql
+ *
+ * @param databaseHistoryKafkaQueryTimeoutMs the value to set
+ * @return the dsl builder
+ */
+ default DebeziumMysqlComponentBuilder databaseHistoryKafkaQueryTimeoutMs(
+ long databaseHistoryKafkaQueryTimeoutMs) {
+ doSetProperty("databaseHistoryKafkaQueryTimeoutMs", databaseHistoryKafkaQueryTimeoutMs);
+ return this;
+ }
/**
* The number of attempts in a row that no data are returned from Kafka
* before recover completes. The maximum amount of time to wait after
@@ -843,8 +860,8 @@ public interface DebeziumMysqlComponentBuilderFactory {
return this;
}
/**
- * Location of the Java keystore file containing an application
- * process's own certificate and private key.
+ * The location of the key store file. This is optional and can be used
+ * for two-way authentication between the client and the MySQL Server.
*
* The option is a: <code>java.lang.String</code> type.
*
@@ -859,11 +876,8 @@ public interface DebeziumMysqlComponentBuilderFactory {
return this;
}
/**
- * Password to access the private key from the keystore file specified
- * by 'ssl.keystore' configuration property or the
- * 'javax.net.ssl.keyStore' system or JVM property. This password is
- * used to unlock the keystore file (store password), and to decrypt the
- * private key stored in the keystore (key password).
+ * The password for the key store file. This is optional and only needed
+ * if 'database.ssl.keystore' is configured.
*
* The option is a: <code>java.lang.String</code> type.
*
@@ -904,8 +918,8 @@ public interface DebeziumMysqlComponentBuilderFactory {
return this;
}
/**
- * Location of the Java truststore file containing the collection of CA
- * certificates trusted by this application process (trust store).
+ * The location of the trust store file for the server certificate
+ * verification.
*
* The option is a: <code>java.lang.String</code> type.
*
@@ -920,9 +934,8 @@ public interface DebeziumMysqlComponentBuilderFactory {
return this;
}
/**
- * Password to unlock the keystore file (store password) specified by
- * 'ssl.trustore' configuration property or the
- * 'javax.net.ssl.trustStore' system or JVM property.
+ * The password for the trust store file. Used to check the integrity of
+ * the truststore, and unlock the truststore.
*
* The option is a: <code>java.lang.String</code> type.
*
@@ -1452,6 +1465,25 @@ public interface DebeziumMysqlComponentBuilderFactory {
doSetProperty("sanitizeFieldNames", sanitizeFieldNames);
return this;
}
+ /**
+ * Specify how schema names should be adjusted for compatibility with
+ * the message converter used by the connector, including:'avro'
+ * replaces the characters that cannot be used in the Avro type name
+ * with underscore (default)'none' does not apply any adjustment.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Default: avro
+ * Group: mysql
+ *
+ * @param schemaNameAdjustmentMode the value to set
+ * @return the dsl builder
+ */
+ default DebeziumMysqlComponentBuilder schemaNameAdjustmentMode(
+ java.lang.String schemaNameAdjustmentMode) {
+ doSetProperty("schemaNameAdjustmentMode", schemaNameAdjustmentMode);
+ return this;
+ }
/**
* The name of the data collection that is used to send signals/commands
* to Debezium. Signaling is disabled when not set.
@@ -1470,8 +1502,9 @@ public interface DebeziumMysqlComponentBuilderFactory {
}
/**
* The comma-separated list of operations to skip during streaming,
- * defined as: 'c' for inserts/create; 'u' for updates; 'd' for deletes.
- * By default, no operations will be skipped.
+ * defined as: 'c' for inserts/create; 'u' for updates; 'd' for deletes,
+ * 't' for truncates, and 'none' to indicate nothing skipped. By
+ * default, no operations will be skipped.
*
* The option is a: <code>java.lang.String</code> type.
*
@@ -1891,6 +1924,7 @@ public interface DebeziumMysqlComponentBuilderFactory {
case "databaseHistory": getOrCreateConfiguration((DebeziumMySqlComponent) component).setDatabaseHistory((java.lang.String) value); return true;
case "databaseHistoryFileFilename": getOrCreateConfiguration((DebeziumMySqlComponent) component).setDatabaseHistoryFileFilename((java.lang.String) value); return true;
case "databaseHistoryKafkaBootstrapServers": getOrCreateConfiguration((DebeziumMySqlComponent) component).setDatabaseHistoryKafkaBootstrapServers((java.lang.String) value); return true;
+ case "databaseHistoryKafkaQueryTimeoutMs": getOrCreateConfiguration((DebeziumMySqlComponent) component).setDatabaseHistoryKafkaQueryTimeoutMs((long) value); return true;
case "databaseHistoryKafkaRecoveryAttempts": getOrCreateConfiguration((DebeziumMySqlComponent) component).setDatabaseHistoryKafkaRecoveryAttempts((int) value); return true;
case "databaseHistoryKafkaRecoveryPollIntervalMs": getOrCreateConfiguration((DebeziumMySqlComponent) component).setDatabaseHistoryKafkaRecoveryPollIntervalMs((int) value); return true;
case "databaseHistoryKafkaTopic": getOrCreateConfiguration((DebeziumMySqlComponent) component).setDatabaseHistoryKafkaTopic((java.lang.String) value); return true;
@@ -1939,6 +1973,7 @@ public interface DebeziumMysqlComponentBuilderFactory {
case "queryFetchSize": getOrCreateConfiguration((DebeziumMySqlComponent) component).setQueryFetchSize((int) value); return true;
case "retriableRestartConnectorWaitMs": getOrCreateConfiguration((DebeziumMySqlComponent) component).setRetriableRestartConnectorWaitMs((long) value); return true;
case "sanitizeFieldNames": getOrCreateConfiguration((DebeziumMySqlComponent) component).setSanitizeFieldNames((boolean) value); return true;
+ case "schemaNameAdjustmentMode": getOrCreateConfiguration((DebeziumMySqlComponent) component).setSchemaNameAdjustmentMode((java.lang.String) value); return true;
case "signalDataCollection": getOrCreateConfiguration((DebeziumMySqlComponent) component).setSignalDataCollection((java.lang.String) value); return true;
case "skippedOperations": getOrCreateConfiguration((DebeziumMySqlComponent) component).setSkippedOperations((java.lang.String) value); return true;
case "snapshotDelayMs": getOrCreateConfiguration((DebeziumMySqlComponent) component).setSnapshotDelayMs((long) value); return true;
diff --git a/dsl/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/DebeziumOracleComponentBuilderFactory.java b/dsl/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/DebeziumOracleComponentBuilderFactory.java
index 68defc46f7c..f45601fd583 100644
--- a/dsl/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/DebeziumOracleComponentBuilderFactory.java
+++ b/dsl/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/DebeziumOracleComponentBuilderFactory.java
@@ -504,6 +504,23 @@ public interface DebeziumOracleComponentBuilderFactory {
doSetProperty("databaseHistoryKafkaBootstrapServers", databaseHistoryKafkaBootstrapServers);
return this;
}
+ /**
+ * The number of milliseconds to wait while fetching cluster information
+ * using Kafka admin client.
+ *
+ * The option is a: <code>long</code> type.
+ *
+ * Default: 3s
+ * Group: oracle
+ *
+ * @param databaseHistoryKafkaQueryTimeoutMs the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleComponentBuilder databaseHistoryKafkaQueryTimeoutMs(
+ long databaseHistoryKafkaQueryTimeoutMs) {
+ doSetProperty("databaseHistoryKafkaQueryTimeoutMs", databaseHistoryKafkaQueryTimeoutMs);
+ return this;
+ }
/**
* The number of attempts in a row that no data are returned from Kafka
* before recover completes. The maximum amount of time to wait after
@@ -1489,6 +1506,25 @@ public interface DebeziumOracleComponentBuilderFactory {
doSetProperty("sanitizeFieldNames", sanitizeFieldNames);
return this;
}
+ /**
+ * Specify how schema names should be adjusted for compatibility with
+ * the message converter used by the connector, including:'avro'
+ * replaces the characters that cannot be used in the Avro type name
+ * with underscore (default)'none' does not apply any adjustment.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Default: avro
+ * Group: oracle
+ *
+ * @param schemaNameAdjustmentMode the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleComponentBuilder schemaNameAdjustmentMode(
+ java.lang.String schemaNameAdjustmentMode) {
+ doSetProperty("schemaNameAdjustmentMode", schemaNameAdjustmentMode);
+ return this;
+ }
/**
* The name of the data collection that is used to send signals/commands
* to Debezium. Signaling is disabled when not set.
@@ -1507,8 +1543,9 @@ public interface DebeziumOracleComponentBuilderFactory {
}
/**
* The comma-separated list of operations to skip during streaming,
- * defined as: 'c' for inserts/create; 'u' for updates; 'd' for deletes.
- * By default, no operations will be skipped.
+ * defined as: 'c' for inserts/create; 'u' for updates; 'd' for deletes,
+ * 't' for truncates, and 'none' to indicate nothing skipped. By
+ * default, no operations will be skipped.
*
* The option is a: <code>java.lang.String</code> type.
*
@@ -1903,6 +1940,7 @@ public interface DebeziumOracleComponentBuilderFactory {
case "databaseHistory": getOrCreateConfiguration((DebeziumOracleComponent) component).setDatabaseHistory((java.lang.String) value); return true;
case "databaseHistoryFileFilename": getOrCreateConfiguration((DebeziumOracleComponent) component).setDatabaseHistoryFileFilename((java.lang.String) value); return true;
case "databaseHistoryKafkaBootstrapServers": getOrCreateConfiguration((DebeziumOracleComponent) component).setDatabaseHistoryKafkaBootstrapServers((java.lang.String) value); return true;
+ case "databaseHistoryKafkaQueryTimeoutMs": getOrCreateConfiguration((DebeziumOracleComponent) component).setDatabaseHistoryKafkaQueryTimeoutMs((long) value); return true;
case "databaseHistoryKafkaRecoveryAttempts": getOrCreateConfiguration((DebeziumOracleComponent) component).setDatabaseHistoryKafkaRecoveryAttempts((int) value); return true;
case "databaseHistoryKafkaRecoveryPollIntervalMs": getOrCreateConfiguration((DebeziumOracleComponent) component).setDatabaseHistoryKafkaRecoveryPollIntervalMs((int) value); return true;
case "databaseHistoryKafkaTopic": getOrCreateConfiguration((DebeziumOracleComponent) component).setDatabaseHistoryKafkaTopic((java.lang.String) value); return true;
@@ -1959,6 +1997,7 @@ public interface DebeziumOracleComponentBuilderFactory {
case "racNodes": getOrCreateConfiguration((DebeziumOracleComponent) component).setRacNodes((java.lang.String) value); return true;
case "retriableRestartConnectorWaitMs": getOrCreateConfiguration((DebeziumOracleComponent) component).setRetriableRestartConnectorWaitMs((long) value); return true;
case "sanitizeFieldNames": getOrCreateConfiguration((DebeziumOracleComponent) component).setSanitizeFieldNames((boolean) value); return true;
+ case "schemaNameAdjustmentMode": getOrCreateConfiguration((DebeziumOracleComponent) component).setSchemaNameAdjustmentMode((java.lang.String) value); return true;
case "signalDataCollection": getOrCreateConfiguration((DebeziumOracleComponent) component).setSignalDataCollection((java.lang.String) value); return true;
case "skippedOperations": getOrCreateConfiguration((DebeziumOracleComponent) component).setSkippedOperations((java.lang.String) value); return true;
case "snapshotDelayMs": getOrCreateConfiguration((DebeziumOracleComponent) component).setSnapshotDelayMs((long) value); return true;
diff --git a/dsl/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/DebeziumPostgresComponentBuilderFactory.java b/dsl/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/DebeziumPostgresComponentBuilderFactory.java
index b7f08720bc0..853ee1c8d89 100644
--- a/dsl/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/DebeziumPostgresComponentBuilderFactory.java
+++ b/dsl/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/DebeziumPostgresComponentBuilderFactory.java
@@ -983,9 +983,8 @@ public interface DebeziumPostgresComponentBuilderFactory {
}
/**
* The name of the Postgres logical decoding plugin installed on the
- * server. Supported values are 'decoderbufs', 'wal2json', 'pgoutput',
- * 'wal2json_streaming', 'wal2json_rds' and 'wal2json_rds_streaming'.
- * Defaults to 'decoderbufs'.
+ * server. Supported values are 'decoderbufs' and 'pgoutput'. Defaults
+ * to 'decoderbufs'.
*
* The option is a: <code>java.lang.String</code> type.
*
@@ -1175,6 +1174,25 @@ public interface DebeziumPostgresComponentBuilderFactory {
doSetProperty("schemaIncludeList", schemaIncludeList);
return this;
}
+ /**
+ * Specify how schema names should be adjusted for compatibility with
+ * the message converter used by the connector, including:'avro'
+ * replaces the characters that cannot be used in the Avro type name
+ * with underscore (default)'none' does not apply any adjustment.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Default: avro
+ * Group: postgres
+ *
+ * @param schemaNameAdjustmentMode the value to set
+ * @return the dsl builder
+ */
+ default DebeziumPostgresComponentBuilder schemaNameAdjustmentMode(
+ java.lang.String schemaNameAdjustmentMode) {
+ doSetProperty("schemaNameAdjustmentMode", schemaNameAdjustmentMode);
+ return this;
+ }
/**
* Specify the conditions that trigger a refresh of the in-memory schema
* for a table. 'columns_diff' (the default) is the safest mode,
@@ -1236,11 +1254,13 @@ public interface DebeziumPostgresComponentBuilderFactory {
}
/**
* The comma-separated list of operations to skip during streaming,
- * defined as: 'c' for inserts/create; 'u' for updates; 'd' for deletes.
- * By default, no operations will be skipped.
+ * defined as: 'c' for inserts/create; 'u' for updates; 'd' for deletes,
+ * 't' for truncates, and 'none' to indicate nothing skipped. By
+ * default, no operations will be skipped.
*
* The option is a: <code>java.lang.String</code> type.
*
+ * Default: t
* Group: postgres
*
* @param skippedOperations the value to set
@@ -1669,25 +1689,6 @@ public interface DebeziumPostgresComponentBuilderFactory {
doSetProperty("transactionTopic", transactionTopic);
return this;
}
- /**
- * Specify how TRUNCATE operations are handled for change events
- * (supported only on pg11 pgoutput plugin), including: 'skip' to skip /
- * ignore TRUNCATE events (default), 'include' to handle and include
- * TRUNCATE events.
- *
- * The option is a: <code>java.lang.String</code> type.
- *
- * Default: skip
- * Group: postgres
- *
- * @param truncateHandlingMode the value to set
- * @return the dsl builder
- */
- default DebeziumPostgresComponentBuilder truncateHandlingMode(
- java.lang.String truncateHandlingMode) {
- doSetProperty("truncateHandlingMode", truncateHandlingMode);
- return this;
- }
/**
* Specify the constant that will be provided by Debezium to indicate
* that the original value is a toasted value not provided by the
@@ -1818,6 +1819,7 @@ public interface DebeziumPostgresComponentBuilderFactory {
case "schemaBlacklist": getOrCreateConfiguration((DebeziumPostgresComponent) component).setSchemaBlacklist((java.lang.String) value); return true;
case "schemaExcludeList": getOrCreateConfiguration((DebeziumPostgresComponent) component).setSchemaExcludeList((java.lang.String) value); return true;
case "schemaIncludeList": getOrCreateConfiguration((DebeziumPostgresComponent) component).setSchemaIncludeList((java.lang.String) value); return true;
+ case "schemaNameAdjustmentMode": getOrCreateConfiguration((DebeziumPostgresComponent) component).setSchemaNameAdjustmentMode((java.lang.String) value); return true;
case "schemaRefreshMode": getOrCreateConfiguration((DebeziumPostgresComponent) component).setSchemaRefreshMode((java.lang.String) value); return true;
case "schemaWhitelist": getOrCreateConfiguration((DebeziumPostgresComponent) component).setSchemaWhitelist((java.lang.String) value); return true;
case "signalDataCollection": getOrCreateConfiguration((DebeziumPostgresComponent) component).setSignalDataCollection((java.lang.String) value); return true;
@@ -1845,7 +1847,6 @@ public interface DebeziumPostgresComponentBuilderFactory {
case "timePrecisionMode": getOrCreateConfiguration((DebeziumPostgresComponent) component).setTimePrecisionMode((java.lang.String) value); return true;
case "tombstonesOnDelete": getOrCreateConfiguration((DebeziumPostgresComponent) component).setTombstonesOnDelete((boolean) value); return true;
case "transactionTopic": getOrCreateConfiguration((DebeziumPostgresComponent) component).setTransactionTopic((java.lang.String) value); return true;
- case "truncateHandlingMode": getOrCreateConfiguration((DebeziumPostgresComponent) component).setTruncateHandlingMode((java.lang.String) value); return true;
case "unavailableValuePlaceholder": getOrCreateConfiguration((DebeziumPostgresComponent) component).setUnavailableValuePlaceholder((java.lang.String) value); return true;
case "xminFetchIntervalMs": getOrCreateConfiguration((DebeziumPostgresComponent) component).setXminFetchIntervalMs((long) value); return true;
default: return false;
diff --git a/dsl/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/DebeziumSqlserverComponentBuilderFactory.java b/dsl/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/DebeziumSqlserverComponentBuilderFactory.java
index afb667ae9c5..8ea77ee25fc 100644
--- a/dsl/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/DebeziumSqlserverComponentBuilderFactory.java
+++ b/dsl/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/DebeziumSqlserverComponentBuilderFactory.java
@@ -486,6 +486,23 @@ public interface DebeziumSqlserverComponentBuilderFactory {
doSetProperty("databaseHistoryKafkaBootstrapServers", databaseHistoryKafkaBootstrapServers);
return this;
}
+ /**
+ * The number of milliseconds to wait while fetching cluster information
+ * using Kafka admin client.
+ *
+ * The option is a: <code>long</code> type.
+ *
+ * Default: 3s
+ * Group: sqlserver
+ *
+ * @param databaseHistoryKafkaQueryTimeoutMs the value to set
+ * @return the dsl builder
+ */
+ default DebeziumSqlserverComponentBuilder databaseHistoryKafkaQueryTimeoutMs(
+ long databaseHistoryKafkaQueryTimeoutMs) {
+ doSetProperty("databaseHistoryKafkaQueryTimeoutMs", databaseHistoryKafkaQueryTimeoutMs);
+ return this;
+ }
/**
* The number of attempts in a row that no data are returned from Kafka
* before recover completes. The maximum amount of time to wait after
@@ -1090,6 +1107,25 @@ public interface DebeziumSqlserverComponentBuilderFactory {
doSetProperty("sanitizeFieldNames", sanitizeFieldNames);
return this;
}
+ /**
+ * Specify how schema names should be adjusted for compatibility with
+ * the message converter used by the connector, including:'avro'
+ * replaces the characters that cannot be used in the Avro type name
+ * with underscore (default)'none' does not apply any adjustment.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Default: avro
+ * Group: sqlserver
+ *
+ * @param schemaNameAdjustmentMode the value to set
+ * @return the dsl builder
+ */
+ default DebeziumSqlserverComponentBuilder schemaNameAdjustmentMode(
+ java.lang.String schemaNameAdjustmentMode) {
+ doSetProperty("schemaNameAdjustmentMode", schemaNameAdjustmentMode);
+ return this;
+ }
/**
* The name of the data collection that is used to send signals/commands
* to Debezium. Signaling is disabled when not set.
@@ -1108,8 +1144,9 @@ public interface DebeziumSqlserverComponentBuilderFactory {
}
/**
* The comma-separated list of operations to skip during streaming,
- * defined as: 'c' for inserts/create; 'u' for updates; 'd' for deletes.
- * By default, no operations will be skipped.
+ * defined as: 'c' for inserts/create; 'u' for updates; 'd' for deletes,
+ * 't' for truncates, and 'none' to indicate nothing skipped. By
+ * default, no operations will be skipped.
*
* The option is a: <code>java.lang.String</code> type.
*
@@ -1512,6 +1549,7 @@ public interface DebeziumSqlserverComponentBuilderFactory {
case "databaseHistory": getOrCreateConfiguration((DebeziumSqlserverComponent) component).setDatabaseHistory((java.lang.String) value); return true;
case "databaseHistoryFileFilename": getOrCreateConfiguration((DebeziumSqlserverComponent) component).setDatabaseHistoryFileFilename((java.lang.String) value); return true;
case "databaseHistoryKafkaBootstrapServers": getOrCreateConfiguration((DebeziumSqlserverComponent) component).setDatabaseHistoryKafkaBootstrapServers((java.lang.String) value); return true;
+ case "databaseHistoryKafkaQueryTimeoutMs": getOrCreateConfiguration((DebeziumSqlserverComponent) component).setDatabaseHistoryKafkaQueryTimeoutMs((long) value); return true;
case "databaseHistoryKafkaRecoveryAttempts": getOrCreateConfiguration((DebeziumSqlserverComponent) component).setDatabaseHistoryKafkaRecoveryAttempts((int) value); return true;
case "databaseHistoryKafkaRecoveryPollIntervalMs": getOrCreateConfiguration((DebeziumSqlserverComponent) component).setDatabaseHistoryKafkaRecoveryPollIntervalMs((int) value); return true;
case "databaseHistoryKafkaTopic": getOrCreateConfiguration((DebeziumSqlserverComponent) component).setDatabaseHistoryKafkaTopic((java.lang.String) value); return true;
@@ -1546,6 +1584,7 @@ public interface DebeziumSqlserverComponentBuilderFactory {
case "queryFetchSize": getOrCreateConfiguration((DebeziumSqlserverComponent) component).setQueryFetchSize((int) value); return true;
case "retriableRestartConnectorWaitMs": getOrCreateConfiguration((DebeziumSqlserverComponent) component).setRetriableRestartConnectorWaitMs((long) value); return true;
case "sanitizeFieldNames": getOrCreateConfiguration((DebeziumSqlserverComponent) component).setSanitizeFieldNames((boolean) value); return true;
+ case "schemaNameAdjustmentMode": getOrCreateConfiguration((DebeziumSqlserverComponent) component).setSchemaNameAdjustmentMode((java.lang.String) value); return true;
case "signalDataCollection": getOrCreateConfiguration((DebeziumSqlserverComponent) component).setSignalDataCollection((java.lang.String) value); return true;
case "skippedOperations": getOrCreateConfiguration((DebeziumSqlserverComponent) component).setSkippedOperations((java.lang.String) value); return true;
case "snapshotDelayMs": getOrCreateConfiguration((DebeziumSqlserverComponent) component).setSnapshotDelayMs((long) value); return true;
diff --git a/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/DebeziumDb2EndpointBuilderFactory.java b/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/DebeziumDb2EndpointBuilderFactory.java
index 515631afc56..f18184146b9 100644
--- a/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/DebeziumDb2EndpointBuilderFactory.java
+++ b/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/DebeziumDb2EndpointBuilderFactory.java
@@ -406,6 +406,71 @@ public interface DebeziumDb2EndpointBuilderFactory {
doSetProperty("columnExcludeList", columnExcludeList);
return this;
}
+ /**
+ * Regular expressions matching columns to include in change events.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: db2
+ *
+ * @param columnIncludeList the value to set
+ * @return the dsl builder
+ */
+ default DebeziumDb2EndpointBuilder columnIncludeList(
+ String columnIncludeList) {
+ doSetProperty("columnIncludeList", columnIncludeList);
+ return this;
+ }
+ /**
+ * A comma-separated list of regular expressions matching
+ * fully-qualified names of columns that adds the columns original type
+ * and original length as parameters to the corresponding field schemas
+ * in the emitted change records.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: db2
+ *
+ * @param columnPropagateSourceType the value to set
+ * @return the dsl builder
+ */
+ default DebeziumDb2EndpointBuilder columnPropagateSourceType(
+ String columnPropagateSourceType) {
+ doSetProperty("columnPropagateSourceType", columnPropagateSourceType);
+ return this;
+ }
+ /**
+ * Regular expressions matching columns to include in change events
+ * (deprecated, use column.include.list instead).
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: db2
+ *
+ * @param columnWhitelist the value to set
+ * @return the dsl builder
+ */
+ default DebeziumDb2EndpointBuilder columnWhitelist(
+ String columnWhitelist) {
+ doSetProperty("columnWhitelist", columnWhitelist);
+ return this;
+ }
+ /**
+ * Optional list of custom converters that would be used instead of
+ * default ones. The converters are defined using '.type' config option
+ * and configured using options '.'.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: db2
+ *
+ * @param converters the value to set
+ * @return the dsl builder
+ */
+ default DebeziumDb2EndpointBuilder converters(String converters) {
+ doSetProperty("converters", converters);
+ return this;
+ }
/**
* The name of the database from which the connector should capture
* changes.
@@ -474,6 +539,40 @@ public interface DebeziumDb2EndpointBuilderFactory {
doSetProperty("databaseHistoryKafkaBootstrapServers", databaseHistoryKafkaBootstrapServers);
return this;
}
+ /**
+ * The number of milliseconds to wait while fetching cluster information
+ * using Kafka admin client.
+ *
+ * The option is a: <code>long</code> type.
+ *
+ * Default: 3s
+ * Group: db2
+ *
+ * @param databaseHistoryKafkaQueryTimeoutMs the value to set
+ * @return the dsl builder
+ */
+ default DebeziumDb2EndpointBuilder databaseHistoryKafkaQueryTimeoutMs(
+ long databaseHistoryKafkaQueryTimeoutMs) {
+ doSetProperty("databaseHistoryKafkaQueryTimeoutMs", databaseHistoryKafkaQueryTimeoutMs);
+ return this;
+ }
+ /**
+ * The number of milliseconds to wait while fetching cluster information
+ * using Kafka admin client.
+ *
+ * The option will be converted to a <code>long</code> type.
+ *
+ * Default: 3s
+ * Group: db2
+ *
+ * @param databaseHistoryKafkaQueryTimeoutMs the value to set
+ * @return the dsl builder
+ */
+ default DebeziumDb2EndpointBuilder databaseHistoryKafkaQueryTimeoutMs(
+ String databaseHistoryKafkaQueryTimeoutMs) {
+ doSetProperty("databaseHistoryKafkaQueryTimeoutMs", databaseHistoryKafkaQueryTimeoutMs);
+ return this;
+ }
/**
* The number of attempts in a row that no data are returned from Kafka
* before recover completes. The maximum amount of time to wait after
@@ -561,6 +660,125 @@ public interface DebeziumDb2EndpointBuilderFactory {
doSetProperty("databaseHistoryKafkaTopic", databaseHistoryKafkaTopic);
return this;
}
+ /**
+ * Controls the action Debezium will take when it meets a DDL statement
+ * in binlog, that it cannot parse.By default the connector will stop
+ * operating but by changing the setting it can ignore the statements
+ * which it cannot parse. If skipping is enabled then Debezium can miss
+ * metadata changes.
+ *
+ * The option is a: <code>boolean</code> type.
+ *
+ * Default: false
+ * Group: db2
+ *
+ * @param databaseHistorySkipUnparseableDdl the value to set
+ * @return the dsl builder
+ */
+ default DebeziumDb2EndpointBuilder databaseHistorySkipUnparseableDdl(
+ boolean databaseHistorySkipUnparseableDdl) {
+ doSetProperty("databaseHistorySkipUnparseableDdl", databaseHistorySkipUnparseableDdl);
+ return this;
+ }
+ /**
+ * Controls the action Debezium will take when it meets a DDL statement
+ * in binlog, that it cannot parse.By default the connector will stop
+ * operating but by changing the setting it can ignore the statements
+ * which it cannot parse. If skipping is enabled then Debezium can miss
+ * metadata changes.
+ *
+ * The option will be converted to a <code>boolean</code>
+ * type.
+ *
+ * Default: false
+ * Group: db2
+ *
+ * @param databaseHistorySkipUnparseableDdl the value to set
+ * @return the dsl builder
+ */
+ default DebeziumDb2EndpointBuilder databaseHistorySkipUnparseableDdl(
+ String databaseHistorySkipUnparseableDdl) {
+ doSetProperty("databaseHistorySkipUnparseableDdl", databaseHistorySkipUnparseableDdl);
+ return this;
+ }
+ /**
+ * Controls what DDL will Debezium store in database history. By default
+ * (false) Debezium will store all incoming DDL statements. If set to
+ * true, then only DDL that manipulates a captured table will be stored.
+ *
+ * The option is a: <code>boolean</code> type.
+ *
+ * Default: false
+ * Group: db2
+ *
+ * @param databaseHistoryStoreOnlyCapturedTablesDdl the value to set
+ * @return the dsl builder
+ */
+ default DebeziumDb2EndpointBuilder databaseHistoryStoreOnlyCapturedTablesDdl(
+ boolean databaseHistoryStoreOnlyCapturedTablesDdl) {
+ doSetProperty("databaseHistoryStoreOnlyCapturedTablesDdl", databaseHistoryStoreOnlyCapturedTablesDdl);
+ return this;
+ }
+ /**
+ * Controls what DDL will Debezium store in database history. By default
+ * (false) Debezium will store all incoming DDL statements. If set to
+ * true, then only DDL that manipulates a captured table will be stored.
+ *
+ * The option will be converted to a <code>boolean</code>
+ * type.
+ *
+ * Default: false
+ * Group: db2
+ *
+ * @param databaseHistoryStoreOnlyCapturedTablesDdl the value to set
+ * @return the dsl builder
+ */
+ default DebeziumDb2EndpointBuilder databaseHistoryStoreOnlyCapturedTablesDdl(
+ String databaseHistoryStoreOnlyCapturedTablesDdl) {
+ doSetProperty("databaseHistoryStoreOnlyCapturedTablesDdl", databaseHistoryStoreOnlyCapturedTablesDdl);
+ return this;
+ }
+ /**
+ * Controls what DDL will Debezium store in database history. By default
+ * (false) Debezium will store all incoming DDL statements. If set to
+ * true, then only DDL that manipulates a monitored table will be stored
+ * (deprecated, use database.history.store.only.captured.tables.ddl
+ * instead).
+ *
+ * The option is a: <code>boolean</code> type.
+ *
+ * Default: false
+ * Group: db2
+ *
+ * @param databaseHistoryStoreOnlyMonitoredTablesDdl the value to set
+ * @return the dsl builder
+ */
+ default DebeziumDb2EndpointBuilder databaseHistoryStoreOnlyMonitoredTablesDdl(
+ boolean databaseHistoryStoreOnlyMonitoredTablesDdl) {
+ doSetProperty("databaseHistoryStoreOnlyMonitoredTablesDdl", databaseHistoryStoreOnlyMonitoredTablesDdl);
+ return this;
+ }
+ /**
+ * Controls what DDL will Debezium store in database history. By default
+ * (false) Debezium will store all incoming DDL statements. If set to
+ * true, then only DDL that manipulates a monitored table will be stored
+ * (deprecated, use database.history.store.only.captured.tables.ddl
+ * instead).
+ *
+ * The option will be converted to a <code>boolean</code>
+ * type.
+ *
+ * Default: false
+ * Group: db2
+ *
+ * @param databaseHistoryStoreOnlyMonitoredTablesDdl the value to set
+ * @return the dsl builder
+ */
+ default DebeziumDb2EndpointBuilder databaseHistoryStoreOnlyMonitoredTablesDdl(
+ String databaseHistoryStoreOnlyMonitoredTablesDdl) {
+ doSetProperty("databaseHistoryStoreOnlyMonitoredTablesDdl", databaseHistoryStoreOnlyMonitoredTablesDdl);
+ return this;
+ }
/**
* Resolvable hostname or IP address of the database server.
*
@@ -656,6 +874,24 @@ public interface DebeziumDb2EndpointBuilderFactory {
doSetProperty("databaseUser", databaseUser);
return this;
}
+ /**
+ * A comma-separated list of regular expressions matching the
+ * database-specific data type names that adds the data type's original
+ * type and original length as parameters to the corresponding field
+ * schemas in the emitted change records.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: db2
+ *
+ * @param datatypePropagateSourceType the value to set
+ * @return the dsl builder
+ */
+ default DebeziumDb2EndpointBuilder datatypePropagateSourceType(
+ String datatypePropagateSourceType) {
+ doSetProperty("datatypePropagateSourceType", datatypePropagateSourceType);
+ return this;
+ }
/**
* Specify how DECIMAL and NUMERIC columns should be represented in
* change events, including:'precise' (the default) uses
@@ -753,6 +989,81 @@ public interface DebeziumDb2EndpointBuilderFactory {
doSetProperty("heartbeatTopicsPrefix", heartbeatTopicsPrefix);
return this;
}
+ /**
+ * Whether the connector should publish changes in the database schema
+ * to a Kafka topic with the same name as the database server ID. Each
+ * schema change will be recorded using a key that contains the database
+ * name and whose value include logical description of the new schema
+ * and optionally the DDL statement(s).The default is 'true'. This is
+ * independent of how the connector internally records database history.
+ *
+ * The option is a: <code>boolean</code> type.
+ *
+ * Default: true
+ * Group: db2
+ *
+ * @param includeSchemaChanges the value to set
+ * @return the dsl builder
+ */
+ default DebeziumDb2EndpointBuilder includeSchemaChanges(
+ boolean includeSchemaChanges) {
+ doSetProperty("includeSchemaChanges", includeSchemaChanges);
+ return this;
+ }
+ /**
+ * Whether the connector should publish changes in the database schema
+ * to a Kafka topic with the same name as the database server ID. Each
+ * schema change will be recorded using a key that contains the database
+ * name and whose value include logical description of the new schema
+ * and optionally the DDL statement(s).The default is 'true'. This is
+ * independent of how the connector internally records database history.
+ *
+ * The option will be converted to a <code>boolean</code>
+ * type.
+ *
+ * Default: true
+ * Group: db2
+ *
+ * @param includeSchemaChanges the value to set
+ * @return the dsl builder
+ */
+ default DebeziumDb2EndpointBuilder includeSchemaChanges(
+ String includeSchemaChanges) {
+ doSetProperty("includeSchemaChanges", includeSchemaChanges);
+ return this;
+ }
+ /**
+ * The maximum size of chunk for incremental snapshotting.
+ *
+ * The option is a: <code>int</code> type.
+ *
+ * Default: 1024
+ * Group: db2
+ *
+ * @param incrementalSnapshotChunkSize the value to set
+ * @return the dsl builder
+ */
+ default DebeziumDb2EndpointBuilder incrementalSnapshotChunkSize(
+ int incrementalSnapshotChunkSize) {
+ doSetProperty("incrementalSnapshotChunkSize", incrementalSnapshotChunkSize);
+ return this;
+ }
+ /**
+ * The maximum size of chunk for incremental snapshotting.
+ *
+ * The option will be converted to a <code>int</code> type.
+ *
+ * Default: 1024
+ * Group: db2
+ *
+ * @param incrementalSnapshotChunkSize the value to set
+ * @return the dsl builder
+ */
+ default DebeziumDb2EndpointBuilder incrementalSnapshotChunkSize(
+ String incrementalSnapshotChunkSize) {
+ doSetProperty("incrementalSnapshotChunkSize", incrementalSnapshotChunkSize);
+ return this;
+ }
/**
* Maximum size of each batch of source records. Defaults to 2048.
*
@@ -817,6 +1128,65 @@ public interface DebeziumDb2EndpointBuilderFactory {
doSetProperty("maxQueueSize", maxQueueSize);
return this;
}
+ /**
+ * Maximum size of the queue in bytes for change events read from the
+ * database log but not yet recorded or forwarded. Defaults to 0. Mean
+ * the feature is not enabled.
+ *
+ * The option is a: <code>long</code> type.
+ *
+ * Default: 0
+ * Group: db2
+ *
+ * @param maxQueueSizeInBytes the value to set
+ * @return the dsl builder
+ */
+ default DebeziumDb2EndpointBuilder maxQueueSizeInBytes(
+ long maxQueueSizeInBytes) {
+ doSetProperty("maxQueueSizeInBytes", maxQueueSizeInBytes);
+ return this;
+ }
+ /**
+ * Maximum size of the queue in bytes for change events read from the
+ * database log but not yet recorded or forwarded. Defaults to 0. Mean
+ * the feature is not enabled.
+ *
+ * The option will be converted to a <code>long</code> type.
+ *
+ * Default: 0
+ * Group: db2
+ *
+ * @param maxQueueSizeInBytes the value to set
+ * @return the dsl builder
+ */
+ default DebeziumDb2EndpointBuilder maxQueueSizeInBytes(
+ String maxQueueSizeInBytes) {
+ doSetProperty("maxQueueSizeInBytes", maxQueueSizeInBytes);
+ return this;
+ }
+ /**
+ * A semicolon-separated list of expressions that match fully-qualified
+ * tables and column(s) to be used as message key. Each expression must
+ * match the pattern ':',where the table names could be defined as
+ * (DB_NAME.TABLE_NAME) or (SCHEMA_NAME.TABLE_NAME), depending on the
+ * specific connector,and the key columns are a comma-separated list of
+ * columns representing the custom key. For any table without an
+ * explicit key configuration the table's primary key column(s) will be
+ * used as message key.Example:
+ * dbserver1.inventory.orderlines:orderId,orderLineId;dbserver1.inventory.orders:id.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: db2
+ *
+ * @param messageKeyColumns the value to set
+ * @return the dsl builder
+ */
+ default DebeziumDb2EndpointBuilder messageKeyColumns(
+ String messageKeyColumns) {
+ doSetProperty("messageKeyColumns", messageKeyColumns);
+ return this;
+ }
/**
* Time to wait for new change events to appear after receiving no
* events, given in milliseconds. Defaults to 500 ms.
@@ -849,6 +1219,191 @@ public interface DebeziumDb2EndpointBuilderFactory {
doSetProperty("pollIntervalMs", pollIntervalMs);
return this;
}
+ /**
+ * Enables transaction metadata extraction together with event counting.
+ *
+ * The option is a: <code>boolean</code> type.
+ *
+ * Default: false
+ * Group: db2
+ *
+ * @param provideTransactionMetadata the value to set
+ * @return the dsl builder
+ */
+ default DebeziumDb2EndpointBuilder provideTransactionMetadata(
+ boolean provideTransactionMetadata) {
+ doSetProperty("provideTransactionMetadata", provideTransactionMetadata);
+ return this;
+ }
+ /**
+ * Enables transaction metadata extraction together with event counting.
+ *
+ * The option will be converted to a <code>boolean</code>
+ * type.
+ *
+ * Default: false
+ * Group: db2
+ *
+ * @param provideTransactionMetadata the value to set
+ * @return the dsl builder
+ */
+ default DebeziumDb2EndpointBuilder provideTransactionMetadata(
+ String provideTransactionMetadata) {
+ doSetProperty("provideTransactionMetadata", provideTransactionMetadata);
+ return this;
+ }
+ /**
+ * The maximum number of records that should be loaded into memory while
+ * streaming. A value of 0 uses the default JDBC fetch size.
+ *
+ * The option is a: <code>int</code> type.
+ *
+ * Default: 0
+ * Group: db2
+ *
+ * @param queryFetchSize the value to set
+ * @return the dsl builder
+ */
+ default DebeziumDb2EndpointBuilder queryFetchSize(int queryFetchSize) {
+ doSetProperty("queryFetchSize", queryFetchSize);
+ return this;
+ }
+ /**
+ * The maximum number of records that should be loaded into memory while
+ * streaming. A value of 0 uses the default JDBC fetch size.
+ *
+ * The option will be converted to a <code>int</code> type.
+ *
+ * Default: 0
+ * Group: db2
+ *
+ * @param queryFetchSize the value to set
+ * @return the dsl builder
+ */
+ default DebeziumDb2EndpointBuilder queryFetchSize(String queryFetchSize) {
+ doSetProperty("queryFetchSize", queryFetchSize);
+ return this;
+ }
+ /**
+ * Time to wait before restarting connector after retriable exception
+ * occurs. Defaults to 10000ms.
+ *
+ * The option is a: <code>long</code> type.
+ *
+ * Default: 10s
+ * Group: db2
+ *
+ * @param retriableRestartConnectorWaitMs the value to set
+ * @return the dsl builder
+ */
+ default DebeziumDb2EndpointBuilder retriableRestartConnectorWaitMs(
+ long retriableRestartConnectorWaitMs) {
+ doSetProperty("retriableRestartConnectorWaitMs", retriableRestartConnectorWaitMs);
+ return this;
+ }
+ /**
+ * Time to wait before restarting connector after retriable exception
+ * occurs. Defaults to 10000ms.
+ *
+ * The option will be converted to a <code>long</code> type.
+ *
+ * Default: 10s
+ * Group: db2
+ *
+ * @param retriableRestartConnectorWaitMs the value to set
+ * @return the dsl builder
+ */
+ default DebeziumDb2EndpointBuilder retriableRestartConnectorWaitMs(
+ String retriableRestartConnectorWaitMs) {
+ doSetProperty("retriableRestartConnectorWaitMs", retriableRestartConnectorWaitMs);
+ return this;
+ }
+ /**
+ * Whether field names will be sanitized to Avro naming conventions.
+ *
+ * The option is a: <code>boolean</code> type.
+ *
+ * Default: false
+ * Group: db2
+ *
+ * @param sanitizeFieldNames the value to set
+ * @return the dsl builder
+ */
+ default DebeziumDb2EndpointBuilder sanitizeFieldNames(
+ boolean sanitizeFieldNames) {
+ doSetProperty("sanitizeFieldNames", sanitizeFieldNames);
+ return this;
+ }
+ /**
+ * Whether field names will be sanitized to Avro naming conventions.
+ *
+ * The option will be converted to a <code>boolean</code>
+ * type.
+ *
+ * Default: false
+ * Group: db2
+ *
+ * @param sanitizeFieldNames the value to set
+ * @return the dsl builder
+ */
+ default DebeziumDb2EndpointBuilder sanitizeFieldNames(
+ String sanitizeFieldNames) {
+ doSetProperty("sanitizeFieldNames", sanitizeFieldNames);
+ return this;
+ }
+ /**
+ * Specify how schema names should be adjusted for compatibility with
+ * the message converter used by the connector, including:'avro'
+ * replaces the characters that cannot be used in the Avro type name
+ * with underscore (default)'none' does not apply any adjustment.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Default: avro
+ * Group: db2
+ *
+ * @param schemaNameAdjustmentMode the value to set
+ * @return the dsl builder
+ */
+ default DebeziumDb2EndpointBuilder schemaNameAdjustmentMode(
+ String schemaNameAdjustmentMode) {
+ doSetProperty("schemaNameAdjustmentMode", schemaNameAdjustmentMode);
+ return this;
+ }
+ /**
+ * The name of the data collection that is used to send signals/commands
+ * to Debezium. Signaling is disabled when not set.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: db2
+ *
+ * @param signalDataCollection the value to set
+ * @return the dsl builder
+ */
+ default DebeziumDb2EndpointBuilder signalDataCollection(
+ String signalDataCollection) {
+ doSetProperty("signalDataCollection", signalDataCollection);
+ return this;
+ }
+ /**
+ * The comma-separated list of operations to skip during streaming,
+ * defined as: 'c' for inserts/create; 'u' for updates; 'd' for deletes,
+ * 't' for truncates, and 'none' to indicate nothing skipped. By
+ * default, no operations will be skipped.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: db2
+ *
+ * @param skippedOperations the value to set
+ * @return the dsl builder
+ */
+ default DebeziumDb2EndpointBuilder skippedOperations(
+ String skippedOperations) {
+ doSetProperty("skippedOperations", skippedOperations);
+ return this;
+ }
/**
* A delay period before a snapshot will begin, given in milliseconds.
* Defaults to 0 ms.
@@ -914,6 +1469,58 @@ public interface DebeziumDb2EndpointBuilderFactory {
doSetProperty("snapshotFetchSize", snapshotFetchSize);
return this;
}
+ /**
+ * this setting must be set to specify a list of tables/collections
+ * whose snapshot must be taken on creating or restarting the connector.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: db2
+ *
+ * @param snapshotIncludeCollectionList the value to set
+ * @return the dsl builder
+ */
+ default DebeziumDb2EndpointBuilder snapshotIncludeCollectionList(
+ String snapshotIncludeCollectionList) {
+ doSetProperty("snapshotIncludeCollectionList", snapshotIncludeCollectionList);
+ return this;
+ }
+ /**
+ * The maximum number of millis to wait for table locks at the beginning
+ * of a snapshot. If locks cannot be acquired in this time frame, the
+ * snapshot will be aborted. Defaults to 10 seconds.
+ *
+ * The option is a: <code>long</code> type.
+ *
+ * Default: 10s
+ * Group: db2
+ *
+ * @param snapshotLockTimeoutMs the value to set
+ * @return the dsl builder
+ */
+ default DebeziumDb2EndpointBuilder snapshotLockTimeoutMs(
+ long snapshotLockTimeoutMs) {
+ doSetProperty("snapshotLockTimeoutMs", snapshotLockTimeoutMs);
+ return this;
+ }
+ /**
+ * The maximum number of millis to wait for table locks at the beginning
+ * of a snapshot. If locks cannot be acquired in this time frame, the
+ * snapshot will be aborted. Defaults to 10 seconds.
+ *
+ * The option will be converted to a <code>long</code> type.
+ *
+ * Default: 10s
+ * Group: db2
+ *
+ * @param snapshotLockTimeoutMs the value to set
+ * @return the dsl builder
+ */
+ default DebeziumDb2EndpointBuilder snapshotLockTimeoutMs(
+ String snapshotLockTimeoutMs) {
+ doSetProperty("snapshotLockTimeoutMs", snapshotLockTimeoutMs);
+ return this;
+ }
/**
* The criteria for running a snapshot upon startup of the connector.
* Options include: 'initial' (the default) to specify the connector
@@ -1095,6 +1702,65 @@ public interface DebeziumDb2EndpointBuilderFactory {
doSetProperty("timePrecisionMode", timePrecisionMode);
return this;
}
+ /**
+ * Whether delete operations should be represented by a delete event and
+ * a subsquenttombstone event (true) or only by a delete event (false).
+ * Emitting the tombstone event (the default behavior) allows Kafka to
+ * completely delete all events pertaining to the given key once the
+ * source record got deleted.
+ *
+ * The option is a: <code>boolean</code> type.
+ *
+ * Default: false
+ * Group: db2
+ *
+ * @param tombstonesOnDelete the value to set
+ * @return the dsl builder
+ */
+ default DebeziumDb2EndpointBuilder tombstonesOnDelete(
+ boolean tombstonesOnDelete) {
+ doSetProperty("tombstonesOnDelete", tombstonesOnDelete);
+ return this;
+ }
+ /**
+ * Whether delete operations should be represented by a delete event and
+ * a subsquenttombstone event (true) or only by a delete event (false).
+ * Emitting the tombstone event (the default behavior) allows Kafka to
+ * completely delete all events pertaining to the given key once the
+ * source record got deleted.
+ *
+ * The option will be converted to a <code>boolean</code>
+ * type.
+ *
+ * Default: false
+ * Group: db2
+ *
+ * @param tombstonesOnDelete the value to set
+ * @return the dsl builder
+ */
+ default DebeziumDb2EndpointBuilder tombstonesOnDelete(
+ String tombstonesOnDelete) {
+ doSetProperty("tombstonesOnDelete", tombstonesOnDelete);
+ return this;
+ }
+ /**
+ * The name of the transaction metadata topic. The placeholder
+ * ${database.server.name} can be used for referring to the connector's
+ * logical name; defaults to ${database.server.name}.transaction.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Default: ${database.server.name}.transaction
+ * Group: db2
+ *
+ * @param transactionTopic the value to set
+ * @return the dsl builder
+ */
+ default DebeziumDb2EndpointBuilder transactionTopic(
+ String transactionTopic) {
+ doSetProperty("transactionTopic", transactionTopic);
+ return this;
+ }
}
/**
diff --git a/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/DebeziumMongodbEndpointBuilderFactory.java b/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/DebeziumMongodbEndpointBuilderFactory.java
index 53e6667e704..ca0abf15bf6 100644
--- a/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/DebeziumMongodbEndpointBuilderFactory.java
+++ b/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/DebeziumMongodbEndpointBuilderFactory.java
@@ -949,8 +949,8 @@ public interface DebeziumMongodbEndpointBuilderFactory {
}
/**
* Unique name that identifies the MongoDB replica set or cluster and
- * all recorded offsets, andthat is used as a prefix for all schemas and
- * topics. Each distinct MongoDB installation should have a separate
+ * all recorded offsets, and that is used as a prefix for all schemas
+ * and topics. Each distinct MongoDB installation should have a separate
* namespace and monitored by at most one Debezium connector.
*
* The option is a: <code>java.lang.String</code> type.
@@ -1330,6 +1330,25 @@ public interface DebeziumMongodbEndpointBuilderFactory {
doSetProperty("sanitizeFieldNames", sanitizeFieldNames);
return this;
}
+ /**
+ * Specify how schema names should be adjusted for compatibility with
+ * the message converter used by the connector, including:'avro'
+ * replaces the characters that cannot be used in the Avro type name
+ * with underscore (default)'none' does not apply any adjustment.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Default: avro
+ * Group: mongodb
+ *
+ * @param schemaNameAdjustmentMode the value to set
+ * @return the dsl builder
+ */
+ default DebeziumMongodbEndpointBuilder schemaNameAdjustmentMode(
+ String schemaNameAdjustmentMode) {
+ doSetProperty("schemaNameAdjustmentMode", schemaNameAdjustmentMode);
+ return this;
+ }
/**
* The name of the data collection that is used to send signals/commands
* to Debezium. Signaling is disabled when not set.
@@ -1348,8 +1367,9 @@ public interface DebeziumMongodbEndpointBuilderFactory {
}
/**
* The comma-separated list of operations to skip during streaming,
- * defined as: 'c' for inserts/create; 'u' for updates; 'd' for deletes.
- * By default, no operations will be skipped.
+ * defined as: 'c' for inserts/create; 'u' for updates; 'd' for deletes,
+ * 't' for truncates, and 'none' to indicate nothing skipped. By
+ * default, no operations will be skipped.
*
* The option is a: <code>java.lang.String</code> type.
*
diff --git a/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/DebeziumMySqlEndpointBuilderFactory.java b/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/DebeziumMySqlEndpointBuilderFactory.java
index 2172d044005..b0334e968ee 100644
--- a/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/DebeziumMySqlEndpointBuilderFactory.java
+++ b/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/DebeziumMySqlEndpointBuilderFactory.java
@@ -724,6 +724,40 @@ public interface DebeziumMySqlEndpointBuilderFactory {
doSetProperty("databaseHistoryKafkaBootstrapServers", databaseHistoryKafkaBootstrapServers);
return this;
}
+ /**
+ * The number of milliseconds to wait while fetching cluster information
+ * using Kafka admin client.
+ *
+ * The option is a: <code>long</code> type.
+ *
+ * Default: 3s
+ * Group: mysql
+ *
+ * @param databaseHistoryKafkaQueryTimeoutMs the value to set
+ * @return the dsl builder
+ */
+ default DebeziumMySqlEndpointBuilder databaseHistoryKafkaQueryTimeoutMs(
+ long databaseHistoryKafkaQueryTimeoutMs) {
+ doSetProperty("databaseHistoryKafkaQueryTimeoutMs", databaseHistoryKafkaQueryTimeoutMs);
+ return this;
+ }
+ /**
+ * The number of milliseconds to wait while fetching cluster information
+ * using Kafka admin client.
+ *
+ * The option will be converted to a <code>long</code> type.
+ *
+ * Default: 3s
+ * Group: mysql
+ *
+ * @param databaseHistoryKafkaQueryTimeoutMs the value to set
+ * @return the dsl builder
+ */
+ default DebeziumMySqlEndpointBuilder databaseHistoryKafkaQueryTimeoutMs(
+ String databaseHistoryKafkaQueryTimeoutMs) {
+ doSetProperty("databaseHistoryKafkaQueryTimeoutMs", databaseHistoryKafkaQueryTimeoutMs);
+ return this;
+ }
/**
* The number of attempts in a row that no data are returned from Kafka
* before recover completes. The maximum amount of time to wait after
@@ -1140,8 +1174,8 @@ public interface DebeziumMySqlEndpointBuilderFactory {
return this;
}
/**
- * Location of the Java keystore file containing an application
- * process's own certificate and private key.
+ * The location of the key store file. This is optional and can be used
+ * for two-way authentication between the client and the MySQL Server.
*
* The option is a: <code>java.lang.String</code> type.
*
@@ -1156,11 +1190,8 @@ public interface DebeziumMySqlEndpointBuilderFactory {
return this;
}
/**
- * Password to access the private key from the keystore file specified
- * by 'ssl.keystore' configuration property or the
- * 'javax.net.ssl.keyStore' system or JVM property. This password is
- * used to unlock the keystore file (store password), and to decrypt the
- * private key stored in the keystore (key password).
+ * The password for the key store file. This is optional and only needed
+ * if 'database.ssl.keystore' is configured.
*
* The option is a: <code>java.lang.String</code> type.
*
@@ -1201,8 +1232,8 @@ public interface DebeziumMySqlEndpointBuilderFactory {
return this;
}
/**
- * Location of the Java truststore file containing the collection of CA
- * certificates trusted by this application process (trust store).
+ * The location of the trust store file for the server certificate
+ * verification.
*
* The option is a: <code>java.lang.String</code> type.
*
@@ -1217,9 +1248,8 @@ public interface DebeziumMySqlEndpointBuilderFactory {
return this;
}
/**
- * Password to unlock the keystore file (store password) specified by
- * 'ssl.trustore' configuration property or the
- * 'javax.net.ssl.trustStore' system or JVM property.
+ * The password for the trust store file. Used to check the integrity of
+ * the truststore, and unlock the truststore.
*
* The option is a: <code>java.lang.String</code> type.
*
@@ -2066,6 +2096,25 @@ public interface DebeziumMySqlEndpointBuilderFactory {
doSetProperty("sanitizeFieldNames", sanitizeFieldNames);
return this;
}
+ /**
+ * Specify how schema names should be adjusted for compatibility with
+ * the message converter used by the connector, including:'avro'
+ * replaces the characters that cannot be used in the Avro type name
+ * with underscore (default)'none' does not apply any adjustment.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Default: avro
+ * Group: mysql
+ *
+ * @param schemaNameAdjustmentMode the value to set
+ * @return the dsl builder
+ */
+ default DebeziumMySqlEndpointBuilder schemaNameAdjustmentMode(
+ String schemaNameAdjustmentMode) {
+ doSetProperty("schemaNameAdjustmentMode", schemaNameAdjustmentMode);
+ return this;
+ }
/**
* The name of the data collection that is used to send signals/commands
* to Debezium. Signaling is disabled when not set.
@@ -2084,8 +2133,9 @@ public interface DebeziumMySqlEndpointBuilderFactory {
}
/**
* The comma-separated list of operations to skip during streaming,
- * defined as: 'c' for inserts/create; 'u' for updates; 'd' for deletes.
- * By default, no operations will be skipped.
+ * defined as: 'c' for inserts/create; 'u' for updates; 'd' for deletes,
+ * 't' for truncates, and 'none' to indicate nothing skipped. By
+ * default, no operations will be skipped.
*
* The option is a: <code>java.lang.String</code> type.
*
diff --git a/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/DebeziumOracleEndpointBuilderFactory.java b/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/DebeziumOracleEndpointBuilderFactory.java
index 432c5148ea8..e008283098c 100644
--- a/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/DebeziumOracleEndpointBuilderFactory.java
+++ b/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/DebeziumOracleEndpointBuilderFactory.java
@@ -577,6 +577,40 @@ public interface DebeziumOracleEndpointBuilderFactory {
doSetProperty("databaseHistoryKafkaBootstrapServers", databaseHistoryKafkaBootstrapServers);
return this;
}
+ /**
+ * The number of milliseconds to wait while fetching cluster information
+ * using Kafka admin client.
+ *
+ * The option is a: <code>long</code> type.
+ *
+ * Default: 3s
+ * Group: oracle
+ *
+ * @param databaseHistoryKafkaQueryTimeoutMs the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleEndpointBuilder databaseHistoryKafkaQueryTimeoutMs(
+ long databaseHistoryKafkaQueryTimeoutMs) {
+ doSetProperty("databaseHistoryKafkaQueryTimeoutMs", databaseHistoryKafkaQueryTimeoutMs);
+ return this;
+ }
+ /**
+ * The number of milliseconds to wait while fetching cluster information
+ * using Kafka admin client.
+ *
+ * The option will be converted to a <code>long</code> type.
+ *
+ * Default: 3s
+ * Group: oracle
+ *
+ * @param databaseHistoryKafkaQueryTimeoutMs the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleEndpointBuilder databaseHistoryKafkaQueryTimeoutMs(
+ String databaseHistoryKafkaQueryTimeoutMs) {
+ doSetProperty("databaseHistoryKafkaQueryTimeoutMs", databaseHistoryKafkaQueryTimeoutMs);
+ return this;
+ }
/**
* The number of attempts in a row that no data are returned from Kafka
* before recover completes. The maximum amount of time to wait after
@@ -2143,6 +2177,25 @@ public interface DebeziumOracleEndpointBuilderFactory {
doSetProperty("sanitizeFieldNames", sanitizeFieldNames);
return this;
}
+ /**
+ * Specify how schema names should be adjusted for compatibility with
+ * the message converter used by the connector, including:'avro'
+ * replaces the characters that cannot be used in the Avro type name
+ * with underscore (default)'none' does not apply any adjustment.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Default: avro
+ * Group: oracle
+ *
+ * @param schemaNameAdjustmentMode the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleEndpointBuilder schemaNameAdjustmentMode(
+ String schemaNameAdjustmentMode) {
+ doSetProperty("schemaNameAdjustmentMode", schemaNameAdjustmentMode);
+ return this;
+ }
/**
* The name of the data collection that is used to send signals/commands
* to Debezium. Signaling is disabled when not set.
@@ -2161,8 +2214,9 @@ public interface DebeziumOracleEndpointBuilderFactory {
}
/**
* The comma-separated list of operations to skip during streaming,
- * defined as: 'c' for inserts/create; 'u' for updates; 'd' for deletes.
- * By default, no operations will be skipped.
+ * defined as: 'c' for inserts/create; 'u' for updates; 'd' for deletes,
+ * 't' for truncates, and 'none' to indicate nothing skipped. By
+ * default, no operations will be skipped.
*
* The option is a: <code>java.lang.String</code> type.
*
diff --git a/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/DebeziumPostgresEndpointBuilderFactory.java b/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/DebeziumPostgresEndpointBuilderFactory.java
index 58b6b609b6b..7631df69a8c 100644
--- a/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/DebeziumPostgresEndpointBuilderFactory.java
+++ b/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/DebeziumPostgresEndpointBuilderFactory.java
@@ -1217,9 +1217,8 @@ public interface DebeziumPostgresEndpointBuilderFactory {
}
/**
* The name of the Postgres logical decoding plugin installed on the
- * server. Supported values are 'decoderbufs', 'wal2json', 'pgoutput',
- * 'wal2json_streaming', 'wal2json_rds' and 'wal2json_rds_streaming'.
- * Defaults to 'decoderbufs'.
+ * server. Supported values are 'decoderbufs' and 'pgoutput'. Defaults
+ * to 'decoderbufs'.
*
* The option is a: <code>java.lang.String</code> type.
*
@@ -1493,6 +1492,25 @@ public interface DebeziumPostgresEndpointBuilderFactory {
doSetProperty("schemaIncludeList", schemaIncludeList);
return this;
}
+ /**
+ * Specify how schema names should be adjusted for compatibility with
+ * the message converter used by the connector, including:'avro'
+ * replaces the characters that cannot be used in the Avro type name
+ * with underscore (default)'none' does not apply any adjustment.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Default: avro
+ * Group: postgres
+ *
+ * @param schemaNameAdjustmentMode the value to set
+ * @return the dsl builder
+ */
+ default DebeziumPostgresEndpointBuilder schemaNameAdjustmentMode(
+ String schemaNameAdjustmentMode) {
+ doSetProperty("schemaNameAdjustmentMode", schemaNameAdjustmentMode);
+ return this;
+ }
/**
* Specify the conditions that trigger a refresh of the in-memory schema
* for a table. 'columns_diff' (the default) is the safest mode,
@@ -1554,11 +1572,13 @@ public interface DebeziumPostgresEndpointBuilderFactory {
}
/**
* The comma-separated list of operations to skip during streaming,
- * defined as: 'c' for inserts/create; 'u' for updates; 'd' for deletes.
- * By default, no operations will be skipped.
+ * defined as: 'c' for inserts/create; 'u' for updates; 'd' for deletes,
+ * 't' for truncates, and 'none' to indicate nothing skipped. By
+ * default, no operations will be skipped.
*
* The option is a: <code>java.lang.String</code> type.
*
+ * Default: t
* Group: postgres
*
* @param skippedOperations the value to set
@@ -2162,25 +2182,6 @@ public interface DebeziumPostgresEndpointBuilderFactory {
doSetProperty("transactionTopic", transactionTopic);
return this;
}
- /**
- * Specify how TRUNCATE operations are handled for change events
- * (supported only on pg11 pgoutput plugin), including: 'skip' to skip /
- * ignore TRUNCATE events (default), 'include' to handle and include
- * TRUNCATE events.
- *
- * The option is a: <code>java.lang.String</code> type.
- *
- * Default: skip
- * Group: postgres
- *
- * @param truncateHandlingMode the value to set
- * @return the dsl builder
- */
- default DebeziumPostgresEndpointBuilder truncateHandlingMode(
- String truncateHandlingMode) {
- doSetProperty("truncateHandlingMode", truncateHandlingMode);
- return this;
- }
/**
* Specify the constant that will be provided by Debezium to indicate
* that the original value is a toasted value not provided by the
diff --git a/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/DebeziumSqlserverEndpointBuilderFactory.java b/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/DebeziumSqlserverEndpointBuilderFactory.java
index f92c950b578..04d4fb4b145 100644
--- a/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/DebeziumSqlserverEndpointBuilderFactory.java
+++ b/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/DebeziumSqlserverEndpointBuilderFactory.java
@@ -560,6 +560,40 @@ public interface DebeziumSqlserverEndpointBuilderFactory {
doSetProperty("databaseHistoryKafkaBootstrapServers", databaseHistoryKafkaBootstrapServers);
return this;
}
+ /**
+ * The number of milliseconds to wait while fetching cluster information
+ * using Kafka admin client.
+ *
+ * The option is a: <code>long</code> type.
+ *
+ * Default: 3s
+ * Group: sqlserver
+ *
+ * @param databaseHistoryKafkaQueryTimeoutMs the value to set
+ * @return the dsl builder
+ */
+ default DebeziumSqlserverEndpointBuilder databaseHistoryKafkaQueryTimeoutMs(
+ long databaseHistoryKafkaQueryTimeoutMs) {
+ doSetProperty("databaseHistoryKafkaQueryTimeoutMs", databaseHistoryKafkaQueryTimeoutMs);
+ return this;
+ }
+ /**
+ * The number of milliseconds to wait while fetching cluster information
+ * using Kafka admin client.
+ *
+ * The option will be converted to a <code>long</code> type.
+ *
+ * Default: 3s
+ * Group: sqlserver
+ *
+ * @param databaseHistoryKafkaQueryTimeoutMs the value to set
+ * @return the dsl builder
+ */
+ default DebeziumSqlserverEndpointBuilder databaseHistoryKafkaQueryTimeoutMs(
+ String databaseHistoryKafkaQueryTimeoutMs) {
+ doSetProperty("databaseHistoryKafkaQueryTimeoutMs", databaseHistoryKafkaQueryTimeoutMs);
+ return this;
+ }
/**
* The number of attempts in a row that no data are returned from Kafka
* before recover completes. The maximum amount of time to wait after
@@ -1555,6 +1589,25 @@ public interface DebeziumSqlserverEndpointBuilderFactory {
doSetProperty("sanitizeFieldNames", sanitizeFieldNames);
return this;
}
+ /**
+ * Specify how schema names should be adjusted for compatibility with
+ * the message converter used by the connector, including:'avro'
+ * replaces the characters that cannot be used in the Avro type name
+ * with underscore (default)'none' does not apply any adjustment.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Default: avro
+ * Group: sqlserver
+ *
+ * @param schemaNameAdjustmentMode the value to set
+ * @return the dsl builder
+ */
+ default DebeziumSqlserverEndpointBuilder schemaNameAdjustmentMode(
+ String schemaNameAdjustmentMode) {
+ doSetProperty("schemaNameAdjustmentMode", schemaNameAdjustmentMode);
+ return this;
+ }
/**
* The name of the data collection that is used to send signals/commands
* to Debezium. Signaling is disabled when not set.
@@ -1573,8 +1626,9 @@ public interface DebeziumSqlserverEndpointBuilderFactory {
}
/**
* The comma-separated list of operations to skip during streaming,
- * defined as: 'c' for inserts/create; 'u' for updates; 'd' for deletes.
- * By default, no operations will be skipped.
+ * defined as: 'c' for inserts/create; 'u' for updates; 'd' for deletes,
+ * 't' for truncates, and 'none' to indicate nothing skipped. By
+ * default, no operations will be skipped.
*
* The option is a: <code>java.lang.String</code> type.
*