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-spring-boot.git
The following commit(s) were added to refs/heads/main by this push:
new 7fe8611e154 Regen
7fe8611e154 is described below
commit 7fe8611e154b604f7db9aa6428924cb900879c6b
Author: Claus Ibsen <[email protected]>
AuthorDate: Fri Apr 29 06:30:18 2022 +0200
Regen
---
.../catalog/components/debezium-mongodb.json | 10 ++--
.../catalog/components/debezium-mysql.json | 28 +++++----
.../catalog/components/debezium-postgres.json | 12 ++--
.../catalog/components/debezium-sqlserver.json | 8 ++-
.../src/main/docs/debezium-mongodb.json | 11 +++-
.../DebeziumMongodbComponentConfiguration.java | 26 +++++++--
.../src/main/docs/debezium-mysql.json | 26 +++++++--
.../DebeziumMySqlComponentConfiguration.java | 56 +++++++++++++-----
.../src/main/docs/debezium-postgres.json | 21 +++----
.../DebeziumPostgresComponentConfiguration.java | 42 +++++++-------
.../src/main/docs/debezium-sqlserver.json | 16 +++++-
.../DebeziumSqlserverComponentConfiguration.java | 34 ++++++++++-
tooling/camel-spring-boot-dependencies/pom.xml | 66 +++++++++++-----------
13 files changed, 237 insertions(+), 119 deletions(-)
diff --git
a/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/debezium-mongodb.json
b/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/debezium-mongodb.json
index fcba9f7d3c1..73d9bda7f23 100644
---
a/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/debezium-mongodb.json
+++
b/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/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-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/debezium-mysql.json
b/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/debezium-mysql.json
index 8066a1afc4b..59d13a591ec 100644
---
a/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/debezium-mysql.json
+++
b/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/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 [...]
@@ -61,17 +62,17 @@
"databaseHostname": { "kind": "property", "displayName": "Database
Hostname", "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": "Resolvable hostname or
IP address of the database server." },
"databaseIncludeList": { "kind": "property", "displayName": "Database
Include 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": "The databases for which
changes are to be captured" },
"databaseInitialStatements": { "kind": "property", "displayName":
"Database Initial Statements", "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 semicolon separated
list of SQL statements [...]
- "databaseJdbcDriver": { "kind": "property", "displayName": "Database Jdbc
Driver", "group": "mysql", "label": "consumer,mysql", "required": false,
"type": "string", "javaType": "java.lang.String", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": "class
com.mysql.cj.jdbc.Driver", "configurationClass":
"org.apache.camel.component.debezium.configuration.MySqlConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "JDBC Driv [...]
+ "databaseJdbcDriver": { "kind": "property", "displayName": "Database Jdbc
Driver", "group": "mysql", "label": "consumer,mysql", "required": false,
"type": "string", "javaType": "java.lang.String", "deprecated": false,
"autowired": false, "secret": false, "defaultValue":
"com.mysql.cj.jdbc.Driver", "configurationClass":
"org.apache.camel.component.debezium.configuration.MySqlConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "JDBC Driver cla [...]
"databasePassword": { "kind": "property", "displayName": "Database
Password", "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": "Password of the
database user to be used w [...]
"databasePort": { "kind": "property", "displayName": "Database Port",
"group": "mysql", "label": "consumer,mysql", "required": false, "type":
"integer", "javaType": "int", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": 3306, "configurationClass":
"org.apache.camel.component.debezium.configuration.MySqlConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "Port of the database
server." },
"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 [...]
@@ -171,17 +174,17 @@
"databaseHostname": { "kind": "parameter", "displayName": "Database
Hostname", "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": "Resolvable hostname or
IP address of the database server." },
"databaseIncludeList": { "kind": "parameter", "displayName": "Database
Include 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": "The databases for which
changes are to be captured" },
"databaseInitialStatements": { "kind": "parameter", "displayName":
"Database Initial Statements", "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 semicolon separated
list of SQL statements [...]
- "databaseJdbcDriver": { "kind": "parameter", "displayName": "Database Jdbc
Driver", "group": "mysql", "label": "consumer,mysql", "required": false,
"type": "string", "javaType": "java.lang.String", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": "class
com.mysql.cj.jdbc.Driver", "configurationClass":
"org.apache.camel.component.debezium.configuration.MySqlConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "JDBC Dri [...]
+ "databaseJdbcDriver": { "kind": "parameter", "displayName": "Database Jdbc
Driver", "group": "mysql", "label": "consumer,mysql", "required": false,
"type": "string", "javaType": "java.lang.String", "deprecated": false,
"autowired": false, "secret": false, "defaultValue":
"com.mysql.cj.jdbc.Driver", "configurationClass":
"org.apache.camel.component.debezium.configuration.MySqlConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "JDBC Driver cl [...]
"databasePassword": { "kind": "parameter", "displayName": "Database
Password", "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": "Password of the
database user to be used [...]
"databasePort": { "kind": "parameter", "displayName": "Database Port",
"group": "mysql", "label": "consumer,mysql", "required": false, "type":
"integer", "javaType": "int", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": 3306, "configurationClass":
"org.apache.camel.component.debezium.configuration.MySqlConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "Port of the database
server." },
"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-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/debezium-postgres.json
b/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/debezium-postgres.json
index 0a3f0be29d6..64fcfec3466 100644
---
a/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/debezium-postgres.json
+++
b/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/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-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/debezium-sqlserver.json
b/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/debezium-sqlserver.json
index 7ca3a5e6fd8..bd9ee3f5179 100644
---
a/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/debezium-sqlserver.json
+++
b/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/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-starter/camel-debezium-mongodb-starter/src/main/docs/debezium-mongodb.json
b/components-starter/camel-debezium-mongodb-starter/src/main/docs/debezium-mongodb.json
index 3c968aa2503..d2af2dff9c1 100644
---
a/components-starter/camel-debezium-mongodb-starter/src/main/docs/debezium-mongodb.json
+++
b/components-starter/camel-debezium-mongodb-starter/src/main/docs/debezium-mongodb.json
@@ -218,7 +218,7 @@
{
"name": "camel.component.debezium-mongodb.mongodb-name",
"type": "java.lang.String",
- "description": "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 namespace
and monitored by at most one Debezium connector.",
+ "description": "Unique name that identifies the MongoDB replica set or
cluster and 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.",
"sourceType":
"org.apache.camel.component.debezium.springboot.DebeziumMongodbComponentConfiguration"
},
{
@@ -355,6 +355,13 @@
"sourceType":
"org.apache.camel.component.debezium.springboot.DebeziumMongodbComponentConfiguration",
"defaultValue": false
},
+ {
+ "name": "camel.component.debezium-mongodb.schema-name-adjustment-mode",
+ "type": "java.lang.String",
+ "description": "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",
+ "sourceType":
"org.apache.camel.component.debezium.springboot.DebeziumMongodbComponentConfiguration",
+ "defaultValue": "avro"
+ },
{
"name": "camel.component.debezium-mongodb.signal-data-collection",
"type": "java.lang.String",
@@ -364,7 +371,7 @@
{
"name": "camel.component.debezium-mongodb.skipped-operations",
"type": "java.lang.String",
- "description": "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.",
+ "description": "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.",
"sourceType":
"org.apache.camel.component.debezium.springboot.DebeziumMongodbComponentConfiguration"
},
{
diff --git
a/components-starter/camel-debezium-mongodb-starter/src/main/java/org/apache/camel/component/debezium/springboot/DebeziumMongodbComponentConfiguration.java
b/components-starter/camel-debezium-mongodb-starter/src/main/java/org/apache/camel/component/debezium/springboot/DebeziumMongodbComponentConfiguration.java
index 9c6b1c3b5d1..8c97d24e9a5 100644
---
a/components-starter/camel-debezium-mongodb-starter/src/main/java/org/apache/camel/component/debezium/springboot/DebeziumMongodbComponentConfiguration.java
+++
b/components-starter/camel-debezium-mongodb-starter/src/main/java/org/apache/camel/component/debezium/springboot/DebeziumMongodbComponentConfiguration.java
@@ -264,9 +264,9 @@ public class DebeziumMongodbComponentConfiguration
private Boolean mongodbMembersAutoDiscover = true;
/**
* 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 namespace and
- * monitored by at most one Debezium connector.
+ * 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.
*/
private String mongodbName;
/**
@@ -325,6 +325,13 @@ public class DebeziumMongodbComponentConfiguration
* Whether field names will be sanitized to Avro naming conventions
*/
private Boolean sanitizeFieldNames = false;
+ /**
+ * 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
+ */
+ private String schemaNameAdjustmentMode = "avro";
/**
* The name of the data collection that is used to send signals/commands to
* Debezium. Signaling is disabled when not set.
@@ -332,8 +339,9 @@ public class DebeziumMongodbComponentConfiguration
private String signalDataCollection;
/**
* 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.
+ * 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.
*/
private String skippedOperations;
/**
@@ -798,6 +806,14 @@ public class DebeziumMongodbComponentConfiguration
this.sanitizeFieldNames = sanitizeFieldNames;
}
+ public String getSchemaNameAdjustmentMode() {
+ return schemaNameAdjustmentMode;
+ }
+
+ public void setSchemaNameAdjustmentMode(String schemaNameAdjustmentMode) {
+ this.schemaNameAdjustmentMode = schemaNameAdjustmentMode;
+ }
+
public String getSignalDataCollection() {
return signalDataCollection;
}
diff --git
a/components-starter/camel-debezium-mysql-starter/src/main/docs/debezium-mysql.json
b/components-starter/camel-debezium-mysql-starter/src/main/docs/debezium-mysql.json
index ef69edcabff..dfb460438db 100644
---
a/components-starter/camel-debezium-mysql-starter/src/main/docs/debezium-mysql.json
+++
b/components-starter/camel-debezium-mysql-starter/src/main/docs/debezium-mysql.json
@@ -147,6 +147,13 @@
"description": "A list of host\/port pairs that the connector will use
for establishing the initial connection to the Kafka cluster for retrieving
database schema history previously stored by the connector. This should point
to the same Kafka cluster used by the Kafka Connect process.",
"sourceType":
"org.apache.camel.component.debezium.springboot.DebeziumMySqlComponentConfiguration"
},
+ {
+ "name":
"camel.component.debezium-mysql.database-history-kafka-query-timeout-ms",
+ "type": "java.lang.Long",
+ "description": "The number of milliseconds to wait while fetching
cluster information using Kafka admin client. The option is a long type.",
+ "sourceType":
"org.apache.camel.component.debezium.springboot.DebeziumMySqlComponentConfiguration",
+ "defaultValue": 3000
+ },
{
"name":
"camel.component.debezium-mysql.database-history-kafka-recovery-attempts",
"type": "java.lang.Integer",
@@ -211,7 +218,7 @@
"type": "java.lang.String",
"description": "JDBC Driver class name used to connect to the MySQL
database server.",
"sourceType":
"org.apache.camel.component.debezium.springboot.DebeziumMySqlComponentConfiguration",
- "defaultValue": "class com.mysql.cj.jdbc.Driver"
+ "defaultValue": "com.mysql.cj.jdbc.Driver"
},
{
"name": "camel.component.debezium-mysql.database-password",
@@ -248,13 +255,13 @@
{
"name": "camel.component.debezium-mysql.database-ssl-keystore",
"type": "java.lang.String",
- "description": "Location of the Java keystore file containing an
application process's own certificate and private key.",
+ "description": "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.",
"sourceType":
"org.apache.camel.component.debezium.springboot.DebeziumMySqlComponentConfiguration"
},
{
"name": "camel.component.debezium-mysql.database-ssl-keystore-password",
"type": "java.lang.String",
- "description": "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).",
+ "description": "The password for the key store file. This is optional
and only needed if 'database.ssl.keystore' is configured.",
"sourceType":
"org.apache.camel.component.debezium.springboot.DebeziumMySqlComponentConfiguration"
},
{
@@ -267,13 +274,13 @@
{
"name": "camel.component.debezium-mysql.database-ssl-truststore",
"type": "java.lang.String",
- "description": "Location of the Java truststore file containing the
collection of CA certificates trusted by this application process (trust
store).",
+ "description": "The location of the trust store file for the server
certificate verification.",
"sourceType":
"org.apache.camel.component.debezium.springboot.DebeziumMySqlComponentConfiguration"
},
{
"name":
"camel.component.debezium-mysql.database-ssl-truststore-password",
"type": "java.lang.String",
- "description": "Password to unlock the keystore file (store password)
specified by 'ssl.trustore' configuration property or the
'javax.net.ssl.trustStore' system or JVM property.",
+ "description": "The password for the trust store file. Used to check the
integrity of the truststore, and unlock the truststore.",
"sourceType":
"org.apache.camel.component.debezium.springboot.DebeziumMySqlComponentConfiguration"
},
{
@@ -538,6 +545,13 @@
"sourceType":
"org.apache.camel.component.debezium.springboot.DebeziumMySqlComponentConfiguration",
"defaultValue": false
},
+ {
+ "name": "camel.component.debezium-mysql.schema-name-adjustment-mode",
+ "type": "java.lang.String",
+ "description": "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",
+ "sourceType":
"org.apache.camel.component.debezium.springboot.DebeziumMySqlComponentConfiguration",
+ "defaultValue": "avro"
+ },
{
"name": "camel.component.debezium-mysql.signal-data-collection",
"type": "java.lang.String",
@@ -547,7 +561,7 @@
{
"name": "camel.component.debezium-mysql.skipped-operations",
"type": "java.lang.String",
- "description": "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.",
+ "description": "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.",
"sourceType":
"org.apache.camel.component.debezium.springboot.DebeziumMySqlComponentConfiguration"
},
{
diff --git
a/components-starter/camel-debezium-mysql-starter/src/main/java/org/apache/camel/component/debezium/springboot/DebeziumMySqlComponentConfiguration.java
b/components-starter/camel-debezium-mysql-starter/src/main/java/org/apache/camel/component/debezium/springboot/DebeziumMySqlComponentConfiguration.java
index 97d63bcb6f9..f198dd54199 100644
---
a/components-starter/camel-debezium-mysql-starter/src/main/java/org/apache/camel/component/debezium/springboot/DebeziumMySqlComponentConfiguration.java
+++
b/components-starter/camel-debezium-mysql-starter/src/main/java/org/apache/camel/component/debezium/springboot/DebeziumMySqlComponentConfiguration.java
@@ -218,6 +218,11 @@ public class DebeziumMySqlComponentConfiguration
* the same Kafka cluster used by the Kafka Connect process.
*/
private String databaseHistoryKafkaBootstrapServers;
+ /**
+ * The number of milliseconds to wait while fetching cluster information
+ * using Kafka admin client. The option is a long type.
+ */
+ private Long databaseHistoryKafkaQueryTimeoutMs = 3000L;
/**
* 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
@@ -274,7 +279,7 @@ public class DebeziumMySqlComponentConfiguration
/**
* JDBC Driver class name used to connect to the MySQL database server.
*/
- private String databaseJdbcDriver = "class com.mysql.cj.jdbc.Driver";
+ private String databaseJdbcDriver = "com.mysql.cj.jdbc.Driver";
/**
* Password of the database user to be used when connecting to the
database.
*/
@@ -306,16 +311,13 @@ public class DebeziumMySqlComponentConfiguration
*/
private String databaseServerName;
/**
- * 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.
*/
private String databaseSslKeystore;
/**
- * 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.
*/
private String databaseSslKeystorePassword;
/**
@@ -333,14 +335,13 @@ public class DebeziumMySqlComponentConfiguration
*/
private String databaseSslMode = "disabled";
/**
- * 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.
*/
private String databaseSslTruststore;
/**
- * 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.
*/
private String databaseSslTruststorePassword;
/**
@@ -532,6 +533,13 @@ public class DebeziumMySqlComponentConfiguration
* Whether field names will be sanitized to Avro naming conventions
*/
private Boolean sanitizeFieldNames = false;
+ /**
+ * 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
+ */
+ private String schemaNameAdjustmentMode = "avro";
/**
* The name of the data collection that is used to send signals/commands to
* Debezium. Signaling is disabled when not set.
@@ -539,8 +547,9 @@ public class DebeziumMySqlComponentConfiguration
private String signalDataCollection;
/**
* 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.
+ * 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.
*/
private String skippedOperations;
/**
@@ -929,6 +938,15 @@ public class DebeziumMySqlComponentConfiguration
this.databaseHistoryKafkaBootstrapServers =
databaseHistoryKafkaBootstrapServers;
}
+ public Long getDatabaseHistoryKafkaQueryTimeoutMs() {
+ return databaseHistoryKafkaQueryTimeoutMs;
+ }
+
+ public void setDatabaseHistoryKafkaQueryTimeoutMs(
+ Long databaseHistoryKafkaQueryTimeoutMs) {
+ this.databaseHistoryKafkaQueryTimeoutMs =
databaseHistoryKafkaQueryTimeoutMs;
+ }
+
public Integer getDatabaseHistoryKafkaRecoveryAttempts() {
return databaseHistoryKafkaRecoveryAttempts;
}
@@ -1327,6 +1345,14 @@ public class DebeziumMySqlComponentConfiguration
this.sanitizeFieldNames = sanitizeFieldNames;
}
+ public String getSchemaNameAdjustmentMode() {
+ return schemaNameAdjustmentMode;
+ }
+
+ public void setSchemaNameAdjustmentMode(String schemaNameAdjustmentMode) {
+ this.schemaNameAdjustmentMode = schemaNameAdjustmentMode;
+ }
+
public String getSignalDataCollection() {
return signalDataCollection;
}
diff --git
a/components-starter/camel-debezium-postgres-starter/src/main/docs/debezium-postgres.json
b/components-starter/camel-debezium-postgres-starter/src/main/docs/debezium-postgres.json
index 3a88dc00ccd..50853aa6856 100644
---
a/components-starter/camel-debezium-postgres-starter/src/main/docs/debezium-postgres.json
+++
b/components-starter/camel-debezium-postgres-starter/src/main/docs/debezium-postgres.json
@@ -369,7 +369,7 @@
{
"name": "camel.component.debezium-postgres.plugin-name",
"type": "java.lang.String",
- "description": "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'.",
+ "description": "The name of the Postgres logical decoding plugin
installed on the server. Supported values are 'decoderbufs' and 'pgoutput'.
Defaults to 'decoderbufs'.",
"sourceType":
"org.apache.camel.component.debezium.springboot.DebeziumPostgresComponentConfiguration",
"defaultValue": "decoderbufs"
},
@@ -440,6 +440,13 @@
"description": "The schemas for which events should be captured",
"sourceType":
"org.apache.camel.component.debezium.springboot.DebeziumPostgresComponentConfiguration"
},
+ {
+ "name": "camel.component.debezium-postgres.schema-name-adjustment-mode",
+ "type": "java.lang.String",
+ "description": "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",
+ "sourceType":
"org.apache.camel.component.debezium.springboot.DebeziumPostgresComponentConfiguration",
+ "defaultValue": "avro"
+ },
{
"name": "camel.component.debezium-postgres.schema-refresh-mode",
"type": "java.lang.String",
@@ -462,8 +469,9 @@
{
"name": "camel.component.debezium-postgres.skipped-operations",
"type": "java.lang.String",
- "description": "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.",
- "sourceType":
"org.apache.camel.component.debezium.springboot.DebeziumPostgresComponentConfiguration"
+ "description": "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.",
+ "sourceType":
"org.apache.camel.component.debezium.springboot.DebeziumPostgresComponentConfiguration",
+ "defaultValue": "t"
},
{
"name": "camel.component.debezium-postgres.slot-drop-on-stop",
@@ -617,13 +625,6 @@
"sourceType":
"org.apache.camel.component.debezium.springboot.DebeziumPostgresComponentConfiguration",
"defaultValue": "${database.server.name}.transaction"
},
- {
- "name": "camel.component.debezium-postgres.truncate-handling-mode",
- "type": "java.lang.String",
- "description": "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",
- "sourceType":
"org.apache.camel.component.debezium.springboot.DebeziumPostgresComponentConfiguration",
- "defaultValue": "skip"
- },
{
"name":
"camel.component.debezium-postgres.unavailable-value-placeholder",
"type": "java.lang.String",
diff --git
a/components-starter/camel-debezium-postgres-starter/src/main/java/org/apache/camel/component/debezium/springboot/DebeziumPostgresComponentConfiguration.java
b/components-starter/camel-debezium-postgres-starter/src/main/java/org/apache/camel/component/debezium/springboot/DebeziumPostgresComponentConfiguration.java
index e1a41c1bb29..c3a9f7d47ec 100644
---
a/components-starter/camel-debezium-postgres-starter/src/main/java/org/apache/camel/component/debezium/springboot/DebeziumPostgresComponentConfiguration.java
+++
b/components-starter/camel-debezium-postgres-starter/src/main/java/org/apache/camel/component/debezium/springboot/DebeziumPostgresComponentConfiguration.java
@@ -359,9 +359,8 @@ public class DebeziumPostgresComponentConfiguration
private String messagePrefixIncludeList;
/**
* 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'.
+ * Supported values are 'decoderbufs' and 'pgoutput'. Defaults to
+ * 'decoderbufs'.
*/
private String pluginName = "decoderbufs";
/**
@@ -421,6 +420,13 @@ public class DebeziumPostgresComponentConfiguration
* The schemas for which events should be captured
*/
private String schemaIncludeList;
+ /**
+ * 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
+ */
+ private String schemaNameAdjustmentMode = "avro";
/**
* Specify the conditions that trigger a refresh of the in-memory schema
for
* a table. 'columns_diff' (the default) is the safest mode, ensuring the
@@ -447,10 +453,11 @@ public class DebeziumPostgresComponentConfiguration
private String signalDataCollection;
/**
* 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.
+ * 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.
*/
- private String skippedOperations;
+ private String skippedOperations = "t";
/**
* Whether or not to drop the logical replication slot when the connector
* finishes orderlyBy default the replication is kept so that on restart
@@ -602,13 +609,6 @@ public class DebeziumPostgresComponentConfiguration
* logical name; defaults to ${database.server.name}.transaction.
*/
private String transactionTopic = "${database.server.name}.transaction";
- /**
- * 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
- */
- private String truncateHandlingMode = "skip";
/**
* Specify the constant that will be provided by Debezium to indicate that
* the original value is a toasted value not provided by the database. If
@@ -1147,6 +1147,14 @@ public class DebeziumPostgresComponentConfiguration
this.schemaIncludeList = schemaIncludeList;
}
+ public String getSchemaNameAdjustmentMode() {
+ return schemaNameAdjustmentMode;
+ }
+
+ public void setSchemaNameAdjustmentMode(String schemaNameAdjustmentMode) {
+ this.schemaNameAdjustmentMode = schemaNameAdjustmentMode;
+ }
+
public String getSchemaRefreshMode() {
return schemaRefreshMode;
}
@@ -1365,14 +1373,6 @@ public class DebeziumPostgresComponentConfiguration
this.transactionTopic = transactionTopic;
}
- public String getTruncateHandlingMode() {
- return truncateHandlingMode;
- }
-
- public void setTruncateHandlingMode(String truncateHandlingMode) {
- this.truncateHandlingMode = truncateHandlingMode;
- }
-
public String getUnavailableValuePlaceholder() {
return unavailableValuePlaceholder;
}
diff --git
a/components-starter/camel-debezium-sqlserver-starter/src/main/docs/debezium-sqlserver.json
b/components-starter/camel-debezium-sqlserver-starter/src/main/docs/debezium-sqlserver.json
index 36fb4bcd9de..5aafaf7a355 100644
---
a/components-starter/camel-debezium-sqlserver-starter/src/main/docs/debezium-sqlserver.json
+++
b/components-starter/camel-debezium-sqlserver-starter/src/main/docs/debezium-sqlserver.json
@@ -112,6 +112,13 @@
"description": "A list of host\/port pairs that the connector will use
for establishing the initial connection to the Kafka cluster for retrieving
database schema history previously stored by the connector. This should point
to the same Kafka cluster used by the Kafka Connect process.",
"sourceType":
"org.apache.camel.component.debezium.springboot.DebeziumSqlserverComponentConfiguration"
},
+ {
+ "name":
"camel.component.debezium-sqlserver.database-history-kafka-query-timeout-ms",
+ "type": "java.lang.Long",
+ "description": "The number of milliseconds to wait while fetching
cluster information using Kafka admin client. The option is a long type.",
+ "sourceType":
"org.apache.camel.component.debezium.springboot.DebeziumSqlserverComponentConfiguration",
+ "defaultValue": 3000
+ },
{
"name":
"camel.component.debezium-sqlserver.database-history-kafka-recovery-attempts",
"type": "java.lang.Integer",
@@ -412,6 +419,13 @@
"sourceType":
"org.apache.camel.component.debezium.springboot.DebeziumSqlserverComponentConfiguration",
"defaultValue": false
},
+ {
+ "name": "camel.component.debezium-sqlserver.schema-name-adjustment-mode",
+ "type": "java.lang.String",
+ "description": "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",
+ "sourceType":
"org.apache.camel.component.debezium.springboot.DebeziumSqlserverComponentConfiguration",
+ "defaultValue": "avro"
+ },
{
"name": "camel.component.debezium-sqlserver.signal-data-collection",
"type": "java.lang.String",
@@ -421,7 +435,7 @@
{
"name": "camel.component.debezium-sqlserver.skipped-operations",
"type": "java.lang.String",
- "description": "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.",
+ "description": "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.",
"sourceType":
"org.apache.camel.component.debezium.springboot.DebeziumSqlserverComponentConfiguration"
},
{
diff --git
a/components-starter/camel-debezium-sqlserver-starter/src/main/java/org/apache/camel/component/debezium/springboot/DebeziumSqlserverComponentConfiguration.java
b/components-starter/camel-debezium-sqlserver-starter/src/main/java/org/apache/camel/component/debezium/springboot/DebeziumSqlserverComponentConfiguration.java
index 8bdbd9da7c1..b587b696ce8 100644
---
a/components-starter/camel-debezium-sqlserver-starter/src/main/java/org/apache/camel/component/debezium/springboot/DebeziumSqlserverComponentConfiguration.java
+++
b/components-starter/camel-debezium-sqlserver-starter/src/main/java/org/apache/camel/component/debezium/springboot/DebeziumSqlserverComponentConfiguration.java
@@ -184,6 +184,11 @@ public class DebeziumSqlserverComponentConfiguration
* the same Kafka cluster used by the Kafka Connect process.
*/
private String databaseHistoryKafkaBootstrapServers;
+ /**
+ * The number of milliseconds to wait while fetching cluster information
+ * using Kafka admin client. The option is a long type.
+ */
+ private Long databaseHistoryKafkaQueryTimeoutMs = 3000L;
/**
* 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
@@ -388,6 +393,13 @@ public class DebeziumSqlserverComponentConfiguration
* Whether field names will be sanitized to Avro naming conventions
*/
private Boolean sanitizeFieldNames = false;
+ /**
+ * 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
+ */
+ private String schemaNameAdjustmentMode = "avro";
/**
* The name of the data collection that is used to send signals/commands to
* Debezium. Signaling is disabled when not set.
@@ -395,8 +407,9 @@ public class DebeziumSqlserverComponentConfiguration
private String signalDataCollection;
/**
* 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.
+ * 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.
*/
private String skippedOperations;
/**
@@ -733,6 +746,15 @@ public class DebeziumSqlserverComponentConfiguration
this.databaseHistoryKafkaBootstrapServers =
databaseHistoryKafkaBootstrapServers;
}
+ public Long getDatabaseHistoryKafkaQueryTimeoutMs() {
+ return databaseHistoryKafkaQueryTimeoutMs;
+ }
+
+ public void setDatabaseHistoryKafkaQueryTimeoutMs(
+ Long databaseHistoryKafkaQueryTimeoutMs) {
+ this.databaseHistoryKafkaQueryTimeoutMs =
databaseHistoryKafkaQueryTimeoutMs;
+ }
+
public Integer getDatabaseHistoryKafkaRecoveryAttempts() {
return databaseHistoryKafkaRecoveryAttempts;
}
@@ -1016,6 +1038,14 @@ public class DebeziumSqlserverComponentConfiguration
this.sanitizeFieldNames = sanitizeFieldNames;
}
+ public String getSchemaNameAdjustmentMode() {
+ return schemaNameAdjustmentMode;
+ }
+
+ public void setSchemaNameAdjustmentMode(String schemaNameAdjustmentMode) {
+ this.schemaNameAdjustmentMode = schemaNameAdjustmentMode;
+ }
+
public String getSignalDataCollection() {
return signalDataCollection;
}
diff --git a/tooling/camel-spring-boot-dependencies/pom.xml
b/tooling/camel-spring-boot-dependencies/pom.xml
index 0c06e9b2662..9b5814095ac 100644
--- a/tooling/camel-spring-boot-dependencies/pom.xml
+++ b/tooling/camel-spring-boot-dependencies/pom.xml
@@ -2652,11 +2652,6 @@
<artifactId>camel-fastjson</artifactId>
<version>3.17.0-SNAPSHOT</version>
</dependency>
- <dependency>
- <groupId>org.apache.camel</groupId>
- <artifactId>camel-fatjar-main</artifactId>
- <version>3.17.0-SNAPSHOT</version>
- </dependency>
<dependency>
<groupId>org.apache.camel</groupId>
<artifactId>camel-fhir</artifactId>
@@ -3932,6 +3927,11 @@
<artifactId>camel-twitter</artifactId>
<version>3.17.0-SNAPSHOT</version>
</dependency>
+ <dependency>
+ <groupId>org.apache.camel</groupId>
+ <artifactId>camel-uberjar-main</artifactId>
+ <version>3.17.0-SNAPSHOT</version>
+ </dependency>
<dependency>
<groupId>org.apache.camel</groupId>
<artifactId>camel-undertow</artifactId>
@@ -4170,142 +4170,142 @@
<dependency>
<groupId>org.apache.cxf.services.sts</groupId>
<artifactId>cxf-services-sts-core</artifactId>
- <version>3.5.1</version>
+ <version>3.5.2</version>
</dependency>
<dependency>
<groupId>org.apache.cxf.services.ws-discovery</groupId>
<artifactId>cxf-services-ws-discovery-api</artifactId>
- <version>3.5.1</version>
+ <version>3.5.2</version>
</dependency>
<dependency>
<groupId>org.apache.cxf</groupId>
<artifactId>cxf-core</artifactId>
- <version>3.5.1</version>
+ <version>3.5.2</version>
</dependency>
<dependency>
<groupId>org.apache.cxf</groupId>
<artifactId>cxf-rt-bindings-soap</artifactId>
- <version>3.5.1</version>
+ <version>3.5.2</version>
</dependency>
<dependency>
<groupId>org.apache.cxf</groupId>
<artifactId>cxf-rt-bindings-xml</artifactId>
- <version>3.5.1</version>
+ <version>3.5.2</version>
</dependency>
<dependency>
<groupId>org.apache.cxf</groupId>
<artifactId>cxf-rt-databinding-jaxb</artifactId>
- <version>3.5.1</version>
+ <version>3.5.2</version>
</dependency>
<dependency>
<groupId>org.apache.cxf</groupId>
<artifactId>cxf-rt-features-clustering</artifactId>
- <version>3.5.1</version>
+ <version>3.5.2</version>
</dependency>
<dependency>
<groupId>org.apache.cxf</groupId>
<artifactId>cxf-rt-features-logging</artifactId>
- <version>3.5.1</version>
+ <version>3.5.2</version>
</dependency>
<dependency>
<groupId>org.apache.cxf</groupId>
<artifactId>cxf-rt-frontend-jaxrs</artifactId>
- <version>3.5.1</version>
+ <version>3.5.2</version>
</dependency>
<dependency>
<groupId>org.apache.cxf</groupId>
<artifactId>cxf-rt-frontend-jaxws</artifactId>
- <version>3.5.1</version>
+ <version>3.5.2</version>
</dependency>
<dependency>
<groupId>org.apache.cxf</groupId>
<artifactId>cxf-rt-frontend-simple</artifactId>
- <version>3.5.1</version>
+ <version>3.5.2</version>
</dependency>
<dependency>
<groupId>org.apache.cxf</groupId>
<artifactId>cxf-rt-management</artifactId>
- <version>3.5.1</version>
+ <version>3.5.2</version>
</dependency>
<dependency>
<groupId>org.apache.cxf</groupId>
<artifactId>cxf-rt-rs-client</artifactId>
- <version>3.5.1</version>
+ <version>3.5.2</version>
</dependency>
<dependency>
<groupId>org.apache.cxf</groupId>
<artifactId>cxf-rt-rs-extension-providers</artifactId>
- <version>3.5.1</version>
+ <version>3.5.2</version>
</dependency>
<dependency>
<groupId>org.apache.cxf</groupId>
<artifactId>cxf-rt-rs-security-oauth2</artifactId>
- <version>3.5.1</version>
+ <version>3.5.2</version>
</dependency>
<dependency>
<groupId>org.apache.cxf</groupId>
<artifactId>cxf-rt-rs-service-description-swagger</artifactId>
- <version>3.5.1</version>
+ <version>3.5.2</version>
</dependency>
<dependency>
<groupId>org.apache.cxf</groupId>
<artifactId>cxf-rt-transports-http</artifactId>
- <version>3.5.1</version>
+ <version>3.5.2</version>
</dependency>
<dependency>
<groupId>org.apache.cxf</groupId>
<artifactId>cxf-rt-transports-http-jetty</artifactId>
- <version>3.5.1</version>
+ <version>3.5.2</version>
</dependency>
<dependency>
<groupId>org.apache.cxf</groupId>
<artifactId>cxf-rt-transports-jms</artifactId>
- <version>3.5.1</version>
+ <version>3.5.2</version>
</dependency>
<dependency>
<groupId>org.apache.cxf</groupId>
<artifactId>cxf-rt-transports-local</artifactId>
- <version>3.5.1</version>
+ <version>3.5.2</version>
</dependency>
<dependency>
<groupId>org.apache.cxf</groupId>
<artifactId>cxf-rt-ws-addr</artifactId>
- <version>3.5.1</version>
+ <version>3.5.2</version>
</dependency>
<dependency>
<groupId>org.apache.cxf</groupId>
<artifactId>cxf-rt-ws-mex</artifactId>
- <version>3.5.1</version>
+ <version>3.5.2</version>
</dependency>
<dependency>
<groupId>org.apache.cxf</groupId>
<artifactId>cxf-rt-ws-policy</artifactId>
- <version>3.5.1</version>
+ <version>3.5.2</version>
</dependency>
<dependency>
<groupId>org.apache.cxf</groupId>
<artifactId>cxf-rt-ws-rm</artifactId>
- <version>3.5.1</version>
+ <version>3.5.2</version>
</dependency>
<dependency>
<groupId>org.apache.cxf</groupId>
<artifactId>cxf-rt-ws-security</artifactId>
- <version>3.5.1</version>
+ <version>3.5.2</version>
</dependency>
<dependency>
<groupId>org.apache.cxf</groupId>
<artifactId>cxf-rt-ws-security-oauth2</artifactId>
- <version>3.5.1</version>
+ <version>3.5.2</version>
</dependency>
<dependency>
<groupId>org.apache.cxf</groupId>
<artifactId>cxf-rt-wsdl</artifactId>
- <version>3.5.1</version>
+ <version>3.5.2</version>
</dependency>
<dependency>
<groupId>org.apache.cxf</groupId>
<artifactId>cxf-testutils</artifactId>
- <version>3.5.1</version>
+ <version>3.5.2</version>
</dependency>
<dependency>
<groupId>org.apache.ftpserver</groupId>
