This is an automated email from the ASF dual-hosted git repository.
acosentino 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 29d81e7 [create-pull-request] automated change
29d81e7 is described below
commit 29d81e74908812e76cd2068a1283a32d9c36cf44
Author: github-actions[bot]
<41898282+github-actions[bot]@users.noreply.github.com>
AuthorDate: Wed Jul 7 00:47:22 2021 +0000
[create-pull-request] automated change
---
.../catalog/components/debezium-mysql.json | 12 +++-
.../catalog/components/debezium-postgres.json | 10 ++--
.../catalog/components/debezium-sqlserver.json | 16 ++++--
components-starter/README.adoc | 4 +-
.../src/main/docs/debezium-mysql-starter.adoc | 8 ++-
.../DebeziumMySqlComponentConfiguration.java | 62 +++++++++++++++++++-
.../src/main/docs/debezium-postgres-starter.adoc | 7 ++-
.../DebeziumPostgresComponentConfiguration.java | 20 +++++--
.../src/main/docs/debezium-sqlserver-starter.adoc | 10 +++-
.../DebeziumSqlserverComponentConfiguration.java | 66 +++++++++++++++++++++-
.../ROOT/pages/azure-servicebus-starter.adoc | 54 ++++++++++++++++++
.../modules/ROOT/pages/debezium-mysql-starter.adoc | 8 ++-
.../ROOT/pages/debezium-postgres-starter.adoc | 7 ++-
.../ROOT/pages/debezium-sqlserver-starter.adoc | 10 +++-
docs/modules/ROOT/pages/list.adoc | 4 +-
tooling/camel-spring-boot-bom/pom.xml | 8 +--
tooling/camel-spring-boot-dependencies/pom.xml | 13 +++--
17 files changed, 275 insertions(+), 44 deletions(-)
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 698a867..2991ceb 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
@@ -54,6 +54,9 @@
"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 [...]
+ "databaseHistorySkipUnparseableDdl": { "kind": "property", "displayName":
"Database History Skip Unparseable Ddl", "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": "Controls the [...]
+ "databaseHistoryStoreOnlyCapturedTablesDdl": { "kind": "property",
"displayName": "Database History Store Only Captured Tables Ddl", "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", "descripti [...]
+ "databaseHistoryStoreOnlyMonitoredTablesDdl": { "kind": "property",
"displayName": "Database History Store Only Monitored Tables Ddl", "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", "descrip [...]
"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 [...]
@@ -82,6 +85,7 @@
"includeQuery": { "kind": "property", "displayName": "Include Query",
"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 the connector
should include the original SQL que [...]
"includeSchemaChanges": { "kind": "property", "displayName": "Include
Schema Changes", "group": "mysql", "label": "consumer,mysql", "required":
false, "type": "boolean", "javaType": "boolean", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": true,
"configurationClass":
"org.apache.camel.component.debezium.configuration.MySqlConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "Whether the connector
should publish chan [...]
"inconsistentSchemaHandlingMode": { "kind": "property", "displayName":
"Inconsistent Schema Handling Mode", "group": "mysql", "label":
"consumer,mysql", "required": false, "type": "string", "javaType":
"java.lang.String", "deprecated": false, "autowired": false, "secret": false,
"defaultValue": "fail", "configurationClass":
"org.apache.camel.component.debezium.configuration.MySqlConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "Specify ho [...]
+ "incrementalSnapshotChunkSize": { "kind": "property", "displayName":
"Incremental Snapshot Chunk Size", "group": "mysql", "label": "consumer,mysql",
"required": false, "type": "integer", "javaType": "int", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": 1024,
"configurationClass":
"org.apache.camel.component.debezium.configuration.MySqlConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "The maximum size of
chunk fo [...]
"maxBatchSize": { "kind": "property", "displayName": "Max Batch Size",
"group": "mysql", "label": "consumer,mysql", "required": false, "type":
"integer", "javaType": "int", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": 2048, "configurationClass":
"org.apache.camel.component.debezium.configuration.MySqlConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "Maximum size of each
batch of source records. Defaults to 2048." },
"maxQueueSize": { "kind": "property", "displayName": "Max Queue Size",
"group": "mysql", "label": "consumer,mysql", "required": false, "type":
"integer", "javaType": "int", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": 8192, "configurationClass":
"org.apache.camel.component.debezium.configuration.MySqlConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "Maximum size of the
queue for change events read from the dat [...]
"maxQueueSizeInBytes": { "kind": "property", "displayName": "Max Queue
Size In Bytes", "group": "mysql", "label": "consumer,mysql", "required": false,
"type": "integer", "javaType": "long", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": 0, "configurationClass":
"org.apache.camel.component.debezium.configuration.MySqlConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "Maximum size of the
queue in bytes for change e [...]
@@ -101,7 +105,7 @@
"snapshotMaxThreads": { "kind": "property", "displayName": "Snapshot Max
Threads", "group": "mysql", "label": "consumer,mysql", "required": false,
"type": "integer", "javaType": "int", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": 1, "configurationClass":
"org.apache.camel.component.debezium.configuration.MySqlConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "The maximum number of
threads used to perform the sn [...]
"snapshotMode": { "kind": "property", "displayName": "Snapshot Mode",
"group": "mysql", "label": "consumer,mysql", "required": false, "type":
"string", "javaType": "java.lang.String", "deprecated": false, "autowired":
false, "secret": false, "defaultValue": "initial", "configurationClass":
"org.apache.camel.component.debezium.configuration.MySqlConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "The criteria for
running a snapshot upon star [...]
"snapshotNewTables": { "kind": "property", "displayName": "Snapshot New
Tables", "group": "mysql", "label": "consumer,mysql", "required": false,
"type": "string", "javaType": "java.lang.String", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": "off",
"configurationClass":
"org.apache.camel.component.debezium.configuration.MySqlConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "BETA FEATURE: On
connector restart, th [...]
- "snapshotSelectStatementOverrides": { "kind": "property", "displayName":
"Snapshot Select Statement Overrides", "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 property contains
a comma [...]
+ "snapshotSelectStatementOverrides": { "kind": "property", "displayName":
"Snapshot Select Statement Overrides", "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 property contains
a comma [...]
"sourceStructVersion": { "kind": "property", "displayName": "Source Struct
Version", "group": "mysql", "label": "consumer,mysql", "required": false,
"type": "string", "javaType": "java.lang.String", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": "v2",
"configurationClass":
"org.apache.camel.component.debezium.configuration.MySqlConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "A version of the format
of the publ [...]
"tableBlacklist": { "kind": "property", "displayName": "Table Blacklist",
"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 expressions that match the fully-q [...]
"tableExcludeList": { "kind": "property", "displayName": "Table Exclude
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": "A comma-separated list
of regular expressions that match the fu [...]
@@ -145,6 +149,9 @@
"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 [...]
+ "databaseHistorySkipUnparseableDdl": { "kind": "parameter", "displayName":
"Database History Skip Unparseable Ddl", "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": "Controls th [...]
+ "databaseHistoryStoreOnlyCapturedTablesDdl": { "kind": "parameter",
"displayName": "Database History Store Only Captured Tables Ddl", "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", "descript [...]
+ "databaseHistoryStoreOnlyMonitoredTablesDdl": { "kind": "parameter",
"displayName": "Database History Store Only Monitored Tables Ddl", "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", "descri [...]
"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 [...]
@@ -173,6 +180,7 @@
"includeQuery": { "kind": "parameter", "displayName": "Include Query",
"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 the connector
should include the original SQL qu [...]
"includeSchemaChanges": { "kind": "parameter", "displayName": "Include
Schema Changes", "group": "mysql", "label": "consumer,mysql", "required":
false, "type": "boolean", "javaType": "boolean", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": true,
"configurationClass":
"org.apache.camel.component.debezium.configuration.MySqlConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "Whether the connector
should publish cha [...]
"inconsistentSchemaHandlingMode": { "kind": "parameter", "displayName":
"Inconsistent Schema Handling Mode", "group": "mysql", "label":
"consumer,mysql", "required": false, "type": "string", "javaType":
"java.lang.String", "deprecated": false, "autowired": false, "secret": false,
"defaultValue": "fail", "configurationClass":
"org.apache.camel.component.debezium.configuration.MySqlConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "Specify h [...]
+ "incrementalSnapshotChunkSize": { "kind": "parameter", "displayName":
"Incremental Snapshot Chunk Size", "group": "mysql", "label": "consumer,mysql",
"required": false, "type": "integer", "javaType": "int", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": 1024,
"configurationClass":
"org.apache.camel.component.debezium.configuration.MySqlConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "The maximum size of
chunk f [...]
"maxBatchSize": { "kind": "parameter", "displayName": "Max Batch Size",
"group": "mysql", "label": "consumer,mysql", "required": false, "type":
"integer", "javaType": "int", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": 2048, "configurationClass":
"org.apache.camel.component.debezium.configuration.MySqlConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "Maximum size of each
batch of source records. Defaults to 2048." },
"maxQueueSize": { "kind": "parameter", "displayName": "Max Queue Size",
"group": "mysql", "label": "consumer,mysql", "required": false, "type":
"integer", "javaType": "int", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": 8192, "configurationClass":
"org.apache.camel.component.debezium.configuration.MySqlConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "Maximum size of the
queue for change events read from the da [...]
"maxQueueSizeInBytes": { "kind": "parameter", "displayName": "Max Queue
Size In Bytes", "group": "mysql", "label": "consumer,mysql", "required": false,
"type": "integer", "javaType": "long", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": 0, "configurationClass":
"org.apache.camel.component.debezium.configuration.MySqlConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "Maximum size of the
queue in bytes for change [...]
@@ -192,7 +200,7 @@
"snapshotMaxThreads": { "kind": "parameter", "displayName": "Snapshot Max
Threads", "group": "mysql", "label": "consumer,mysql", "required": false,
"type": "integer", "javaType": "int", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": 1, "configurationClass":
"org.apache.camel.component.debezium.configuration.MySqlConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "The maximum number of
threads used to perform the s [...]
"snapshotMode": { "kind": "parameter", "displayName": "Snapshot Mode",
"group": "mysql", "label": "consumer,mysql", "required": false, "type":
"string", "javaType": "java.lang.String", "deprecated": false, "autowired":
false, "secret": false, "defaultValue": "initial", "configurationClass":
"org.apache.camel.component.debezium.configuration.MySqlConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "The criteria for
running a snapshot upon sta [...]
"snapshotNewTables": { "kind": "parameter", "displayName": "Snapshot New
Tables", "group": "mysql", "label": "consumer,mysql", "required": false,
"type": "string", "javaType": "java.lang.String", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": "off",
"configurationClass":
"org.apache.camel.component.debezium.configuration.MySqlConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "BETA FEATURE: On
connector restart, t [...]
- "snapshotSelectStatementOverrides": { "kind": "parameter", "displayName":
"Snapshot Select Statement Overrides", "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 property contains
a comm [...]
+ "snapshotSelectStatementOverrides": { "kind": "parameter", "displayName":
"Snapshot Select Statement Overrides", "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 property contains
a comm [...]
"sourceStructVersion": { "kind": "parameter", "displayName": "Source
Struct Version", "group": "mysql", "label": "consumer,mysql", "required":
false, "type": "string", "javaType": "java.lang.String", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": "v2",
"configurationClass":
"org.apache.camel.component.debezium.configuration.MySqlConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "A version of the format
of the pub [...]
"tableBlacklist": { "kind": "parameter", "displayName": "Table Blacklist",
"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 expressions that match the fully- [...]
"tableExcludeList": { "kind": "parameter", "displayName": "Table Exclude
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": "A comma-separated list
of regular expressions that match the f [...]
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 57017b8..a29ae7f 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
@@ -66,6 +66,7 @@
"heartbeatTopicsPrefix": { "kind": "property", "displayName": "Heartbeat
Topics Prefix", "group": "postgres", "label": "consumer,postgres", "required":
false, "type": "string", "javaType": "java.lang.String", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": "__debezium-heartbeat",
"configurationClass":
"org.apache.camel.component.debezium.configuration.PostgresConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "The [...]
"hstoreHandlingMode": { "kind": "property", "displayName": "Hstore
Handling Mode", "group": "postgres", "label": "consumer,postgres", "required":
false, "type": "string", "javaType": "java.lang.String", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": "json",
"configurationClass":
"org.apache.camel.component.debezium.configuration.PostgresConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "Specify how HSTORE
columns [...]
"includeUnknownDatatypes": { "kind": "property", "displayName": "Include
Unknown Datatypes", "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": "Specify whether the
field [...]
+ "incrementalSnapshotChunkSize": { "kind": "property", "displayName":
"Incremental Snapshot Chunk Size", "group": "postgres", "label":
"consumer,postgres", "required": false, "type": "integer", "javaType": "int",
"deprecated": false, "autowired": false, "secret": false, "defaultValue": 1024,
"configurationClass":
"org.apache.camel.component.debezium.configuration.PostgresConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "The maximum size of
[...]
"intervalHandlingMode": { "kind": "property", "displayName": "Interval
Handling Mode", "group": "postgres", "label": "consumer,postgres", "required":
false, "type": "string", "javaType": "java.lang.String", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": "numeric",
"configurationClass":
"org.apache.camel.component.debezium.configuration.PostgresConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "Specify how INTERVA
[...]
"maxBatchSize": { "kind": "property", "displayName": "Max Batch Size",
"group": "postgres", "label": "consumer,postgres", "required": false, "type":
"integer", "javaType": "int", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": 2048, "configurationClass":
"org.apache.camel.component.debezium.configuration.PostgresConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "Maximum size of each
batch of source records. Defaul [...]
"maxQueueSize": { "kind": "property", "displayName": "Max Queue Size",
"group": "postgres", "label": "consumer,postgres", "required": false, "type":
"integer", "javaType": "int", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": 8192, "configurationClass":
"org.apache.camel.component.debezium.configuration.PostgresConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "Maximum size of the
queue for change events read fro [...]
@@ -97,8 +98,8 @@
"snapshotIncludeCollectionList": { "kind": "property", "displayName":
"Snapshot Include Collection 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": "this setting must be
set to [...]
"snapshotLockTimeoutMs": { "kind": "property", "displayName": "Snapshot
Lock Timeout Ms", "group": "postgres", "label": "consumer,postgres",
"required": false, "type": "duration", "javaType": "long", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": "10s",
"configurationClass":
"org.apache.camel.component.debezium.configuration.PostgresConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "The maximum number of
millis t [...]
"snapshotMaxThreads": { "kind": "property", "displayName": "Snapshot Max
Threads", "group": "postgres", "label": "consumer,postgres", "required": false,
"type": "integer", "javaType": "int", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": 1, "configurationClass":
"org.apache.camel.component.debezium.configuration.PostgresConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "The maximum number of
threads used to perfo [...]
- "snapshotMode": { "kind": "property", "displayName": "Snapshot Mode",
"group": "postgres", "label": "consumer,postgres", "required": false, "type":
"string", "javaType": "java.lang.String", "deprecated": false, "autowired":
false, "secret": false, "defaultValue": "initial", "configurationClass":
"org.apache.camel.component.debezium.configuration.PostgresConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "The criteria for
running a snapshot [...]
- "snapshotSelectStatementOverrides": { "kind": "property", "displayName":
"Snapshot Select Statement Overrides", "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": "This property contain
[...]
+ "snapshotMode": { "kind": "property", "displayName": "Snapshot Mode",
"group": "postgres", "label": "consumer,postgres", "required": false, "type":
"string", "javaType": "java.lang.String", "deprecated": false, "autowired":
false, "secret": false, "defaultValue": "initial", "configurationClass":
"org.apache.camel.component.debezium.configuration.PostgresConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "The criteria for
running a snapshot [...]
+ "snapshotSelectStatementOverrides": { "kind": "property", "displayName":
"Snapshot Select Statement Overrides", "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": "This property contain
[...]
"sourceStructVersion": { "kind": "property", "displayName": "Source Struct
Version", "group": "postgres", "label": "consumer,postgres", "required": false,
"type": "string", "javaType": "java.lang.String", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": "v2",
"configurationClass":
"org.apache.camel.component.debezium.configuration.PostgresConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "A version of the format
of [...]
"statusUpdateIntervalMs": { "kind": "property", "displayName": "Status
Update Interval Ms", "group": "postgres", "label": "consumer,postgres",
"required": false, "type": "duration", "javaType": "int", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": "10s",
"configurationClass":
"org.apache.camel.component.debezium.configuration.PostgresConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "Frequency for sending
replica [...]
"tableBlacklist": { "kind": "property", "displayName": "Table 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": "A comma-separated list
of regular expressions that match th [...]
@@ -157,6 +158,7 @@
"heartbeatTopicsPrefix": { "kind": "parameter", "displayName": "Heartbeat
Topics Prefix", "group": "postgres", "label": "consumer,postgres", "required":
false, "type": "string", "javaType": "java.lang.String", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": "__debezium-heartbeat",
"configurationClass":
"org.apache.camel.component.debezium.configuration.PostgresConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "The [...]
"hstoreHandlingMode": { "kind": "parameter", "displayName": "Hstore
Handling Mode", "group": "postgres", "label": "consumer,postgres", "required":
false, "type": "string", "javaType": "java.lang.String", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": "json",
"configurationClass":
"org.apache.camel.component.debezium.configuration.PostgresConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "Specify how HSTORE
column [...]
"includeUnknownDatatypes": { "kind": "parameter", "displayName": "Include
Unknown Datatypes", "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": "Specify whether the
fiel [...]
+ "incrementalSnapshotChunkSize": { "kind": "parameter", "displayName":
"Incremental Snapshot Chunk Size", "group": "postgres", "label":
"consumer,postgres", "required": false, "type": "integer", "javaType": "int",
"deprecated": false, "autowired": false, "secret": false, "defaultValue": 1024,
"configurationClass":
"org.apache.camel.component.debezium.configuration.PostgresConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "The maximum size o [...]
"intervalHandlingMode": { "kind": "parameter", "displayName": "Interval
Handling Mode", "group": "postgres", "label": "consumer,postgres", "required":
false, "type": "string", "javaType": "java.lang.String", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": "numeric",
"configurationClass":
"org.apache.camel.component.debezium.configuration.PostgresConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "Specify how INTERV [...]
"maxBatchSize": { "kind": "parameter", "displayName": "Max Batch Size",
"group": "postgres", "label": "consumer,postgres", "required": false, "type":
"integer", "javaType": "int", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": 2048, "configurationClass":
"org.apache.camel.component.debezium.configuration.PostgresConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "Maximum size of each
batch of source records. Defau [...]
"maxQueueSize": { "kind": "parameter", "displayName": "Max Queue Size",
"group": "postgres", "label": "consumer,postgres", "required": false, "type":
"integer", "javaType": "int", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": 8192, "configurationClass":
"org.apache.camel.component.debezium.configuration.PostgresConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "Maximum size of the
queue for change events read fr [...]
@@ -188,8 +190,8 @@
"snapshotIncludeCollectionList": { "kind": "parameter", "displayName":
"Snapshot Include Collection 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": "this setting must be
set t [...]
"snapshotLockTimeoutMs": { "kind": "parameter", "displayName": "Snapshot
Lock Timeout Ms", "group": "postgres", "label": "consumer,postgres",
"required": false, "type": "duration", "javaType": "long", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": "10s",
"configurationClass":
"org.apache.camel.component.debezium.configuration.PostgresConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "The maximum number of
millis [...]
"snapshotMaxThreads": { "kind": "parameter", "displayName": "Snapshot Max
Threads", "group": "postgres", "label": "consumer,postgres", "required": false,
"type": "integer", "javaType": "int", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": 1, "configurationClass":
"org.apache.camel.component.debezium.configuration.PostgresConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "The maximum number of
threads used to perf [...]
- "snapshotMode": { "kind": "parameter", "displayName": "Snapshot Mode",
"group": "postgres", "label": "consumer,postgres", "required": false, "type":
"string", "javaType": "java.lang.String", "deprecated": false, "autowired":
false, "secret": false, "defaultValue": "initial", "configurationClass":
"org.apache.camel.component.debezium.configuration.PostgresConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "The criteria for
running a snapshot [...]
- "snapshotSelectStatementOverrides": { "kind": "parameter", "displayName":
"Snapshot Select Statement Overrides", "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": "This property contai
[...]
+ "snapshotMode": { "kind": "parameter", "displayName": "Snapshot Mode",
"group": "postgres", "label": "consumer,postgres", "required": false, "type":
"string", "javaType": "java.lang.String", "deprecated": false, "autowired":
false, "secret": false, "defaultValue": "initial", "configurationClass":
"org.apache.camel.component.debezium.configuration.PostgresConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "The criteria for
running a snapshot [...]
+ "snapshotSelectStatementOverrides": { "kind": "parameter", "displayName":
"Snapshot Select Statement Overrides", "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": "This property contai
[...]
"sourceStructVersion": { "kind": "parameter", "displayName": "Source
Struct Version", "group": "postgres", "label": "consumer,postgres", "required":
false, "type": "string", "javaType": "java.lang.String", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": "v2",
"configurationClass":
"org.apache.camel.component.debezium.configuration.PostgresConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "A version of the format
o [...]
"statusUpdateIntervalMs": { "kind": "parameter", "displayName": "Status
Update Interval Ms", "group": "postgres", "label": "consumer,postgres",
"required": false, "type": "duration", "javaType": "int", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": "10s",
"configurationClass":
"org.apache.camel.component.debezium.configuration.PostgresConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "Frequency for sending
replic [...]
"tableBlacklist": { "kind": "parameter", "displayName": "Table 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": "A comma-separated list
of regular expressions that match t [...]
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 20b325c..e355f93 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
@@ -50,6 +50,9 @@
"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 [...]
+ "databaseHistorySkipUnparseableDdl": { "kind": "property", "displayName":
"Database History Skip Unparseable Ddl", "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": " [...]
+ "databaseHistoryStoreOnlyCapturedTablesDdl": { "kind": "property",
"displayName": "Database History Store Only Captured Tables Ddl", "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" [...]
+ "databaseHistoryStoreOnlyMonitoredTablesDdl": { "kind": "property",
"displayName": "Database History Store Only Monitored Tables Ddl", "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": "configuratio [...]
"databaseHostname": { "kind": "property", "displayName": "Database
Hostname", "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": "Resolvable hostname or
IP address of the database se [...]
"databaseInstance": { "kind": "property", "displayName": "Database
Instance", "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 SQL Server instance
name" },
"databasePassword": { "kind": "property", "displayName": "Database
Password", "group": "sqlserver", "label": "consumer,sqlserver", "required":
true, "type": "string", "javaType": "java.lang.String", "deprecated": false,
"deprecationNote": "", "autowired": false, "secret": false,
"configurationClass":
"org.apache.camel.component.debezium.configuration.SqlServerConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "Password of the
database user [...]
@@ -64,6 +67,7 @@
"heartbeatTopicsPrefix": { "kind": "property", "displayName": "Heartbeat
Topics Prefix", "group": "sqlserver", "label": "consumer,sqlserver",
"required": false, "type": "string", "javaType": "java.lang.String",
"deprecated": false, "autowired": false, "secret": false, "defaultValue":
"__debezium-heartbeat", "configurationClass":
"org.apache.camel.component.debezium.configuration.SqlServerConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "T [...]
"includeSchemaChanges": { "kind": "property", "displayName": "Include
Schema Changes", "group": "sqlserver", "label": "consumer,sqlserver",
"required": false, "type": "boolean", "javaType": "boolean", "deprecated":
false, "autowired": false, "secret": false, "defaultValue": true,
"configurationClass":
"org.apache.camel.component.debezium.configuration.SqlServerConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "Whether the connector
should [...]
"maxBatchSize": { "kind": "property", "displayName": "Max Batch Size",
"group": "sqlserver", "label": "consumer,sqlserver", "required": false, "type":
"integer", "javaType": "int", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": 2048, "configurationClass":
"org.apache.camel.component.debezium.configuration.SqlServerConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "Maximum size of each
batch of source records. Def [...]
+ "maxIterationTransactions": { "kind": "property", "displayName": "Max
Iteration Transactions", "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": "This property can be
used to [...]
"maxQueueSize": { "kind": "property", "displayName": "Max Queue Size",
"group": "sqlserver", "label": "consumer,sqlserver", "required": false, "type":
"integer", "javaType": "int", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": 8192, "configurationClass":
"org.apache.camel.component.debezium.configuration.SqlServerConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "Maximum size of the
queue for change events read [...]
"maxQueueSizeInBytes": { "kind": "property", "displayName": "Max Queue
Size In Bytes", "group": "sqlserver", "label": "consumer,sqlserver",
"required": false, "type": "integer", "javaType": "long", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": 0, "configurationClass":
"org.apache.camel.component.debezium.configuration.SqlServerConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "Maximum size of the
queue in bytes [...]
"messageKeyColumns": { "kind": "property", "displayName": "Message Key
Columns", "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 semicolon-separated
list of expressions that ma [...]
@@ -81,9 +85,9 @@
"snapshotLockTimeoutMs": { "kind": "property", "displayName": "Snapshot
Lock Timeout 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": "The maximum number of
milli [...]
"snapshotMaxThreads": { "kind": "property", "displayName": "Snapshot Max
Threads", "group": "sqlserver", "label": "consumer,sqlserver", "required":
false, "type": "integer", "javaType": "int", "deprecated": false, "autowired":
false, "secret": false, "defaultValue": 1, "configurationClass":
"org.apache.camel.component.debezium.configuration.SqlServerConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "The maximum number of
threads used to pe [...]
"snapshotMode": { "kind": "property", "displayName": "Snapshot Mode",
"group": "sqlserver", "label": "consumer,sqlserver", "required": false, "type":
"string", "javaType": "java.lang.String", "deprecated": false, "autowired":
false, "secret": false, "defaultValue": "initial", "configurationClass":
"org.apache.camel.component.debezium.configuration.SqlServerConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "The criteria for
running a snapsh [...]
- "snapshotSelectStatementOverrides": { "kind": "property", "displayName":
"Snapshot Select Statement Overrides", "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 property cont [...]
+ "snapshotSelectStatementOverrides": { "kind": "property", "displayName":
"Snapshot Select Statement Overrides", "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 property cont [...]
"sourceStructVersion": { "kind": "property", "displayName": "Source Struct
Version", "group": "sqlserver", "label": "consumer,sqlserver", "required":
false, "type": "string", "javaType": "java.lang.String", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": "v2",
"configurationClass":
"org.apache.camel.component.debezium.configuration.SqlServerConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "A version of the format
[...]
- "sourceTimestampMode": { "kind": "property", "displayName": "Source
Timestamp Mode", "group": "sqlserver", "label": "consumer,sqlserver",
"required": false, "type": "string", "javaType": "java.lang.String",
"deprecated": false, "autowired": false, "secret": false, "defaultValue":
"commit", "configurationClass":
"org.apache.camel.component.debezium.configuration.SqlServerConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "Configures the crit
[...]
+ "sourceTimestampMode": { "kind": "property", "displayName": "Source
Timestamp Mode", "group": "sqlserver", "label": "consumer,sqlserver",
"required": false, "type": "string", "javaType": "java.lang.String",
"deprecated": false, "autowired": false, "secret": false, "defaultValue":
"commit", "configurationClass":
"org.apache.camel.component.debezium.configuration.SqlServerConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "Configures the crit
[...]
"tableBlacklist": { "kind": "property", "displayName": "Table Blacklist",
"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 comma-separated list
of regular expressions that match [...]
"tableExcludeList": { "kind": "property", "displayName": "Table Exclude
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": "A comma-separated list
of regular expressions that [...]
"tableIgnoreBuiltin": { "kind": "property", "displayName": "Table Ignore
Builtin", "group": "sqlserver", "label": "consumer,sqlserver", "required":
false, "type": "boolean", "javaType": "boolean", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": true,
"configurationClass":
"org.apache.camel.component.debezium.configuration.SqlServerConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "Flag specifying whether
built-in [...]
@@ -122,6 +126,9 @@
"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 [...]
+ "databaseHistorySkipUnparseableDdl": { "kind": "parameter", "displayName":
"Database History Skip Unparseable Ddl", "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": [...]
+ "databaseHistoryStoreOnlyCapturedTablesDdl": { "kind": "parameter",
"displayName": "Database History Store Only Captured Tables Ddl", "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 [...]
+ "databaseHistoryStoreOnlyMonitoredTablesDdl": { "kind": "parameter",
"displayName": "Database History Store Only Monitored Tables Ddl", "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": "configurati [...]
"databaseHostname": { "kind": "parameter", "displayName": "Database
Hostname", "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": "Resolvable hostname or
IP address of the database s [...]
"databaseInstance": { "kind": "parameter", "displayName": "Database
Instance", "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 SQL Server instance
name" },
"databasePassword": { "kind": "parameter", "displayName": "Database
Password", "group": "sqlserver", "label": "consumer,sqlserver", "required":
true, "type": "string", "javaType": "java.lang.String", "deprecated": false,
"deprecationNote": "", "autowired": false, "secret": false,
"configurationClass":
"org.apache.camel.component.debezium.configuration.SqlServerConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "Password of the
database user [...]
@@ -136,6 +143,7 @@
"heartbeatTopicsPrefix": { "kind": "parameter", "displayName": "Heartbeat
Topics Prefix", "group": "sqlserver", "label": "consumer,sqlserver",
"required": false, "type": "string", "javaType": "java.lang.String",
"deprecated": false, "autowired": false, "secret": false, "defaultValue":
"__debezium-heartbeat", "configurationClass":
"org.apache.camel.component.debezium.configuration.SqlServerConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": " [...]
"includeSchemaChanges": { "kind": "parameter", "displayName": "Include
Schema Changes", "group": "sqlserver", "label": "consumer,sqlserver",
"required": false, "type": "boolean", "javaType": "boolean", "deprecated":
false, "autowired": false, "secret": false, "defaultValue": true,
"configurationClass":
"org.apache.camel.component.debezium.configuration.SqlServerConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "Whether the connector
should [...]
"maxBatchSize": { "kind": "parameter", "displayName": "Max Batch Size",
"group": "sqlserver", "label": "consumer,sqlserver", "required": false, "type":
"integer", "javaType": "int", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": 2048, "configurationClass":
"org.apache.camel.component.debezium.configuration.SqlServerConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "Maximum size of each
batch of source records. De [...]
+ "maxIterationTransactions": { "kind": "parameter", "displayName": "Max
Iteration Transactions", "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": "This property can be
used t [...]
"maxQueueSize": { "kind": "parameter", "displayName": "Max Queue Size",
"group": "sqlserver", "label": "consumer,sqlserver", "required": false, "type":
"integer", "javaType": "int", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": 8192, "configurationClass":
"org.apache.camel.component.debezium.configuration.SqlServerConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "Maximum size of the
queue for change events read [...]
"maxQueueSizeInBytes": { "kind": "parameter", "displayName": "Max Queue
Size In Bytes", "group": "sqlserver", "label": "consumer,sqlserver",
"required": false, "type": "integer", "javaType": "long", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": 0, "configurationClass":
"org.apache.camel.component.debezium.configuration.SqlServerConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "Maximum size of the
queue in bytes [...]
"messageKeyColumns": { "kind": "parameter", "displayName": "Message Key
Columns", "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 semicolon-separated
list of expressions that m [...]
@@ -153,9 +161,9 @@
"snapshotLockTimeoutMs": { "kind": "parameter", "displayName": "Snapshot
Lock Timeout 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": "The maximum number of
mill [...]
"snapshotMaxThreads": { "kind": "parameter", "displayName": "Snapshot Max
Threads", "group": "sqlserver", "label": "consumer,sqlserver", "required":
false, "type": "integer", "javaType": "int", "deprecated": false, "autowired":
false, "secret": false, "defaultValue": 1, "configurationClass":
"org.apache.camel.component.debezium.configuration.SqlServerConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "The maximum number of
threads used to p [...]
"snapshotMode": { "kind": "parameter", "displayName": "Snapshot Mode",
"group": "sqlserver", "label": "consumer,sqlserver", "required": false, "type":
"string", "javaType": "java.lang.String", "deprecated": false, "autowired":
false, "secret": false, "defaultValue": "initial", "configurationClass":
"org.apache.camel.component.debezium.configuration.SqlServerConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "The criteria for
running a snaps [...]
- "snapshotSelectStatementOverrides": { "kind": "parameter", "displayName":
"Snapshot Select Statement Overrides", "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 property con [...]
+ "snapshotSelectStatementOverrides": { "kind": "parameter", "displayName":
"Snapshot Select Statement Overrides", "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 property con [...]
"sourceStructVersion": { "kind": "parameter", "displayName": "Source
Struct Version", "group": "sqlserver", "label": "consumer,sqlserver",
"required": false, "type": "string", "javaType": "java.lang.String",
"deprecated": false, "autowired": false, "secret": false, "defaultValue": "v2",
"configurationClass":
"org.apache.camel.component.debezium.configuration.SqlServerConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "A version of the forma
[...]
- "sourceTimestampMode": { "kind": "parameter", "displayName": "Source
Timestamp Mode", "group": "sqlserver", "label": "consumer,sqlserver",
"required": false, "type": "string", "javaType": "java.lang.String",
"deprecated": false, "autowired": false, "secret": false, "defaultValue":
"commit", "configurationClass":
"org.apache.camel.component.debezium.configuration.SqlServerConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "Configures the cri [...]
+ "sourceTimestampMode": { "kind": "parameter", "displayName": "Source
Timestamp Mode", "group": "sqlserver", "label": "consumer,sqlserver",
"required": false, "type": "string", "javaType": "java.lang.String",
"deprecated": false, "autowired": false, "secret": false, "defaultValue":
"commit", "configurationClass":
"org.apache.camel.component.debezium.configuration.SqlServerConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "Configures the cri [...]
"tableBlacklist": { "kind": "parameter", "displayName": "Table Blacklist",
"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 comma-separated list
of regular expressions that matc [...]
"tableExcludeList": { "kind": "parameter", "displayName": "Table Exclude
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": "A comma-separated list
of regular expressions that [...]
"tableIgnoreBuiltin": { "kind": "parameter", "displayName": "Table Ignore
Builtin", "group": "sqlserver", "label": "consumer,sqlserver", "required":
false, "type": "boolean", "javaType": "boolean", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": true,
"configurationClass":
"org.apache.camel.component.debezium.configuration.SqlServerConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "Flag specifying whether
built-in [...]
diff --git a/components-starter/README.adoc b/components-starter/README.adoc
index 97e7c49..0409f5c 100644
--- a/components-starter/README.adoc
+++ b/components-starter/README.adoc
@@ -5,7 +5,7 @@ Apache Camel Spring Boot supports the following Camel artifacts
as Spring Boot S
== Camel Components
// components: START
-Number of Camel components: 333 in 269 JAR artifacts (1 deprecated)
+Number of Camel components: 334 in 270 JAR artifacts (1 deprecated)
[width="100%",cols="4,3,3,3,6",options="header"]
|===
@@ -95,6 +95,8 @@ Number of Camel components: 333 in 269 JAR artifacts (1
deprecated)
| xref:latest@components::azure-eventhubs-component.adoc[Azure Event Hubs] |
camel-azure-eventhubs-starter | Stable | 3.5 | The azure-eventhubs component
that integrates Azure Event Hubs using AMQP protocol. Azure EventHubs is a
highly scalable publish-subscribe service that can ingest millions of events
per second and stream them to multiple consumers.
+| xref:latest@components::azure-servicebus-component.adoc[Azure ServiceBus] |
camel-azure-servicebus-starter | Preview | 3.12 | The azure-servicebus
component that integrates Azure ServiceBus. Azure ServiceBus is a fully managed
enterprise integration message broker. Service Bus can decouple applications
and services. Service Bus offers a reliable and secure platform for
asynchronous transfer of data and state. Data is transferred between different
applications and services using messages.
+
| xref:latest@components::azure-storage-blob-component.adoc[Azure Storage Blob
Service] | camel-azure-storage-blob-starter | Stable | 3.3 | Store and retrieve
blobs from Azure Storage Blob Service using SDK v12.
| xref:latest@components::azure-storage-datalake-component.adoc[Azure storage
datalake service] | camel-azure-storage-datalake-starter | Stable | 3.8 | Camel
Azure Datalake Gen2 Component
diff --git
a/components-starter/camel-debezium-mysql-starter/src/main/docs/debezium-mysql-starter.adoc
b/components-starter/camel-debezium-mysql-starter/src/main/docs/debezium-mysql-starter.adoc
index 51a4671..7eab3c3 100644
---
a/components-starter/camel-debezium-mysql-starter/src/main/docs/debezium-mysql-starter.adoc
+++
b/components-starter/camel-debezium-mysql-starter/src/main/docs/debezium-mysql-starter.adoc
@@ -17,7 +17,7 @@ When using debezium-mysql with Spring Boot make sure to use
the following Maven
----
-The component supports 89 options, which are listed below.
+The component supports 93 options, which are listed below.
@@ -46,6 +46,9 @@ The component supports 89 options, which are listed below.
| *camel.component.debezium-mysql.database-history-kafka-recovery-attempts* |
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 receiving no data
is (recovery.attempts) x (recovery.poll.interval.ms). | 100 | Integer
|
*camel.component.debezium-mysql.database-history-kafka-recovery-poll-interval-ms*
| The number of milliseconds to wait while polling for persisted data during
recovery. The option is a int type. | 100 | Integer
| *camel.component.debezium-mysql.database-history-kafka-topic* | The name of
the topic for the database schema history | | String
+| *camel.component.debezium-mysql.database-history-skip-unparseable-ddl* |
Controls the action Debezium will take when it meets a DDL statement in binlog,
that it cannot parse.By default the connector will stop operating but by
changing the setting it can ignore the statements which it cannot parse. If
skipping is enabled then Debezium can miss metadata changes. | false | Boolean
+|
*camel.component.debezium-mysql.database-history-store-only-captured-tables-ddl*
| Controls what DDL will Debezium store in database history. By default
(false) Debezium will store all incoming DDL statements. If set to true, then
only DDL that manipulates a captured table will be stored. | false | Boolean
+|
*camel.component.debezium-mysql.database-history-store-only-monitored-tables-ddl*
| Controls what DDL will Debezium store in database history. By default
(false) Debezium will store all incoming DDL statements. If set to true, then
only DDL that manipulates a monitored table will be stored (deprecated, use
database.history.store.only.captured.tables.ddl instead) | false | Boolean
| *camel.component.debezium-mysql.database-hostname* | Resolvable hostname or
IP address of the database server. | | String
| *camel.component.debezium-mysql.database-include-list* | The databases for
which changes are to be captured | | String
| *camel.component.debezium-mysql.database-initial-statements* | A semicolon
separated list of SQL statements to be executed when a JDBC connection (not
binlog reading connection) to the database is established. Note that the
connector may establish JDBC connections at its own discretion, so this should
typically be used for configuration of session parameters only,but not for
executing DML statements. Use doubled semicolon (';;') to use a semicolon as a
character and not as a delimiter. [...]
@@ -75,6 +78,7 @@ The component supports 89 options, which are listed below.
| *camel.component.debezium-mysql.include-query* | Whether the connector
should include the original SQL query that generated the change event. Note:
This option requires MySQL be configured with the binlog_rows_query_log_events
option set to ON. Query will not be present for events generated from snapshot.
WARNING: Enabling this option may expose tables or fields explicitly
blacklisted or masked by including the original SQL statement in the change
event. For this reason the default val [...]
| *camel.component.debezium-mysql.include-schema-changes* | Whether the
connector should publish changes in the database schema to a Kafka topic with
the same name as the database server ID. Each schema change will be recorded
using a key that contains the database name and whose value include logical
description of the new schema and optionally the DDL statement(s).The default
is 'true'. This is independent of how the connector internally records database
history. | true | Boolean
| *camel.component.debezium-mysql.inconsistent-schema-handling-mode* | Specify
how binlog events that belong to a table missing from internal schema
representation (i.e. internal representation is not consistent with database)
should be handled, including:'fail' (the default) an exception indicating the
problematic event and its binlog position is raised, causing the connector to
be stopped; 'warn' the problematic event and its binlog position will be logged
and the event will be skipped [...]
+| *camel.component.debezium-mysql.incremental-snapshot-chunk-size* | The
maximum size of chunk for incremental snapshotting | 1024 | Integer
| *camel.component.debezium-mysql.internal-key-converter* | The Converter
class that should be used to serialize and deserialize key data for offsets.
The default is JSON converter. | org.apache.kafka.connect.json.JsonConverter |
String
| *camel.component.debezium-mysql.internal-value-converter* | The Converter
class that should be used to serialize and deserialize value data for offsets.
The default is JSON converter. | org.apache.kafka.connect.json.JsonConverter |
String
| *camel.component.debezium-mysql.max-batch-size* | Maximum size of each batch
of source records. Defaults to 2048. | 2048 | Integer
@@ -104,7 +108,7 @@ The component supports 89 options, which are listed below.
| *camel.component.debezium-mysql.snapshot-max-threads* | The maximum number
of threads used to perform the snapshot. Defaults to 1. | 1 | Integer
| *camel.component.debezium-mysql.snapshot-mode* | The criteria for running a
snapshot upon startup of the connector. Options include: 'when_needed' to
specify that the connector run a snapshot upon startup whenever it deems it
necessary; 'schema_only' to only take a snapshot of the schema (table
structures) but no actual data; 'initial' (the default) to specify the
connector can run a snapshot only when no offsets are available for the logical
server name; 'initial_only' same as 'initia [...]
| *camel.component.debezium-mysql.snapshot-new-tables* | BETA FEATURE: On
connector restart, the connector will check if there have been any new tables
added to the configuration, and snapshot them. There is presently only two
options:'off': Default behavior. Do not snapshot new tables.'parallel': The
snapshot of the new tables will occur in parallel to the continued binlog
reading of the old tables. When the snapshot completes, an independent binlog
reader will begin reading the events [...]
-| *camel.component.debezium-mysql.snapshot-select-statement-overrides* | This
property contains a comma-separated list of fully-qualified tables
(DB_NAME.TABLE_NAME) or (SCHEMA_NAME.TABLE_NAME), depending on thespecific
connectors . Select statements for the individual tables are specified in
further configuration properties, one for each table, identified by the id
'snapshot.select.statement.overrides.DB_NAME.TABLE_NAME' or
'snapshot.select.statement.overrides.SCHEMA_NAME.TABLE_NAME', r [...]
+| *camel.component.debezium-mysql.snapshot-select-statement-overrides* | This
property contains a comma-separated list of fully-qualified tables
(DB_NAME.TABLE_NAME) or (SCHEMA_NAME.TABLE_NAME), depending on thespecific
connectors. Select statements for the individual tables are specified in
further configuration properties, one for each table, identified by the id
'snapshot.select.statement.overrides.DB_NAME.TABLE_NAME' or
'snapshot.select.statement.overrides.SCHEMA_NAME.TABLE_NAME', re [...]
| *camel.component.debezium-mysql.source-struct-version* | A version of the
format of the publicly visible source part in the message | v2 | String
| *camel.component.debezium-mysql.table-blacklist* | A comma-separated list of
regular expressions that match the fully-qualified names of tables to be
excluded from monitoring (deprecated, use table.exclude.list instead) | |
String
| *camel.component.debezium-mysql.table-exclude-list* | A comma-separated list
of regular expressions that match the fully-qualified names of tables to be
excluded from monitoring | | String
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 b4b8946..c485aaf 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
@@ -227,6 +227,26 @@ public class DebeziumMySqlComponentConfiguration
*/
private String databaseHistoryKafkaTopic;
/**
+ * Controls the action Debezium will take when it meets a DDL statement in
+ * binlog, that it cannot parse.By default the connector will stop
operating
+ * but by changing the setting it can ignore the statements which it cannot
+ * parse. If skipping is enabled then Debezium can miss metadata changes.
+ */
+ private Boolean databaseHistorySkipUnparseableDdl = false;
+ /**
+ * Controls what DDL will Debezium store in database history. By default
+ * (false) Debezium will store all incoming DDL statements. If set to true,
+ * then only DDL that manipulates a captured table will be stored.
+ */
+ private Boolean databaseHistoryStoreOnlyCapturedTablesDdl = false;
+ /**
+ * Controls what DDL will Debezium store in database history. By default
+ * (false) Debezium will store all incoming DDL statements. If set to true,
+ * then only DDL that manipulates a monitored table will be stored
+ * (deprecated, use database.history.store.only.captured.tables.ddl
instead)
+ */
+ private Boolean databaseHistoryStoreOnlyMonitoredTablesDdl = false;
+ /**
* Resolvable hostname or IP address of the database server.
*/
private String databaseHostname;
@@ -421,6 +441,10 @@ public class DebeziumMySqlComponentConfiguration
*/
private String inconsistentSchemaHandlingMode = "fail";
/**
+ * The maximum size of chunk for incremental snapshotting
+ */
+ private Integer incrementalSnapshotChunkSize = 1024;
+ /**
* Maximum size of each batch of source records. Defaults to 2048.
*/
private Integer maxBatchSize = 2048;
@@ -558,7 +582,7 @@ public class DebeziumMySqlComponentConfiguration
/**
* This property contains a comma-separated list of fully-qualified tables
* (DB_NAME.TABLE_NAME) or (SCHEMA_NAME.TABLE_NAME), depending on
- * thespecific connectors . Select statements for the individual tables are
+ * thespecific connectors. Select statements for the individual tables are
* specified in further configuration properties, one for each table,
* identified by the id
* 'snapshot.select.statement.overrides.DB_NAME.TABLE_NAME' or
@@ -880,6 +904,33 @@ public class DebeziumMySqlComponentConfiguration
this.databaseHistoryKafkaTopic = databaseHistoryKafkaTopic;
}
+ public Boolean getDatabaseHistorySkipUnparseableDdl() {
+ return databaseHistorySkipUnparseableDdl;
+ }
+
+ public void setDatabaseHistorySkipUnparseableDdl(
+ Boolean databaseHistorySkipUnparseableDdl) {
+ this.databaseHistorySkipUnparseableDdl =
databaseHistorySkipUnparseableDdl;
+ }
+
+ public Boolean getDatabaseHistoryStoreOnlyCapturedTablesDdl() {
+ return databaseHistoryStoreOnlyCapturedTablesDdl;
+ }
+
+ public void setDatabaseHistoryStoreOnlyCapturedTablesDdl(
+ Boolean databaseHistoryStoreOnlyCapturedTablesDdl) {
+ this.databaseHistoryStoreOnlyCapturedTablesDdl =
databaseHistoryStoreOnlyCapturedTablesDdl;
+ }
+
+ public Boolean getDatabaseHistoryStoreOnlyMonitoredTablesDdl() {
+ return databaseHistoryStoreOnlyMonitoredTablesDdl;
+ }
+
+ public void setDatabaseHistoryStoreOnlyMonitoredTablesDdl(
+ Boolean databaseHistoryStoreOnlyMonitoredTablesDdl) {
+ this.databaseHistoryStoreOnlyMonitoredTablesDdl =
databaseHistoryStoreOnlyMonitoredTablesDdl;
+ }
+
public String getDatabaseHostname() {
return databaseHostname;
}
@@ -1110,6 +1161,15 @@ public class DebeziumMySqlComponentConfiguration
this.inconsistentSchemaHandlingMode = inconsistentSchemaHandlingMode;
}
+ public Integer getIncrementalSnapshotChunkSize() {
+ return incrementalSnapshotChunkSize;
+ }
+
+ public void setIncrementalSnapshotChunkSize(
+ Integer incrementalSnapshotChunkSize) {
+ this.incrementalSnapshotChunkSize = incrementalSnapshotChunkSize;
+ }
+
public Integer getMaxBatchSize() {
return maxBatchSize;
}
diff --git
a/components-starter/camel-debezium-postgres-starter/src/main/docs/debezium-postgres-starter.adoc
b/components-starter/camel-debezium-postgres-starter/src/main/docs/debezium-postgres-starter.adoc
index 63d4bf1..d457ca3 100644
---
a/components-starter/camel-debezium-postgres-starter/src/main/docs/debezium-postgres-starter.adoc
+++
b/components-starter/camel-debezium-postgres-starter/src/main/docs/debezium-postgres-starter.adoc
@@ -17,7 +17,7 @@ When using debezium-postgres with Spring Boot make sure to
use the following Mav
----
-The component supports 89 options, which are listed below.
+The component supports 90 options, which are listed below.
@@ -59,6 +59,7 @@ The component supports 89 options, which are listed below.
| *camel.component.debezium-postgres.heartbeat-topics-prefix* | The prefix
that is used to name heartbeat topics.Defaults to __debezium-heartbeat. |
__debezium-heartbeat | String
| *camel.component.debezium-postgres.hstore-handling-mode* | Specify how
HSTORE columns should be represented in change events, including:'json'
represents values as string-ified JSON (default)'map' represents values as a
key/value map | json | String
| *camel.component.debezium-postgres.include-unknown-datatypes* | Specify
whether the fields of data type not supported by Debezium should be
processed:'false' (the default) omits the fields; 'true' converts the field
into an implementation dependent binary representation. | false | Boolean
+| *camel.component.debezium-postgres.incremental-snapshot-chunk-size* | The
maximum size of chunk for incremental snapshotting | 1024 | Integer
| *camel.component.debezium-postgres.internal-key-converter* | The Converter
class that should be used to serialize and deserialize key data for offsets.
The default is JSON converter. | org.apache.kafka.connect.json.JsonConverter |
String
| *camel.component.debezium-postgres.internal-value-converter* | The Converter
class that should be used to serialize and deserialize value data for offsets.
The default is JSON converter. | org.apache.kafka.connect.json.JsonConverter |
String
| *camel.component.debezium-postgres.interval-handling-mode* | Specify how
INTERVAL columns should be represented in change events, including:'string'
represents values as an exact ISO formatted string'numeric' (default)
represents values using the inexact conversion into microseconds | numeric |
String
@@ -100,8 +101,8 @@ The component supports 89 options, which are listed below.
| *camel.component.debezium-postgres.snapshot-include-collection-list* | this
setting must be set to specify a list of tables/collections whose snapshot must
be taken on creating or restarting the connector. | | String
| *camel.component.debezium-postgres.snapshot-lock-timeout-ms* | The maximum
number of millis to wait for table locks at the beginning of a snapshot. If
locks cannot be acquired in this time frame, the snapshot will be aborted.
Defaults to 10 seconds. The option is a long type. | 10000 | Long
| *camel.component.debezium-postgres.snapshot-max-threads* | The maximum
number of threads used to perform the snapshot. Defaults to 1. | 1 | Integer
-| *camel.component.debezium-postgres.snapshot-mode* | The criteria for running
a snapshot upon startup of the connector. Options include: 'always' to specify
that the connector run a snapshot each time it starts up; 'initial' (the
default) to specify the connector can run a snapshot only when no offsets are
available for the logical server name; 'initial_only' same as 'initial' except
the connector should stop after completing the snapshot and before it would
normally start emitting chan [...]
-| *camel.component.debezium-postgres.snapshot-select-statement-overrides* |
This property contains a comma-separated list of fully-qualified tables
(DB_NAME.TABLE_NAME) or (SCHEMA_NAME.TABLE_NAME), depending on thespecific
connectors . Select statements for the individual tables are specified in
further configuration properties, one for each table, identified by the id
'snapshot.select.statement.overrides.DB_NAME.TABLE_NAME' or
'snapshot.select.statement.overrides.SCHEMA_NAME.TABLE_NAME' [...]
+| *camel.component.debezium-postgres.snapshot-mode* | The criteria for running
a snapshot upon startup of the connector. Options include: 'always' to specify
that the connector run a snapshot each time it starts up; 'initial' (the
default) to specify the connector can run a snapshot only when no offsets are
available for the logical server name; 'initial_only' same as 'initial' except
the connector should stop after completing the snapshot and before it would
normally start emitting chan [...]
+| *camel.component.debezium-postgres.snapshot-select-statement-overrides* |
This property contains a comma-separated list of fully-qualified tables
(DB_NAME.TABLE_NAME) or (SCHEMA_NAME.TABLE_NAME), depending on thespecific
connectors. Select statements for the individual tables are specified in
further configuration properties, one for each table, identified by the id
'snapshot.select.statement.overrides.DB_NAME.TABLE_NAME' or
'snapshot.select.statement.overrides.SCHEMA_NAME.TABLE_NAME', [...]
| *camel.component.debezium-postgres.source-struct-version* | A version of the
format of the publicly visible source part in the message | v2 | String
| *camel.component.debezium-postgres.status-update-interval-ms* | Frequency
for sending replication connection status updates to the server, given in
milliseconds. Defaults to 10 seconds (10,000 ms). The option is a int type. |
10000 | Integer
| *camel.component.debezium-postgres.table-blacklist* | A comma-separated list
of regular expressions that match the fully-qualified names of tables to be
excluded from monitoring (deprecated, use table.exclude.list instead) | |
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 86a8238..6f90d32 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
@@ -299,6 +299,10 @@ public class DebeziumPostgresComponentConfiguration
*/
private Boolean includeUnknownDatatypes = false;
/**
+ * The maximum size of chunk for incremental snapshotting
+ */
+ private Integer incrementalSnapshotChunkSize = 1024;
+ /**
* Specify how INTERVAL columns should be represented in change events,
* including:'string' represents values as an exact ISO formatted
* string'numeric' (default) represents values using the inexact conversion
@@ -497,9 +501,8 @@ public class DebeziumPostgresComponentConfiguration
* stop after completing the snapshot and before it would normally start
* emitting changes;'never' to specify the connector should never run a
* snapshot and that upon first startup the connector should read from the
- * last position (LSN) recorded by the server; and'exported' to specify the
- * connector should run a snapshot based on the position when the
- * replication slot was created; 'custom' to specify a custom class with
+ * last position (LSN) recorded by the server; and'exported' deprecated,
use
+ * 'initial' instead; 'custom' to specify a custom class with
* 'snapshot.custom_class' which will be loaded and used to determine the
* snapshot, see docs for more details.
*/
@@ -507,7 +510,7 @@ public class DebeziumPostgresComponentConfiguration
/**
* This property contains a comma-separated list of fully-qualified tables
* (DB_NAME.TABLE_NAME) or (SCHEMA_NAME.TABLE_NAME), depending on
- * thespecific connectors . Select statements for the individual tables are
+ * thespecific connectors. Select statements for the individual tables are
* specified in further configuration properties, one for each table,
* identified by the id
* 'snapshot.select.statement.overrides.DB_NAME.TABLE_NAME' or
@@ -949,6 +952,15 @@ public class DebeziumPostgresComponentConfiguration
this.includeUnknownDatatypes = includeUnknownDatatypes;
}
+ public Integer getIncrementalSnapshotChunkSize() {
+ return incrementalSnapshotChunkSize;
+ }
+
+ public void setIncrementalSnapshotChunkSize(
+ Integer incrementalSnapshotChunkSize) {
+ this.incrementalSnapshotChunkSize = incrementalSnapshotChunkSize;
+ }
+
public String getIntervalHandlingMode() {
return intervalHandlingMode;
}
diff --git
a/components-starter/camel-debezium-sqlserver-starter/src/main/docs/debezium-sqlserver-starter.adoc
b/components-starter/camel-debezium-sqlserver-starter/src/main/docs/debezium-sqlserver-starter.adoc
index 8df5610..9ea9ee1 100644
---
a/components-starter/camel-debezium-sqlserver-starter/src/main/docs/debezium-sqlserver-starter.adoc
+++
b/components-starter/camel-debezium-sqlserver-starter/src/main/docs/debezium-sqlserver-starter.adoc
@@ -17,7 +17,7 @@ When using debezium-sqlserver with Spring Boot make sure to
use the following Ma
----
-The component supports 70 options, which are listed below.
+The component supports 74 options, which are listed below.
@@ -42,6 +42,9 @@ The component supports 70 options, which are listed below.
|
*camel.component.debezium-sqlserver.database-history-kafka-recovery-attempts* |
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 receiving no data
is (recovery.attempts) x (recovery.poll.interval.ms). | 100 | Integer
|
*camel.component.debezium-sqlserver.database-history-kafka-recovery-poll-interval-ms*
| The number of milliseconds to wait while polling for persisted data during
recovery. The option is a int type. | 100 | Integer
| *camel.component.debezium-sqlserver.database-history-kafka-topic* | The name
of the topic for the database schema history | | String
+| *camel.component.debezium-sqlserver.database-history-skip-unparseable-ddl* |
Controls the action Debezium will take when it meets a DDL statement in binlog,
that it cannot parse.By default the connector will stop operating but by
changing the setting it can ignore the statements which it cannot parse. If
skipping is enabled then Debezium can miss metadata changes. | false | Boolean
+|
*camel.component.debezium-sqlserver.database-history-store-only-captured-tables-ddl*
| Controls what DDL will Debezium store in database history. By default
(false) Debezium will store all incoming DDL statements. If set to true, then
only DDL that manipulates a captured table will be stored. | false | Boolean
+|
*camel.component.debezium-sqlserver.database-history-store-only-monitored-tables-ddl*
| Controls what DDL will Debezium store in database history. By default
(false) Debezium will store all incoming DDL statements. If set to true, then
only DDL that manipulates a monitored table will be stored (deprecated, use
database.history.store.only.captured.tables.ddl instead) | false | Boolean
| *camel.component.debezium-sqlserver.database-hostname* | Resolvable hostname
or IP address of the database server. | | String
| *camel.component.debezium-sqlserver.database-instance* | The SQL Server
instance name | | String
| *camel.component.debezium-sqlserver.database-password* | Password of the
database user to be used when connecting to the database. | | String
@@ -59,6 +62,7 @@ The component supports 70 options, which are listed below.
| *camel.component.debezium-sqlserver.internal-key-converter* | The Converter
class that should be used to serialize and deserialize key data for offsets.
The default is JSON converter. | org.apache.kafka.connect.json.JsonConverter |
String
| *camel.component.debezium-sqlserver.internal-value-converter* | The
Converter class that should be used to serialize and deserialize value data for
offsets. The default is JSON converter. |
org.apache.kafka.connect.json.JsonConverter | String
| *camel.component.debezium-sqlserver.max-batch-size* | Maximum size of each
batch of source records. Defaults to 2048. | 2048 | Integer
+| *camel.component.debezium-sqlserver.max-iteration-transactions* | This
property can be used to reduce the connector memory usage footprint when
changes are streamed from multiple tables per database. | 0 | Integer
| *camel.component.debezium-sqlserver.max-queue-size* | Maximum size of the
queue for change events read from the database log but not yet recorded or
forwarded. Defaults to 8192, and should always be larger than the maximum batch
size. | 8192 | Integer
| *camel.component.debezium-sqlserver.max-queue-size-in-bytes* | Maximum size
of the queue in bytes for change events read from the database log but not yet
recorded or forwarded. Defaults to 0. Mean the feature is not enabled | 0 | Long
| *camel.component.debezium-sqlserver.message-key-columns* | A
semicolon-separated list of expressions that match fully-qualified tables and
column(s) to be used as message key. Each expression must match the pattern
':',where the table names could be defined as (DB_NAME.TABLE_NAME) or
(SCHEMA_NAME.TABLE_NAME), depending on the specific connector,and the key
columns are a comma-separated list of columns representing the custom key. For
any table without an explicit key configuration the [...]
@@ -84,9 +88,9 @@ The component supports 70 options, which are listed below.
| *camel.component.debezium-sqlserver.snapshot-lock-timeout-ms* | The maximum
number of millis to wait for table locks at the beginning of a snapshot. If
locks cannot be acquired in this time frame, the snapshot will be aborted.
Defaults to 10 seconds. The option is a long type. | 10000 | Long
| *camel.component.debezium-sqlserver.snapshot-max-threads* | The maximum
number of threads used to perform the snapshot. Defaults to 1. | 1 | Integer
| *camel.component.debezium-sqlserver.snapshot-mode* | The criteria for
running a snapshot upon startup of the connector. Options include: 'initial'
(the default) to specify the connector should run a snapshot only when no
offsets are available for the logical server name; 'schema_only' to specify the
connector should run a snapshot of the schema when no offsets are available for
the logical server name. | initial | String
-| *camel.component.debezium-sqlserver.snapshot-select-statement-overrides* |
This property contains a comma-separated list of fully-qualified tables
(DB_NAME.TABLE_NAME) or (SCHEMA_NAME.TABLE_NAME), depending on thespecific
connectors . Select statements for the individual tables are specified in
further configuration properties, one for each table, identified by the id
'snapshot.select.statement.overrides.DB_NAME.TABLE_NAME' or
'snapshot.select.statement.overrides.SCHEMA_NAME.TABLE_NAME [...]
+| *camel.component.debezium-sqlserver.snapshot-select-statement-overrides* |
This property contains a comma-separated list of fully-qualified tables
(DB_NAME.TABLE_NAME) or (SCHEMA_NAME.TABLE_NAME), depending on thespecific
connectors. Select statements for the individual tables are specified in
further configuration properties, one for each table, identified by the id
'snapshot.select.statement.overrides.DB_NAME.TABLE_NAME' or
'snapshot.select.statement.overrides.SCHEMA_NAME.TABLE_NAME' [...]
| *camel.component.debezium-sqlserver.source-struct-version* | A version of
the format of the publicly visible source part in the message | v2 | String
-| *camel.component.debezium-sqlserver.source-timestamp-mode* | Configures the
criteria of the attached timestamp within the source record (ts_ms).Options
include:'commit', (default) the source timestamp is set to the instant where
the record was committed in the database'processing', the source timestamp is
set to the instant where the record was processed by Debezium. | commit | String
+| *camel.component.debezium-sqlserver.source-timestamp-mode* | Configures the
criteria of the attached timestamp within the source record (ts_ms).Options
include:'commit', (default) the source timestamp is set to the instant where
the record was committed in the database'processing', (deprecated) the source
timestamp is set to the instant where the record was processed by Debezium. |
commit | String
| *camel.component.debezium-sqlserver.table-blacklist* | A comma-separated
list of regular expressions that match the fully-qualified names of tables to
be excluded from monitoring (deprecated, use table.exclude.list instead) | |
String
| *camel.component.debezium-sqlserver.table-exclude-list* | A comma-separated
list of regular expressions that match the fully-qualified names of tables to
be excluded from monitoring | | String
| *camel.component.debezium-sqlserver.table-ignore-builtin* | Flag specifying
whether built-in tables should be ignored. | true | Boolean
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 88da07a..2644ce3 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
@@ -200,6 +200,26 @@ public class DebeziumSqlserverComponentConfiguration
*/
private String databaseHistoryKafkaTopic;
/**
+ * Controls the action Debezium will take when it meets a DDL statement in
+ * binlog, that it cannot parse.By default the connector will stop
operating
+ * but by changing the setting it can ignore the statements which it cannot
+ * parse. If skipping is enabled then Debezium can miss metadata changes.
+ */
+ private Boolean databaseHistorySkipUnparseableDdl = false;
+ /**
+ * Controls what DDL will Debezium store in database history. By default
+ * (false) Debezium will store all incoming DDL statements. If set to true,
+ * then only DDL that manipulates a captured table will be stored.
+ */
+ private Boolean databaseHistoryStoreOnlyCapturedTablesDdl = false;
+ /**
+ * Controls what DDL will Debezium store in database history. By default
+ * (false) Debezium will store all incoming DDL statements. If set to true,
+ * then only DDL that manipulates a monitored table will be stored
+ * (deprecated, use database.history.store.only.captured.tables.ddl
instead)
+ */
+ private Boolean databaseHistoryStoreOnlyMonitoredTablesDdl = false;
+ /**
* Resolvable hostname or IP address of the database server.
*/
private String databaseHostname;
@@ -283,6 +303,11 @@ public class DebeziumSqlserverComponentConfiguration
*/
private Integer maxBatchSize = 2048;
/**
+ * This property can be used to reduce the connector memory usage footprint
+ * when changes are streamed from multiple tables per database.
+ */
+ private Integer maxIterationTransactions = 0;
+ /**
* Maximum size of the queue for change events read from the database log
* but not yet recorded or forwarded. Defaults to 8192, and should always
be
* larger than the maximum batch size.
@@ -395,7 +420,7 @@ public class DebeziumSqlserverComponentConfiguration
/**
* This property contains a comma-separated list of fully-qualified tables
* (DB_NAME.TABLE_NAME) or (SCHEMA_NAME.TABLE_NAME), depending on
- * thespecific connectors . Select statements for the individual tables are
+ * thespecific connectors. Select statements for the individual tables are
* specified in further configuration properties, one for each table,
* identified by the id
* 'snapshot.select.statement.overrides.DB_NAME.TABLE_NAME' or
@@ -416,8 +441,8 @@ public class DebeziumSqlserverComponentConfiguration
* Configures the criteria of the attached timestamp within the source
* record (ts_ms).Options include:'commit', (default) the source timestamp
* is set to the instant where the record was committed in the
- * database'processing', the source timestamp is set to the instant where
- * the record was processed by Debezium.
+ * database'processing', (deprecated) the source timestamp is set to the
+ * instant where the record was processed by Debezium.
*/
private String sourceTimestampMode = "commit";
/**
@@ -694,6 +719,33 @@ public class DebeziumSqlserverComponentConfiguration
this.databaseHistoryKafkaTopic = databaseHistoryKafkaTopic;
}
+ public Boolean getDatabaseHistorySkipUnparseableDdl() {
+ return databaseHistorySkipUnparseableDdl;
+ }
+
+ public void setDatabaseHistorySkipUnparseableDdl(
+ Boolean databaseHistorySkipUnparseableDdl) {
+ this.databaseHistorySkipUnparseableDdl =
databaseHistorySkipUnparseableDdl;
+ }
+
+ public Boolean getDatabaseHistoryStoreOnlyCapturedTablesDdl() {
+ return databaseHistoryStoreOnlyCapturedTablesDdl;
+ }
+
+ public void setDatabaseHistoryStoreOnlyCapturedTablesDdl(
+ Boolean databaseHistoryStoreOnlyCapturedTablesDdl) {
+ this.databaseHistoryStoreOnlyCapturedTablesDdl =
databaseHistoryStoreOnlyCapturedTablesDdl;
+ }
+
+ public Boolean getDatabaseHistoryStoreOnlyMonitoredTablesDdl() {
+ return databaseHistoryStoreOnlyMonitoredTablesDdl;
+ }
+
+ public void setDatabaseHistoryStoreOnlyMonitoredTablesDdl(
+ Boolean databaseHistoryStoreOnlyMonitoredTablesDdl) {
+ this.databaseHistoryStoreOnlyMonitoredTablesDdl =
databaseHistoryStoreOnlyMonitoredTablesDdl;
+ }
+
public String getDatabaseHostname() {
return databaseHostname;
}
@@ -808,6 +860,14 @@ public class DebeziumSqlserverComponentConfiguration
this.maxBatchSize = maxBatchSize;
}
+ public Integer getMaxIterationTransactions() {
+ return maxIterationTransactions;
+ }
+
+ public void setMaxIterationTransactions(Integer maxIterationTransactions) {
+ this.maxIterationTransactions = maxIterationTransactions;
+ }
+
public Integer getMaxQueueSize() {
return maxQueueSize;
}
diff --git a/docs/modules/ROOT/pages/azure-servicebus-starter.adoc
b/docs/modules/ROOT/pages/azure-servicebus-starter.adoc
new file mode 100644
index 0000000..524d7ca
--- /dev/null
+++ b/docs/modules/ROOT/pages/azure-servicebus-starter.adoc
@@ -0,0 +1,54 @@
+// spring-boot-auto-configure options: START
+:page-partial:
+:doctitle: Camel Spring Boot Starter for azure-servicebus
+
+== Spring Boot Auto-Configuration
+
+When using azure-servicebus with Spring Boot make sure to use the following
Maven dependency to have support for auto configuration:
+
+[source,xml]
+----
+<dependency>
+ <groupId>org.apache.camel.springboot</groupId>
+ <artifactId>camel-azure-servicebus-starter</artifactId>
+ <version>x.x.x</version>
+ <!-- use the same version as your Camel core version -->
+</dependency>
+----
+
+
+The component supports 24 options, which are listed below.
+
+
+
+[width="100%",cols="2,5,^1,2",options="header"]
+|===
+| Name | Description | Default | Type
+| *camel.component.azure-servicebus.amqp-retry-options* | Sets the retry
options for Service Bus clients. If not specified, the default retry options
are used. The option is a com.azure.core.amqp.AmqpRetryOptions type. | |
AmqpRetryOptions
+| *camel.component.azure-servicebus.amqp-transport-type* | Sets the transport
type by which all the communication with Azure Service Bus occurs. Default
value is AmqpTransportType#AMQP. | | AmqpTransportType
+| *camel.component.azure-servicebus.autowired-enabled* | Whether autowiring is
enabled. This is used for automatic autowiring options (the option must be
marked as autowired) by looking up in the registry to find if there is a single
instance of matching type, which then gets configured on the component. This
can be used for automatic configuring JDBC data sources, JMS connection
factories, AWS Clients, etc. | true | Boolean
+| *camel.component.azure-servicebus.bridge-error-handler* | Allows for
bridging the consumer to the Camel routing Error Handler, which mean any
exceptions occurred while the consumer is trying to pickup incoming messages,
or the likes, will now be processed as a message and handled by the routing
Error Handler. By default the consumer will use the
org.apache.camel.spi.ExceptionHandler to deal with exceptions, that will be
logged at WARN or ERROR level and ignored. | false | Boolean
+| *camel.component.azure-servicebus.client-options* | Sets the ClientOptions
to be sent from the client built from this builder, enabling customization of
certain properties, as well as support the addition of custom header
information. Refer to the ClientOptions documentation for more information. The
option is a com.azure.core.util.ClientOptions type. | | ClientOptions
+| *camel.component.azure-servicebus.configuration* | The component
configurations. The option is a
org.apache.camel.component.azure.servicebus.ServiceBusConfiguration type. | |
ServiceBusConfiguration
+| *camel.component.azure-servicebus.connection-string* | Sets the connection
string for a Service Bus namespace or a specific Service Bus resource. | |
String
+| *camel.component.azure-servicebus.consumer-operation* | Sets the desired
operation to be used in the consumer | | ServiceBusConsumerOperationDefinition
+| *camel.component.azure-servicebus.disable-auto-complete* | Disables
auto-complete and auto-abandon of received messages. By default, a successfully
processed message is {link
ServiceBusReceiverAsyncClient#complete(ServiceBusReceivedMessage) completed}.
If an error happens when the message is processed, it is {link
ServiceBusReceiverAsyncClient#abandon(ServiceBusReceivedMessage) abandoned}. |
false | Boolean
+| *camel.component.azure-servicebus.enabled* | Whether to enable auto
configuration of the azure-servicebus component. This is enabled by default. |
| Boolean
+| *camel.component.azure-servicebus.lazy-start-producer* | Whether the
producer should be started lazy (on the first message). By starting lazy you
can use this to allow CamelContext and routes to startup in situations where a
producer may otherwise fail during starting and cause the route to fail being
started. By deferring this startup to be lazy then the startup failure can be
handled during routing messages via Camel's routing error handlers. Beware that
when the first message is pro [...]
+| *camel.component.azure-servicebus.max-auto-lock-renew-duration* | Sets the
amount of time to continue auto-renewing the lock. Setting Duration#ZERO or
null disables auto-renewal. For {link ServiceBusReceiveMode#RECEIVE_AND_DELETE
RECEIVE_AND_DELETE} mode, auto-renewal is disabled. The option is a
java.time.Duration type. | | Duration
+| *camel.component.azure-servicebus.peek-num-max-messages* | Set the max
number of messages to be peeked during the peek operation. | | Integer
+| *camel.component.azure-servicebus.prefetch-count* | Sets the prefetch count
of the receiver. For both {link ServiceBusReceiveMode#PEEK_LOCK PEEK_LOCK} and
{link ServiceBusReceiveMode#RECEIVE_AND_DELETE RECEIVE_AND_DELETE} modes the
default value is 1. Prefetch speeds up the message flow by aiming to have a
message readily available for local retrieval when and before the application
asks for one using ServiceBusReceiverAsyncClient#receiveMessages(). Setting a
non-zero value will prefet [...]
+| *camel.component.azure-servicebus.producer-operation* | Sets the desired
operation to be used in the producer | | ServiceBusProducerOperationDefinition
+| *camel.component.azure-servicebus.proxy-options* | Sets the proxy
configuration to use for ServiceBusSenderAsyncClient. When a proxy is
configured, AmqpTransportType#AMQP_WEB_SOCKETS must be used for the transport
type. The option is a com.azure.core.amqp.ProxyOptions type. | | ProxyOptions
+| *camel.component.azure-servicebus.receiver-async-client* | Sets the
receiverAsyncClient in order to consume messages in the Consumer. The option is
a com.azure.messaging.servicebus.ServiceBusReceiverAsyncClient type. | |
ServiceBusReceiverAsyncClient
+| *camel.component.azure-servicebus.scheduled-enqueue-time* | Sets
OffsetDateTime at which the message should appear in the Service Bus queue or
topic. The option is a java.time.OffsetDateTime type. | | OffsetDateTime
+| *camel.component.azure-servicebus.sender-async-client* | Sets
SenderAsyncClient to be used in the producer. The option is a
com.azure.messaging.servicebus.ServiceBusSenderAsyncClient type. | |
ServiceBusSenderAsyncClient
+| *camel.component.azure-servicebus.service-bus-receive-mode* | Sets the
receive mode for the receiver. | | ServiceBusReceiveMode
+| *camel.component.azure-servicebus.service-bus-transaction-context* |
Represents transaction in service. This object just contains transaction id.
The option is a com.azure.messaging.servicebus.ServiceBusTransactionContext
type. | | ServiceBusTransactionContext
+| *camel.component.azure-servicebus.service-bus-type* | The service bus type
of connection to execute. Queue is for typical queue option and topic for
subscription based model. | | ServiceBusType
+| *camel.component.azure-servicebus.sub-queue* | Sets the type of the SubQueue
to connect to. | | SubQueue
+| *camel.component.azure-servicebus.subscription-name* | Sets the name of the
subscription in the topic to listen to. topicOrQueueName and
serviceBusType=topic must also be set. | | String
+|===
+
+
+// spring-boot-auto-configure options: END
diff --git a/docs/modules/ROOT/pages/debezium-mysql-starter.adoc
b/docs/modules/ROOT/pages/debezium-mysql-starter.adoc
index 51a4671..7eab3c3 100644
--- a/docs/modules/ROOT/pages/debezium-mysql-starter.adoc
+++ b/docs/modules/ROOT/pages/debezium-mysql-starter.adoc
@@ -17,7 +17,7 @@ When using debezium-mysql with Spring Boot make sure to use
the following Maven
----
-The component supports 89 options, which are listed below.
+The component supports 93 options, which are listed below.
@@ -46,6 +46,9 @@ The component supports 89 options, which are listed below.
| *camel.component.debezium-mysql.database-history-kafka-recovery-attempts* |
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 receiving no data
is (recovery.attempts) x (recovery.poll.interval.ms). | 100 | Integer
|
*camel.component.debezium-mysql.database-history-kafka-recovery-poll-interval-ms*
| The number of milliseconds to wait while polling for persisted data during
recovery. The option is a int type. | 100 | Integer
| *camel.component.debezium-mysql.database-history-kafka-topic* | The name of
the topic for the database schema history | | String
+| *camel.component.debezium-mysql.database-history-skip-unparseable-ddl* |
Controls the action Debezium will take when it meets a DDL statement in binlog,
that it cannot parse.By default the connector will stop operating but by
changing the setting it can ignore the statements which it cannot parse. If
skipping is enabled then Debezium can miss metadata changes. | false | Boolean
+|
*camel.component.debezium-mysql.database-history-store-only-captured-tables-ddl*
| Controls what DDL will Debezium store in database history. By default
(false) Debezium will store all incoming DDL statements. If set to true, then
only DDL that manipulates a captured table will be stored. | false | Boolean
+|
*camel.component.debezium-mysql.database-history-store-only-monitored-tables-ddl*
| Controls what DDL will Debezium store in database history. By default
(false) Debezium will store all incoming DDL statements. If set to true, then
only DDL that manipulates a monitored table will be stored (deprecated, use
database.history.store.only.captured.tables.ddl instead) | false | Boolean
| *camel.component.debezium-mysql.database-hostname* | Resolvable hostname or
IP address of the database server. | | String
| *camel.component.debezium-mysql.database-include-list* | The databases for
which changes are to be captured | | String
| *camel.component.debezium-mysql.database-initial-statements* | A semicolon
separated list of SQL statements to be executed when a JDBC connection (not
binlog reading connection) to the database is established. Note that the
connector may establish JDBC connections at its own discretion, so this should
typically be used for configuration of session parameters only,but not for
executing DML statements. Use doubled semicolon (';;') to use a semicolon as a
character and not as a delimiter. [...]
@@ -75,6 +78,7 @@ The component supports 89 options, which are listed below.
| *camel.component.debezium-mysql.include-query* | Whether the connector
should include the original SQL query that generated the change event. Note:
This option requires MySQL be configured with the binlog_rows_query_log_events
option set to ON. Query will not be present for events generated from snapshot.
WARNING: Enabling this option may expose tables or fields explicitly
blacklisted or masked by including the original SQL statement in the change
event. For this reason the default val [...]
| *camel.component.debezium-mysql.include-schema-changes* | Whether the
connector should publish changes in the database schema to a Kafka topic with
the same name as the database server ID. Each schema change will be recorded
using a key that contains the database name and whose value include logical
description of the new schema and optionally the DDL statement(s).The default
is 'true'. This is independent of how the connector internally records database
history. | true | Boolean
| *camel.component.debezium-mysql.inconsistent-schema-handling-mode* | Specify
how binlog events that belong to a table missing from internal schema
representation (i.e. internal representation is not consistent with database)
should be handled, including:'fail' (the default) an exception indicating the
problematic event and its binlog position is raised, causing the connector to
be stopped; 'warn' the problematic event and its binlog position will be logged
and the event will be skipped [...]
+| *camel.component.debezium-mysql.incremental-snapshot-chunk-size* | The
maximum size of chunk for incremental snapshotting | 1024 | Integer
| *camel.component.debezium-mysql.internal-key-converter* | The Converter
class that should be used to serialize and deserialize key data for offsets.
The default is JSON converter. | org.apache.kafka.connect.json.JsonConverter |
String
| *camel.component.debezium-mysql.internal-value-converter* | The Converter
class that should be used to serialize and deserialize value data for offsets.
The default is JSON converter. | org.apache.kafka.connect.json.JsonConverter |
String
| *camel.component.debezium-mysql.max-batch-size* | Maximum size of each batch
of source records. Defaults to 2048. | 2048 | Integer
@@ -104,7 +108,7 @@ The component supports 89 options, which are listed below.
| *camel.component.debezium-mysql.snapshot-max-threads* | The maximum number
of threads used to perform the snapshot. Defaults to 1. | 1 | Integer
| *camel.component.debezium-mysql.snapshot-mode* | The criteria for running a
snapshot upon startup of the connector. Options include: 'when_needed' to
specify that the connector run a snapshot upon startup whenever it deems it
necessary; 'schema_only' to only take a snapshot of the schema (table
structures) but no actual data; 'initial' (the default) to specify the
connector can run a snapshot only when no offsets are available for the logical
server name; 'initial_only' same as 'initia [...]
| *camel.component.debezium-mysql.snapshot-new-tables* | BETA FEATURE: On
connector restart, the connector will check if there have been any new tables
added to the configuration, and snapshot them. There is presently only two
options:'off': Default behavior. Do not snapshot new tables.'parallel': The
snapshot of the new tables will occur in parallel to the continued binlog
reading of the old tables. When the snapshot completes, an independent binlog
reader will begin reading the events [...]
-| *camel.component.debezium-mysql.snapshot-select-statement-overrides* | This
property contains a comma-separated list of fully-qualified tables
(DB_NAME.TABLE_NAME) or (SCHEMA_NAME.TABLE_NAME), depending on thespecific
connectors . Select statements for the individual tables are specified in
further configuration properties, one for each table, identified by the id
'snapshot.select.statement.overrides.DB_NAME.TABLE_NAME' or
'snapshot.select.statement.overrides.SCHEMA_NAME.TABLE_NAME', r [...]
+| *camel.component.debezium-mysql.snapshot-select-statement-overrides* | This
property contains a comma-separated list of fully-qualified tables
(DB_NAME.TABLE_NAME) or (SCHEMA_NAME.TABLE_NAME), depending on thespecific
connectors. Select statements for the individual tables are specified in
further configuration properties, one for each table, identified by the id
'snapshot.select.statement.overrides.DB_NAME.TABLE_NAME' or
'snapshot.select.statement.overrides.SCHEMA_NAME.TABLE_NAME', re [...]
| *camel.component.debezium-mysql.source-struct-version* | A version of the
format of the publicly visible source part in the message | v2 | String
| *camel.component.debezium-mysql.table-blacklist* | A comma-separated list of
regular expressions that match the fully-qualified names of tables to be
excluded from monitoring (deprecated, use table.exclude.list instead) | |
String
| *camel.component.debezium-mysql.table-exclude-list* | A comma-separated list
of regular expressions that match the fully-qualified names of tables to be
excluded from monitoring | | String
diff --git a/docs/modules/ROOT/pages/debezium-postgres-starter.adoc
b/docs/modules/ROOT/pages/debezium-postgres-starter.adoc
index 63d4bf1..d457ca3 100644
--- a/docs/modules/ROOT/pages/debezium-postgres-starter.adoc
+++ b/docs/modules/ROOT/pages/debezium-postgres-starter.adoc
@@ -17,7 +17,7 @@ When using debezium-postgres with Spring Boot make sure to
use the following Mav
----
-The component supports 89 options, which are listed below.
+The component supports 90 options, which are listed below.
@@ -59,6 +59,7 @@ The component supports 89 options, which are listed below.
| *camel.component.debezium-postgres.heartbeat-topics-prefix* | The prefix
that is used to name heartbeat topics.Defaults to __debezium-heartbeat. |
__debezium-heartbeat | String
| *camel.component.debezium-postgres.hstore-handling-mode* | Specify how
HSTORE columns should be represented in change events, including:'json'
represents values as string-ified JSON (default)'map' represents values as a
key/value map | json | String
| *camel.component.debezium-postgres.include-unknown-datatypes* | Specify
whether the fields of data type not supported by Debezium should be
processed:'false' (the default) omits the fields; 'true' converts the field
into an implementation dependent binary representation. | false | Boolean
+| *camel.component.debezium-postgres.incremental-snapshot-chunk-size* | The
maximum size of chunk for incremental snapshotting | 1024 | Integer
| *camel.component.debezium-postgres.internal-key-converter* | The Converter
class that should be used to serialize and deserialize key data for offsets.
The default is JSON converter. | org.apache.kafka.connect.json.JsonConverter |
String
| *camel.component.debezium-postgres.internal-value-converter* | The Converter
class that should be used to serialize and deserialize value data for offsets.
The default is JSON converter. | org.apache.kafka.connect.json.JsonConverter |
String
| *camel.component.debezium-postgres.interval-handling-mode* | Specify how
INTERVAL columns should be represented in change events, including:'string'
represents values as an exact ISO formatted string'numeric' (default)
represents values using the inexact conversion into microseconds | numeric |
String
@@ -100,8 +101,8 @@ The component supports 89 options, which are listed below.
| *camel.component.debezium-postgres.snapshot-include-collection-list* | this
setting must be set to specify a list of tables/collections whose snapshot must
be taken on creating or restarting the connector. | | String
| *camel.component.debezium-postgres.snapshot-lock-timeout-ms* | The maximum
number of millis to wait for table locks at the beginning of a snapshot. If
locks cannot be acquired in this time frame, the snapshot will be aborted.
Defaults to 10 seconds. The option is a long type. | 10000 | Long
| *camel.component.debezium-postgres.snapshot-max-threads* | The maximum
number of threads used to perform the snapshot. Defaults to 1. | 1 | Integer
-| *camel.component.debezium-postgres.snapshot-mode* | The criteria for running
a snapshot upon startup of the connector. Options include: 'always' to specify
that the connector run a snapshot each time it starts up; 'initial' (the
default) to specify the connector can run a snapshot only when no offsets are
available for the logical server name; 'initial_only' same as 'initial' except
the connector should stop after completing the snapshot and before it would
normally start emitting chan [...]
-| *camel.component.debezium-postgres.snapshot-select-statement-overrides* |
This property contains a comma-separated list of fully-qualified tables
(DB_NAME.TABLE_NAME) or (SCHEMA_NAME.TABLE_NAME), depending on thespecific
connectors . Select statements for the individual tables are specified in
further configuration properties, one for each table, identified by the id
'snapshot.select.statement.overrides.DB_NAME.TABLE_NAME' or
'snapshot.select.statement.overrides.SCHEMA_NAME.TABLE_NAME' [...]
+| *camel.component.debezium-postgres.snapshot-mode* | The criteria for running
a snapshot upon startup of the connector. Options include: 'always' to specify
that the connector run a snapshot each time it starts up; 'initial' (the
default) to specify the connector can run a snapshot only when no offsets are
available for the logical server name; 'initial_only' same as 'initial' except
the connector should stop after completing the snapshot and before it would
normally start emitting chan [...]
+| *camel.component.debezium-postgres.snapshot-select-statement-overrides* |
This property contains a comma-separated list of fully-qualified tables
(DB_NAME.TABLE_NAME) or (SCHEMA_NAME.TABLE_NAME), depending on thespecific
connectors. Select statements for the individual tables are specified in
further configuration properties, one for each table, identified by the id
'snapshot.select.statement.overrides.DB_NAME.TABLE_NAME' or
'snapshot.select.statement.overrides.SCHEMA_NAME.TABLE_NAME', [...]
| *camel.component.debezium-postgres.source-struct-version* | A version of the
format of the publicly visible source part in the message | v2 | String
| *camel.component.debezium-postgres.status-update-interval-ms* | Frequency
for sending replication connection status updates to the server, given in
milliseconds. Defaults to 10 seconds (10,000 ms). The option is a int type. |
10000 | Integer
| *camel.component.debezium-postgres.table-blacklist* | A comma-separated list
of regular expressions that match the fully-qualified names of tables to be
excluded from monitoring (deprecated, use table.exclude.list instead) | |
String
diff --git a/docs/modules/ROOT/pages/debezium-sqlserver-starter.adoc
b/docs/modules/ROOT/pages/debezium-sqlserver-starter.adoc
index 8df5610..9ea9ee1 100644
--- a/docs/modules/ROOT/pages/debezium-sqlserver-starter.adoc
+++ b/docs/modules/ROOT/pages/debezium-sqlserver-starter.adoc
@@ -17,7 +17,7 @@ When using debezium-sqlserver with Spring Boot make sure to
use the following Ma
----
-The component supports 70 options, which are listed below.
+The component supports 74 options, which are listed below.
@@ -42,6 +42,9 @@ The component supports 70 options, which are listed below.
|
*camel.component.debezium-sqlserver.database-history-kafka-recovery-attempts* |
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 receiving no data
is (recovery.attempts) x (recovery.poll.interval.ms). | 100 | Integer
|
*camel.component.debezium-sqlserver.database-history-kafka-recovery-poll-interval-ms*
| The number of milliseconds to wait while polling for persisted data during
recovery. The option is a int type. | 100 | Integer
| *camel.component.debezium-sqlserver.database-history-kafka-topic* | The name
of the topic for the database schema history | | String
+| *camel.component.debezium-sqlserver.database-history-skip-unparseable-ddl* |
Controls the action Debezium will take when it meets a DDL statement in binlog,
that it cannot parse.By default the connector will stop operating but by
changing the setting it can ignore the statements which it cannot parse. If
skipping is enabled then Debezium can miss metadata changes. | false | Boolean
+|
*camel.component.debezium-sqlserver.database-history-store-only-captured-tables-ddl*
| Controls what DDL will Debezium store in database history. By default
(false) Debezium will store all incoming DDL statements. If set to true, then
only DDL that manipulates a captured table will be stored. | false | Boolean
+|
*camel.component.debezium-sqlserver.database-history-store-only-monitored-tables-ddl*
| Controls what DDL will Debezium store in database history. By default
(false) Debezium will store all incoming DDL statements. If set to true, then
only DDL that manipulates a monitored table will be stored (deprecated, use
database.history.store.only.captured.tables.ddl instead) | false | Boolean
| *camel.component.debezium-sqlserver.database-hostname* | Resolvable hostname
or IP address of the database server. | | String
| *camel.component.debezium-sqlserver.database-instance* | The SQL Server
instance name | | String
| *camel.component.debezium-sqlserver.database-password* | Password of the
database user to be used when connecting to the database. | | String
@@ -59,6 +62,7 @@ The component supports 70 options, which are listed below.
| *camel.component.debezium-sqlserver.internal-key-converter* | The Converter
class that should be used to serialize and deserialize key data for offsets.
The default is JSON converter. | org.apache.kafka.connect.json.JsonConverter |
String
| *camel.component.debezium-sqlserver.internal-value-converter* | The
Converter class that should be used to serialize and deserialize value data for
offsets. The default is JSON converter. |
org.apache.kafka.connect.json.JsonConverter | String
| *camel.component.debezium-sqlserver.max-batch-size* | Maximum size of each
batch of source records. Defaults to 2048. | 2048 | Integer
+| *camel.component.debezium-sqlserver.max-iteration-transactions* | This
property can be used to reduce the connector memory usage footprint when
changes are streamed from multiple tables per database. | 0 | Integer
| *camel.component.debezium-sqlserver.max-queue-size* | Maximum size of the
queue for change events read from the database log but not yet recorded or
forwarded. Defaults to 8192, and should always be larger than the maximum batch
size. | 8192 | Integer
| *camel.component.debezium-sqlserver.max-queue-size-in-bytes* | Maximum size
of the queue in bytes for change events read from the database log but not yet
recorded or forwarded. Defaults to 0. Mean the feature is not enabled | 0 | Long
| *camel.component.debezium-sqlserver.message-key-columns* | A
semicolon-separated list of expressions that match fully-qualified tables and
column(s) to be used as message key. Each expression must match the pattern
':',where the table names could be defined as (DB_NAME.TABLE_NAME) or
(SCHEMA_NAME.TABLE_NAME), depending on the specific connector,and the key
columns are a comma-separated list of columns representing the custom key. For
any table without an explicit key configuration the [...]
@@ -84,9 +88,9 @@ The component supports 70 options, which are listed below.
| *camel.component.debezium-sqlserver.snapshot-lock-timeout-ms* | The maximum
number of millis to wait for table locks at the beginning of a snapshot. If
locks cannot be acquired in this time frame, the snapshot will be aborted.
Defaults to 10 seconds. The option is a long type. | 10000 | Long
| *camel.component.debezium-sqlserver.snapshot-max-threads* | The maximum
number of threads used to perform the snapshot. Defaults to 1. | 1 | Integer
| *camel.component.debezium-sqlserver.snapshot-mode* | The criteria for
running a snapshot upon startup of the connector. Options include: 'initial'
(the default) to specify the connector should run a snapshot only when no
offsets are available for the logical server name; 'schema_only' to specify the
connector should run a snapshot of the schema when no offsets are available for
the logical server name. | initial | String
-| *camel.component.debezium-sqlserver.snapshot-select-statement-overrides* |
This property contains a comma-separated list of fully-qualified tables
(DB_NAME.TABLE_NAME) or (SCHEMA_NAME.TABLE_NAME), depending on thespecific
connectors . Select statements for the individual tables are specified in
further configuration properties, one for each table, identified by the id
'snapshot.select.statement.overrides.DB_NAME.TABLE_NAME' or
'snapshot.select.statement.overrides.SCHEMA_NAME.TABLE_NAME [...]
+| *camel.component.debezium-sqlserver.snapshot-select-statement-overrides* |
This property contains a comma-separated list of fully-qualified tables
(DB_NAME.TABLE_NAME) or (SCHEMA_NAME.TABLE_NAME), depending on thespecific
connectors. Select statements for the individual tables are specified in
further configuration properties, one for each table, identified by the id
'snapshot.select.statement.overrides.DB_NAME.TABLE_NAME' or
'snapshot.select.statement.overrides.SCHEMA_NAME.TABLE_NAME' [...]
| *camel.component.debezium-sqlserver.source-struct-version* | A version of
the format of the publicly visible source part in the message | v2 | String
-| *camel.component.debezium-sqlserver.source-timestamp-mode* | Configures the
criteria of the attached timestamp within the source record (ts_ms).Options
include:'commit', (default) the source timestamp is set to the instant where
the record was committed in the database'processing', the source timestamp is
set to the instant where the record was processed by Debezium. | commit | String
+| *camel.component.debezium-sqlserver.source-timestamp-mode* | Configures the
criteria of the attached timestamp within the source record (ts_ms).Options
include:'commit', (default) the source timestamp is set to the instant where
the record was committed in the database'processing', (deprecated) the source
timestamp is set to the instant where the record was processed by Debezium. |
commit | String
| *camel.component.debezium-sqlserver.table-blacklist* | A comma-separated
list of regular expressions that match the fully-qualified names of tables to
be excluded from monitoring (deprecated, use table.exclude.list instead) | |
String
| *camel.component.debezium-sqlserver.table-exclude-list* | A comma-separated
list of regular expressions that match the fully-qualified names of tables to
be excluded from monitoring | | String
| *camel.component.debezium-sqlserver.table-ignore-builtin* | Flag specifying
whether built-in tables should be ignored. | true | Boolean
diff --git a/docs/modules/ROOT/pages/list.adoc
b/docs/modules/ROOT/pages/list.adoc
index 97e7c49..0409f5c 100644
--- a/docs/modules/ROOT/pages/list.adoc
+++ b/docs/modules/ROOT/pages/list.adoc
@@ -5,7 +5,7 @@ Apache Camel Spring Boot supports the following Camel artifacts
as Spring Boot S
== Camel Components
// components: START
-Number of Camel components: 333 in 269 JAR artifacts (1 deprecated)
+Number of Camel components: 334 in 270 JAR artifacts (1 deprecated)
[width="100%",cols="4,3,3,3,6",options="header"]
|===
@@ -95,6 +95,8 @@ Number of Camel components: 333 in 269 JAR artifacts (1
deprecated)
| xref:latest@components::azure-eventhubs-component.adoc[Azure Event Hubs] |
camel-azure-eventhubs-starter | Stable | 3.5 | The azure-eventhubs component
that integrates Azure Event Hubs using AMQP protocol. Azure EventHubs is a
highly scalable publish-subscribe service that can ingest millions of events
per second and stream them to multiple consumers.
+| xref:latest@components::azure-servicebus-component.adoc[Azure ServiceBus] |
camel-azure-servicebus-starter | Preview | 3.12 | The azure-servicebus
component that integrates Azure ServiceBus. Azure ServiceBus is a fully managed
enterprise integration message broker. Service Bus can decouple applications
and services. Service Bus offers a reliable and secure platform for
asynchronous transfer of data and state. Data is transferred between different
applications and services using messages.
+
| xref:latest@components::azure-storage-blob-component.adoc[Azure Storage Blob
Service] | camel-azure-storage-blob-starter | Stable | 3.3 | Store and retrieve
blobs from Azure Storage Blob Service using SDK v12.
| xref:latest@components::azure-storage-datalake-component.adoc[Azure storage
datalake service] | camel-azure-storage-datalake-starter | Stable | 3.8 | Camel
Azure Datalake Gen2 Component
diff --git a/tooling/camel-spring-boot-bom/pom.xml
b/tooling/camel-spring-boot-bom/pom.xml
index d4a1b39..cb08c86 100644
--- a/tooling/camel-spring-boot-bom/pom.xml
+++ b/tooling/camel-spring-boot-bom/pom.xml
@@ -230,22 +230,22 @@
</dependency>
<dependency>
<groupId>org.apache.camel.springboot</groupId>
- <artifactId>camel-azure-storage-blob-starter</artifactId>
+ <artifactId>camel-azure-servicebus-starter</artifactId>
<version>${project.version}</version>
</dependency>
<dependency>
<groupId>org.apache.camel.springboot</groupId>
- <artifactId>camel-azure-storage-datalake-starter</artifactId>
+ <artifactId>camel-azure-storage-blob-starter</artifactId>
<version>${project.version}</version>
</dependency>
<dependency>
<groupId>org.apache.camel.springboot</groupId>
- <artifactId>camel-azure-storage-queue-starter</artifactId>
+ <artifactId>camel-azure-storage-datalake-starter</artifactId>
<version>${project.version}</version>
</dependency>
<dependency>
<groupId>org.apache.camel.springboot</groupId>
- <artifactId>camel-azure-servicebus-starter</artifactId>
+ <artifactId>camel-azure-storage-queue-starter</artifactId>
<version>${project.version}</version>
</dependency>
<dependency>
diff --git a/tooling/camel-spring-boot-dependencies/pom.xml
b/tooling/camel-spring-boot-dependencies/pom.xml
index ec796ea..4355f75 100644
--- a/tooling/camel-spring-boot-dependencies/pom.xml
+++ b/tooling/camel-spring-boot-dependencies/pom.xml
@@ -633,22 +633,22 @@
</dependency>
<dependency>
<groupId>org.apache.camel.springboot</groupId>
- <artifactId>camel-azure-storage-blob-starter</artifactId>
+ <artifactId>camel-azure-servicebus-starter</artifactId>
<version>${project.version}</version>
</dependency>
<dependency>
<groupId>org.apache.camel.springboot</groupId>
- <artifactId>camel-azure-storage-datalake-starter</artifactId>
+ <artifactId>camel-azure-storage-blob-starter</artifactId>
<version>${project.version}</version>
</dependency>
<dependency>
<groupId>org.apache.camel.springboot</groupId>
- <artifactId>camel-azure-storage-queue-starter</artifactId>
+ <artifactId>camel-azure-storage-datalake-starter</artifactId>
<version>${project.version}</version>
</dependency>
<dependency>
<groupId>org.apache.camel.springboot</groupId>
- <artifactId>camel-azure-servicebus-starter</artifactId>
+ <artifactId>camel-azure-storage-queue-starter</artifactId>
<version>${project.version}</version>
</dependency>
<dependency>
@@ -2449,6 +2449,11 @@
</dependency>
<dependency>
<groupId>org.apache.camel</groupId>
+ <artifactId>camel-azure-servicebus</artifactId>
+ <version>3.12.0-SNAPSHOT</version>
+ </dependency>
+ <dependency>
+ <groupId>org.apache.camel</groupId>
<artifactId>camel-azure-storage-blob</artifactId>
<version>3.12.0-SNAPSHOT</version>
</dependency>
