You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by da...@apache.org on 2022/01/14 17:01:13 UTC
[camel] branch main updated (1dab230 -> a262f81)
This is an automated email from the ASF dual-hosted git repository.
davsclaus pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/camel.git.
from 1dab230 Small documentation improvements (#6753)
new 22913bc Upgrade to same versions for doc generation as camel-website
new a262f81 CAMEL-17490: Upgrade to debezium 1.8
The 2 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../camel/catalog/components/debezium-mongodb.json | 8 +-
.../camel/catalog/components/debezium-mysql.json | 12 +-
.../catalog/components/debezium-postgres.json | 12 +-
.../catalog/components/debezium-sqlserver.json | 16 +-
docs/pom.xml | 6 +-
.../DebeziumMongodbComponentBuilderFactory.java | 41 +++++
.../dsl/DebeziumMysqlComponentBuilderFactory.java | 81 +++++++++
.../DebeziumPostgresComponentBuilderFactory.java | 116 ++++++++++---
.../DebeziumSqlserverComponentBuilderFactory.java | 117 +++++++++++++
.../dsl/DebeziumMongodbEndpointBuilderFactory.java | 38 ++++
.../dsl/DebeziumMySqlEndpointBuilderFactory.java | 123 +++++++++++++
.../DebeziumPostgresEndpointBuilderFactory.java | 132 ++++++++++++--
.../DebeziumSqlserverEndpointBuilderFactory.java | 192 +++++++++++++++++++++
13 files changed, 844 insertions(+), 50 deletions(-)
[camel] 01/02: Upgrade to same versions for doc generation as camel-website
Posted by da...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
davsclaus pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel.git
commit 22913bc844163063c67461a9a7f2428b52297dc4
Author: Claus Ibsen <cl...@gmail.com>
AuthorDate: Fri Jan 14 17:42:05 2022 +0100
Upgrade to same versions for doc generation as camel-website
---
docs/pom.xml | 6 +++---
1 file changed, 3 insertions(+), 3 deletions(-)
diff --git a/docs/pom.xml b/docs/pom.xml
index 1127864..3afa14f 100644
--- a/docs/pom.xml
+++ b/docs/pom.xml
@@ -70,7 +70,7 @@
<plugin>
<groupId>com.github.eirslett</groupId>
<artifactId>frontend-maven-plugin</artifactId>
- <version>1.11.3</version>
+ <version>1.12.1</version>
<executions>
<execution>
<id>install node and yarn</id>
@@ -78,8 +78,8 @@
<goal>install-node-and-yarn</goal>
</goals>
<configuration>
- <nodeVersion>v14.16.0</nodeVersion>
- <yarnVersion>v1.22.5</yarnVersion>
+ <nodeVersion>v16.13.2</nodeVersion>
+ <yarnVersion>v1.22.17</yarnVersion>
</configuration>
</execution>
<execution>
[camel] 02/02: CAMEL-17490: Upgrade to debezium 1.8
Posted by da...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
davsclaus pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel.git
commit a262f813adf359054d18850a26016fd175587d3d
Author: Claus Ibsen <cl...@gmail.com>
AuthorDate: Fri Jan 14 18:00:11 2022 +0100
CAMEL-17490: Upgrade to debezium 1.8
---
.../camel/catalog/components/debezium-mongodb.json | 8 +-
.../camel/catalog/components/debezium-mysql.json | 12 +-
.../catalog/components/debezium-postgres.json | 12 +-
.../catalog/components/debezium-sqlserver.json | 16 +-
.../DebeziumMongodbComponentBuilderFactory.java | 41 +++++
.../dsl/DebeziumMysqlComponentBuilderFactory.java | 81 +++++++++
.../DebeziumPostgresComponentBuilderFactory.java | 116 ++++++++++---
.../DebeziumSqlserverComponentBuilderFactory.java | 117 +++++++++++++
.../dsl/DebeziumMongodbEndpointBuilderFactory.java | 38 ++++
.../dsl/DebeziumMySqlEndpointBuilderFactory.java | 123 +++++++++++++
.../DebeziumPostgresEndpointBuilderFactory.java | 132 ++++++++++++--
.../DebeziumSqlserverEndpointBuilderFactory.java | 192 +++++++++++++++++++++
12 files changed, 841 insertions(+), 47 deletions(-)
diff --git a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/debezium-mongodb.json b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/debezium-mongodb.json
index 47aa6ea..dbe8461 100644
--- a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/debezium-mongodb.json
+++ b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/debezium-mongodb.json
@@ -36,6 +36,7 @@
"offsetStorageReplicationFactor": { "kind": "property", "displayName": "Offset Storage Replication Factor", "group": "consumer", "label": "consumer", "required": false, "type": "integer", "javaType": "int", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.MongoDbConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Replication factor used when creating the offse [...]
"offsetStorageTopic": { "kind": "property", "displayName": "Offset Storage Topic", "group": "consumer", "label": "consumer", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.MongoDbConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The name of the Kafka topic where offsets are to be stored. [...]
"autowiredEnabled": { "kind": "property", "displayName": "Autowired Enabled", "group": "advanced", "label": "advanced", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": true, "description": "Whether autowiring is enabled. This is used for automatic autowiring options (the option must be marked as autowired) by looking up in the registry to find if there is a single instance of matching type, which t [...]
+ "captureMode": { "kind": "property", "displayName": "Capture Mode", "group": "mongodb", "label": "consumer,mongodb", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "change_streams_update_full", "configurationClass": "org.apache.camel.component.debezium.configuration.MongoDbConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The method used to cap [...]
"collectionExcludeList": { "kind": "property", "displayName": "Collection Exclude List", "group": "mongodb", "label": "consumer,mongodb", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.MongoDbConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "A comma-separated list of regular expressions t [...]
"collectionIncludeList": { "kind": "property", "displayName": "Collection Include List", "group": "mongodb", "label": "consumer,mongodb", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.MongoDbConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "A comma-separated list of regular expressions t [...]
"connectBackoffInitialDelayMs": { "kind": "property", "displayName": "Connect Backoff Initial Delay Ms", "group": "mongodb", "label": "consumer,mongodb", "required": false, "type": "duration", "javaType": "long", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "1s", "configurationClass": "org.apache.camel.component.debezium.configuration.MongoDbConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The initial delay w [...]
@@ -80,7 +81,8 @@
"snapshotMaxThreads": { "kind": "property", "displayName": "Snapshot Max Threads", "group": "mongodb", "label": "consumer,mongodb", "required": false, "type": "integer", "javaType": "int", "deprecated": false, "autowired": false, "secret": false, "defaultValue": 1, "configurationClass": "org.apache.camel.component.debezium.configuration.MongoDbConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The maximum number of threads used to perform [...]
"snapshotMode": { "kind": "property", "displayName": "Snapshot Mode", "group": "mongodb", "label": "consumer,mongodb", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "initial", "configurationClass": "org.apache.camel.component.debezium.configuration.MongoDbConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The criteria for running a snapshot upo [...]
"sourceStructVersion": { "kind": "property", "displayName": "Source Struct Version", "group": "mongodb", "label": "consumer,mongodb", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "v2", "configurationClass": "org.apache.camel.component.debezium.configuration.MongoDbConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "A version of the format of th [...]
- "tombstonesOnDelete": { "kind": "property", "displayName": "Tombstones On Delete", "group": "mongodb", "label": "consumer,mongodb", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": false, "configurationClass": "org.apache.camel.component.debezium.configuration.MongoDbConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Whether delete operations should be re [...]
+ "tombstonesOnDelete": { "kind": "property", "displayName": "Tombstones On Delete", "group": "mongodb", "label": "consumer,mongodb", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": false, "configurationClass": "org.apache.camel.component.debezium.configuration.MongoDbConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Whether delete operations should be re [...]
+ "transactionTopic": { "kind": "property", "displayName": "Transaction Topic", "group": "mongodb", "label": "consumer,mongodb", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "${database.server.name}.transaction", "configurationClass": "org.apache.camel.component.debezium.configuration.MongoDbConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The [...]
},
"properties": {
"name": { "kind": "path", "displayName": "Name", "group": "consumer", "label": "consumer", "required": true, "type": "string", "javaType": "java.lang.String", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.MongoDbConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Unique name for the connector. Attempting to register again with the sam [...]
@@ -98,6 +100,7 @@
"offsetStorageTopic": { "kind": "parameter", "displayName": "Offset Storage Topic", "group": "consumer", "label": "consumer", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.MongoDbConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The name of the Kafka topic where offsets are to be stored. [...]
"exceptionHandler": { "kind": "parameter", "displayName": "Exception Handler", "group": "consumer (advanced)", "label": "consumer,advanced", "required": false, "type": "object", "javaType": "org.apache.camel.spi.ExceptionHandler", "optionalPrefix": "consumer.", "deprecated": false, "autowired": false, "secret": false, "description": "To let the consumer use a custom ExceptionHandler. Notice if the option bridgeErrorHandler is enabled then this option is not in use. By default the con [...]
"exchangePattern": { "kind": "parameter", "displayName": "Exchange Pattern", "group": "consumer (advanced)", "label": "consumer,advanced", "required": false, "type": "object", "javaType": "org.apache.camel.ExchangePattern", "enum": [ "InOnly", "InOut", "InOptionalOut" ], "deprecated": false, "autowired": false, "secret": false, "description": "Sets the exchange pattern when the consumer creates an exchange." },
+ "captureMode": { "kind": "parameter", "displayName": "Capture Mode", "group": "mongodb", "label": "consumer,mongodb", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "change_streams_update_full", "configurationClass": "org.apache.camel.component.debezium.configuration.MongoDbConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The method used to ca [...]
"collectionExcludeList": { "kind": "parameter", "displayName": "Collection Exclude List", "group": "mongodb", "label": "consumer,mongodb", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.MongoDbConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "A comma-separated list of regular expressions [...]
"collectionIncludeList": { "kind": "parameter", "displayName": "Collection Include List", "group": "mongodb", "label": "consumer,mongodb", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.MongoDbConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "A comma-separated list of regular expressions [...]
"connectBackoffInitialDelayMs": { "kind": "parameter", "displayName": "Connect Backoff Initial Delay Ms", "group": "mongodb", "label": "consumer,mongodb", "required": false, "type": "duration", "javaType": "long", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "1s", "configurationClass": "org.apache.camel.component.debezium.configuration.MongoDbConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The initial delay [...]
@@ -142,6 +145,7 @@
"snapshotMaxThreads": { "kind": "parameter", "displayName": "Snapshot Max Threads", "group": "mongodb", "label": "consumer,mongodb", "required": false, "type": "integer", "javaType": "int", "deprecated": false, "autowired": false, "secret": false, "defaultValue": 1, "configurationClass": "org.apache.camel.component.debezium.configuration.MongoDbConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The maximum number of threads used to perform [...]
"snapshotMode": { "kind": "parameter", "displayName": "Snapshot Mode", "group": "mongodb", "label": "consumer,mongodb", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "initial", "configurationClass": "org.apache.camel.component.debezium.configuration.MongoDbConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The criteria for running a snapshot up [...]
"sourceStructVersion": { "kind": "parameter", "displayName": "Source Struct Version", "group": "mongodb", "label": "consumer,mongodb", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "v2", "configurationClass": "org.apache.camel.component.debezium.configuration.MongoDbConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "A version of the format of t [...]
- "tombstonesOnDelete": { "kind": "parameter", "displayName": "Tombstones On Delete", "group": "mongodb", "label": "consumer,mongodb", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": false, "configurationClass": "org.apache.camel.component.debezium.configuration.MongoDbConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Whether delete operations should be r [...]
+ "tombstonesOnDelete": { "kind": "parameter", "displayName": "Tombstones On Delete", "group": "mongodb", "label": "consumer,mongodb", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": false, "configurationClass": "org.apache.camel.component.debezium.configuration.MongoDbConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Whether delete operations should be r [...]
+ "transactionTopic": { "kind": "parameter", "displayName": "Transaction Topic", "group": "mongodb", "label": "consumer,mongodb", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "${database.server.name}.transaction", "configurationClass": "org.apache.camel.component.debezium.configuration.MongoDbConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Th [...]
}
}
diff --git a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/debezium-mysql.json b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/debezium-mysql.json
index 7244328..dad0a93 100644
--- a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/debezium-mysql.json
+++ b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/debezium-mysql.json
@@ -81,11 +81,14 @@
"gtidSourceExcludes": { "kind": "property", "displayName": "Gtid Source Excludes", "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 source UUIDs used to exclude GTID ranges when determine [...]
"gtidSourceFilterDmlEvents": { "kind": "property", "displayName": "Gtid Source Filter Dml Events", "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": "If set to true, we will only [...]
"gtidSourceIncludes": { "kind": "property", "displayName": "Gtid Source Includes", "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 source UUIDs used to include GTID ranges when determine [...]
+ "heartbeatActionQuery": { "kind": "property", "displayName": "Heartbeat Action Query", "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 query executed with every heartbeat." },
"heartbeatIntervalMs": { "kind": "property", "displayName": "Heartbeat Interval Ms", "group": "mysql", "label": "consumer,mysql", "required": false, "type": "duration", "javaType": "int", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "0ms", "configurationClass": "org.apache.camel.component.debezium.configuration.MySqlConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Length of an interval in milli-seconds in in [...]
"heartbeatTopicsPrefix": { "kind": "property", "displayName": "Heartbeat Topics Prefix", "group": "mysql", "label": "consumer,mysql", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "__debezium-heartbeat", "configurationClass": "org.apache.camel.component.debezium.configuration.MySqlConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The prefix th [...]
"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 [...]
+ "includeSchemaComments": { "kind": "property", "displayName": "Include Schema Comments", "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 parse table and [...]
"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 [...]
+ "incrementalSnapshotAllowSchemaChanges": { "kind": "property", "displayName": "Incremental Snapshot Allow Schema Changes", "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": "Dete [...]
"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 [...]
@@ -115,7 +118,8 @@
"tableIncludeList": { "kind": "property", "displayName": "Table 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 tables for which changes are to be captured" },
"tableWhitelist": { "kind": "property", "displayName": "Table Whitelist", "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 tables for which changes are to be captured (deprecated, use tab [...]
"timePrecisionMode": { "kind": "property", "displayName": "Time Precision Mode", "group": "mysql", "label": "consumer,mysql", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "adaptive_time_microseconds", "configurationClass": "org.apache.camel.component.debezium.configuration.MySqlConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Time, date and [...]
- "tombstonesOnDelete": { "kind": "property", "displayName": "Tombstones On Delete", "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 delete operations should be represen [...]
+ "tombstonesOnDelete": { "kind": "property", "displayName": "Tombstones On Delete", "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 delete operations should be represen [...]
+ "transactionTopic": { "kind": "property", "displayName": "Transaction Topic", "group": "mysql", "label": "consumer,mysql", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "${database.server.name}.transaction", "configurationClass": "org.apache.camel.component.debezium.configuration.MySqlConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The name [...]
},
"properties": {
"name": { "kind": "path", "displayName": "Name", "group": "consumer", "label": "consumer", "required": true, "type": "string", "javaType": "java.lang.String", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.MySqlConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Unique name for the connector. Attempting to register again with the same [...]
@@ -178,11 +182,14 @@
"gtidSourceExcludes": { "kind": "parameter", "displayName": "Gtid Source Excludes", "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 source UUIDs used to exclude GTID ranges when determin [...]
"gtidSourceFilterDmlEvents": { "kind": "parameter", "displayName": "Gtid Source Filter Dml Events", "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": "If set to true, we will only [...]
"gtidSourceIncludes": { "kind": "parameter", "displayName": "Gtid Source Includes", "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 source UUIDs used to include GTID ranges when determin [...]
+ "heartbeatActionQuery": { "kind": "parameter", "displayName": "Heartbeat Action Query", "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 query executed with every heartbeat." },
"heartbeatIntervalMs": { "kind": "parameter", "displayName": "Heartbeat Interval Ms", "group": "mysql", "label": "consumer,mysql", "required": false, "type": "duration", "javaType": "int", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "0ms", "configurationClass": "org.apache.camel.component.debezium.configuration.MySqlConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Length of an interval in milli-seconds in in [...]
"heartbeatTopicsPrefix": { "kind": "parameter", "displayName": "Heartbeat Topics Prefix", "group": "mysql", "label": "consumer,mysql", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "__debezium-heartbeat", "configurationClass": "org.apache.camel.component.debezium.configuration.MySqlConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The prefix t [...]
"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 [...]
+ "includeSchemaComments": { "kind": "parameter", "displayName": "Include Schema Comments", "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 parse table and [...]
"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 [...]
+ "incrementalSnapshotAllowSchemaChanges": { "kind": "parameter", "displayName": "Incremental Snapshot Allow Schema Changes", "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": "Det [...]
"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 [...]
@@ -212,6 +219,7 @@
"tableIncludeList": { "kind": "parameter", "displayName": "Table 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 tables for which changes are to be captured" },
"tableWhitelist": { "kind": "parameter", "displayName": "Table Whitelist", "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 tables for which changes are to be captured (deprecated, use ta [...]
"timePrecisionMode": { "kind": "parameter", "displayName": "Time Precision Mode", "group": "mysql", "label": "consumer,mysql", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "adaptive_time_microseconds", "configurationClass": "org.apache.camel.component.debezium.configuration.MySqlConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Time, date and [...]
- "tombstonesOnDelete": { "kind": "parameter", "displayName": "Tombstones On Delete", "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 delete operations should be represe [...]
+ "tombstonesOnDelete": { "kind": "parameter", "displayName": "Tombstones On Delete", "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 delete operations should be represe [...]
+ "transactionTopic": { "kind": "parameter", "displayName": "Transaction Topic", "group": "mysql", "label": "consumer,mysql", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "${database.server.name}.transaction", "configurationClass": "org.apache.camel.component.debezium.configuration.MySqlConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The name [...]
}
}
diff --git a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/debezium-postgres.json b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/debezium-postgres.json
index 0ae0939..8e4a5c8 100644
--- a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/debezium-postgres.json
+++ b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/debezium-postgres.json
@@ -65,6 +65,7 @@
"heartbeatIntervalMs": { "kind": "property", "displayName": "Heartbeat Interval Ms", "group": "postgres", "label": "consumer,postgres", "required": false, "type": "duration", "javaType": "int", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "0ms", "configurationClass": "org.apache.camel.component.debezium.configuration.PostgresConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Length of an interval in milli-secon [...]
"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 [...]
+ "includeSchemaComments": { "kind": "property", "displayName": "Include Schema Comments", "group": "postgres", "label": "consumer,postgres", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": false, "configurationClass": "org.apache.camel.component.debezium.configuration.PostgresConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Whether the connector parse t [...]
"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 [...]
@@ -72,6 +73,8 @@
"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 [...]
"maxQueueSizeInBytes": { "kind": "property", "displayName": "Max Queue Size In Bytes", "group": "postgres", "label": "consumer,postgres", "required": false, "type": "integer", "javaType": "long", "deprecated": false, "autowired": false, "secret": false, "defaultValue": 0, "configurationClass": "org.apache.camel.component.debezium.configuration.PostgresConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Maximum size of the queue in bytes for [...]
"messageKeyColumns": { "kind": "property", "displayName": "Message Key Columns", "group": "postgres", "label": "consumer,postgres", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.PostgresConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "A semicolon-separated list of expressions that match [...]
+ "messagePrefixExcludeList": { "kind": "property", "displayName": "Message Prefix Exclude List", "group": "postgres", "label": "consumer,postgres", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.PostgresConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "A comma-separated list of regular exp [...]
+ "messagePrefixIncludeList": { "kind": "property", "displayName": "Message Prefix Include List", "group": "postgres", "label": "consumer,postgres", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.PostgresConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "A comma-separated list of regular exp [...]
"pluginName": { "kind": "property", "displayName": "Plugin Name", "group": "postgres", "label": "consumer,postgres", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "decoderbufs", "configurationClass": "org.apache.camel.component.debezium.configuration.PostgresConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The name of the Postgres logical dec [...]
"pollIntervalMs": { "kind": "property", "displayName": "Poll Interval Ms", "group": "postgres", "label": "consumer,postgres", "required": false, "type": "duration", "javaType": "long", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "500ms", "configurationClass": "org.apache.camel.component.debezium.configuration.PostgresConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Time to wait for new change events to appea [...]
"provideTransactionMetadata": { "kind": "property", "displayName": "Provide Transaction Metadata", "group": "postgres", "label": "consumer,postgres", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": false, "configurationClass": "org.apache.camel.component.debezium.configuration.PostgresConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Enables transaction [...]
@@ -108,9 +111,10 @@
"tableIncludeList": { "kind": "property", "displayName": "Table Include List", "group": "postgres", "label": "consumer,postgres", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.PostgresConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The tables for which changes are to be captured" },
"tableWhitelist": { "kind": "property", "displayName": "Table Whitelist", "group": "postgres", "label": "consumer,postgres", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.PostgresConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The tables for which changes are to be captured (deprecated [...]
"timePrecisionMode": { "kind": "property", "displayName": "Time Precision Mode", "group": "postgres", "label": "consumer,postgres", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "adaptive", "configurationClass": "org.apache.camel.component.debezium.configuration.PostgresConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Time, date, and timestam [...]
- "toastedValuePlaceholder": { "kind": "property", "displayName": "Toasted Value Placeholder", "group": "postgres", "label": "consumer,postgres", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "__debezium_unavailable_value", "configurationClass": "org.apache.camel.component.debezium.configuration.PostgresConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "descrip [...]
"tombstonesOnDelete": { "kind": "property", "displayName": "Tombstones On Delete", "group": "postgres", "label": "consumer,postgres", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": false, "configurationClass": "org.apache.camel.component.debezium.configuration.PostgresConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Whether delete operations should be [...]
+ "transactionTopic": { "kind": "property", "displayName": "Transaction Topic", "group": "postgres", "label": "consumer,postgres", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "${database.server.name}.transaction", "configurationClass": "org.apache.camel.component.debezium.configuration.PostgresConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": " [...]
"truncateHandlingMode": { "kind": "property", "displayName": "Truncate Handling Mode", "group": "postgres", "label": "consumer,postgres", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "skip", "configurationClass": "org.apache.camel.component.debezium.configuration.PostgresConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Specify how TRUNCATE o [...]
+ "unavailableValuePlaceholder": { "kind": "property", "displayName": "Unavailable Value Placeholder", "group": "postgres", "label": "consumer,postgres", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "__debezium_unavailable_value", "configurationClass": "org.apache.camel.component.debezium.configuration.PostgresConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", [...]
"xminFetchIntervalMs": { "kind": "property", "displayName": "Xmin Fetch Interval Ms", "group": "postgres", "label": "consumer,postgres", "required": false, "type": "duration", "javaType": "long", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "0ms", "configurationClass": "org.apache.camel.component.debezium.configuration.PostgresConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Specify how often (in ms) the xmin [...]
},
"properties": {
@@ -158,6 +162,7 @@
"heartbeatIntervalMs": { "kind": "parameter", "displayName": "Heartbeat Interval Ms", "group": "postgres", "label": "consumer,postgres", "required": false, "type": "duration", "javaType": "int", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "0ms", "configurationClass": "org.apache.camel.component.debezium.configuration.PostgresConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Length of an interval in milli-seco [...]
"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 [...]
+ "includeSchemaComments": { "kind": "parameter", "displayName": "Include Schema Comments", "group": "postgres", "label": "consumer,postgres", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": false, "configurationClass": "org.apache.camel.component.debezium.configuration.PostgresConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Whether the connector parse [...]
"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 [...]
@@ -165,6 +170,8 @@
"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 [...]
"maxQueueSizeInBytes": { "kind": "parameter", "displayName": "Max Queue Size In Bytes", "group": "postgres", "label": "consumer,postgres", "required": false, "type": "integer", "javaType": "long", "deprecated": false, "autowired": false, "secret": false, "defaultValue": 0, "configurationClass": "org.apache.camel.component.debezium.configuration.PostgresConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Maximum size of the queue in bytes fo [...]
"messageKeyColumns": { "kind": "parameter", "displayName": "Message Key Columns", "group": "postgres", "label": "consumer,postgres", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.PostgresConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "A semicolon-separated list of expressions that matc [...]
+ "messagePrefixExcludeList": { "kind": "parameter", "displayName": "Message Prefix Exclude List", "group": "postgres", "label": "consumer,postgres", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.PostgresConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "A comma-separated list of regular ex [...]
+ "messagePrefixIncludeList": { "kind": "parameter", "displayName": "Message Prefix Include List", "group": "postgres", "label": "consumer,postgres", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.PostgresConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "A comma-separated list of regular ex [...]
"pluginName": { "kind": "parameter", "displayName": "Plugin Name", "group": "postgres", "label": "consumer,postgres", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "decoderbufs", "configurationClass": "org.apache.camel.component.debezium.configuration.PostgresConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The name of the Postgres logical de [...]
"pollIntervalMs": { "kind": "parameter", "displayName": "Poll Interval Ms", "group": "postgres", "label": "consumer,postgres", "required": false, "type": "duration", "javaType": "long", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "500ms", "configurationClass": "org.apache.camel.component.debezium.configuration.PostgresConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Time to wait for new change events to appe [...]
"provideTransactionMetadata": { "kind": "parameter", "displayName": "Provide Transaction Metadata", "group": "postgres", "label": "consumer,postgres", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": false, "configurationClass": "org.apache.camel.component.debezium.configuration.PostgresConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Enables transactio [...]
@@ -201,9 +208,10 @@
"tableIncludeList": { "kind": "parameter", "displayName": "Table Include List", "group": "postgres", "label": "consumer,postgres", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.PostgresConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The tables for which changes are to be captured" },
"tableWhitelist": { "kind": "parameter", "displayName": "Table Whitelist", "group": "postgres", "label": "consumer,postgres", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.PostgresConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The tables for which changes are to be captured (deprecate [...]
"timePrecisionMode": { "kind": "parameter", "displayName": "Time Precision Mode", "group": "postgres", "label": "consumer,postgres", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "adaptive", "configurationClass": "org.apache.camel.component.debezium.configuration.PostgresConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Time, date, and timesta [...]
- "toastedValuePlaceholder": { "kind": "parameter", "displayName": "Toasted Value Placeholder", "group": "postgres", "label": "consumer,postgres", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "__debezium_unavailable_value", "configurationClass": "org.apache.camel.component.debezium.configuration.PostgresConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "descri [...]
"tombstonesOnDelete": { "kind": "parameter", "displayName": "Tombstones On Delete", "group": "postgres", "label": "consumer,postgres", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": false, "configurationClass": "org.apache.camel.component.debezium.configuration.PostgresConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Whether delete operations should b [...]
+ "transactionTopic": { "kind": "parameter", "displayName": "Transaction Topic", "group": "postgres", "label": "consumer,postgres", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "${database.server.name}.transaction", "configurationClass": "org.apache.camel.component.debezium.configuration.PostgresConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": [...]
"truncateHandlingMode": { "kind": "parameter", "displayName": "Truncate Handling Mode", "group": "postgres", "label": "consumer,postgres", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "skip", "configurationClass": "org.apache.camel.component.debezium.configuration.PostgresConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Specify how TRUNCATE [...]
+ "unavailableValuePlaceholder": { "kind": "parameter", "displayName": "Unavailable Value Placeholder", "group": "postgres", "label": "consumer,postgres", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "__debezium_unavailable_value", "configurationClass": "org.apache.camel.component.debezium.configuration.PostgresConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", [...]
"xminFetchIntervalMs": { "kind": "parameter", "displayName": "Xmin Fetch Interval Ms", "group": "postgres", "label": "consumer,postgres", "required": false, "type": "duration", "javaType": "long", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "0ms", "configurationClass": "org.apache.camel.component.debezium.configuration.PostgresConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Specify how often (in ms) the xmi [...]
}
}
diff --git a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/debezium-sqlserver.json b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/debezium-sqlserver.json
index 52a47d2..b41d07b 100644
--- a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/debezium-sqlserver.json
+++ b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/debezium-sqlserver.json
@@ -63,9 +63,14 @@
"datatypePropagateSourceType": { "kind": "property", "displayName": "Datatype Propagate Source Type", "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 re [...]
"decimalHandlingMode": { "kind": "property", "displayName": "Decimal Handling Mode", "group": "sqlserver", "label": "consumer,sqlserver", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "precise", "configurationClass": "org.apache.camel.component.debezium.configuration.SqlServerConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Specify how DECIMA [...]
"eventProcessingFailureHandlingMode": { "kind": "property", "displayName": "Event Processing Failure Handling Mode", "group": "sqlserver", "label": "consumer,sqlserver", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "fail", "configurationClass": "org.apache.camel.component.debezium.configuration.SqlServerConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "desc [...]
+ "heartbeatActionQuery": { "kind": "property", "displayName": "Heartbeat Action Query", "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 query executed with every heartbeat." },
"heartbeatIntervalMs": { "kind": "property", "displayName": "Heartbeat Interval Ms", "group": "sqlserver", "label": "consumer,sqlserver", "required": false, "type": "duration", "javaType": "int", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "0ms", "configurationClass": "org.apache.camel.component.debezium.configuration.SqlServerConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Length of an interval in milli-se [...]
"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 [...]
+ "includeSchemaComments": { "kind": "property", "displayName": "Include Schema Comments", "group": "sqlserver", "label": "consumer,sqlserver", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": false, "configurationClass": "org.apache.camel.component.debezium.configuration.SqlServerConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Whether the connector pars [...]
+ "incrementalSnapshotAllowSchemaChanges": { "kind": "property", "displayName": "Incremental Snapshot Allow Schema Changes", "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", "descrip [...]
+ "incrementalSnapshotChunkSize": { "kind": "property", "displayName": "Incremental Snapshot Chunk Size", "group": "sqlserver", "label": "consumer,sqlserver", "required": false, "type": "integer", "javaType": "int", "deprecated": false, "autowired": false, "secret": false, "defaultValue": 1024, "configurationClass": "org.apache.camel.component.debezium.configuration.SqlServerConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The maximum size [...]
+ "incrementalSnapshotOptionRecompile": { "kind": "property", "displayName": "Incremental Snapshot Option Recompile", "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": [...]
"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 [...]
@@ -94,7 +99,8 @@
"tableIncludeList": { "kind": "property", "displayName": "Table Include 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": "The tables for which changes are to be captured" },
"tableWhitelist": { "kind": "property", "displayName": "Table Whitelist", "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 tables for which changes are to be captured (depreca [...]
"timePrecisionMode": { "kind": "property", "displayName": "Time Precision Mode", "group": "sqlserver", "label": "consumer,sqlserver", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "adaptive", "configurationClass": "org.apache.camel.component.debezium.configuration.SqlServerConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Time, date, and times [...]
- "tombstonesOnDelete": { "kind": "property", "displayName": "Tombstones On Delete", "group": "sqlserver", "label": "consumer,sqlserver", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": false, "configurationClass": "org.apache.camel.component.debezium.configuration.SqlServerConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Whether delete operations should [...]
+ "tombstonesOnDelete": { "kind": "property", "displayName": "Tombstones On Delete", "group": "sqlserver", "label": "consumer,sqlserver", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": false, "configurationClass": "org.apache.camel.component.debezium.configuration.SqlServerConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Whether delete operations should [...]
+ "transactionTopic": { "kind": "property", "displayName": "Transaction Topic", "group": "sqlserver", "label": "consumer,sqlserver", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "${database.server.name}.transaction", "configurationClass": "org.apache.camel.component.debezium.configuration.SqlServerConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description" [...]
},
"properties": {
"name": { "kind": "path", "displayName": "Name", "group": "consumer", "label": "consumer", "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": "Unique name for the connector. Attempting to register again with the s [...]
@@ -139,9 +145,14 @@
"datatypePropagateSourceType": { "kind": "parameter", "displayName": "Datatype Propagate Source Type", "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 r [...]
"decimalHandlingMode": { "kind": "parameter", "displayName": "Decimal Handling Mode", "group": "sqlserver", "label": "consumer,sqlserver", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "precise", "configurationClass": "org.apache.camel.component.debezium.configuration.SqlServerConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Specify how DECIM [...]
"eventProcessingFailureHandlingMode": { "kind": "parameter", "displayName": "Event Processing Failure Handling Mode", "group": "sqlserver", "label": "consumer,sqlserver", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "fail", "configurationClass": "org.apache.camel.component.debezium.configuration.SqlServerConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "des [...]
+ "heartbeatActionQuery": { "kind": "parameter", "displayName": "Heartbeat Action Query", "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 query executed with every heartbeat." },
"heartbeatIntervalMs": { "kind": "parameter", "displayName": "Heartbeat Interval Ms", "group": "sqlserver", "label": "consumer,sqlserver", "required": false, "type": "duration", "javaType": "int", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "0ms", "configurationClass": "org.apache.camel.component.debezium.configuration.SqlServerConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Length of an interval in milli-s [...]
"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 [...]
+ "includeSchemaComments": { "kind": "parameter", "displayName": "Include Schema Comments", "group": "sqlserver", "label": "consumer,sqlserver", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": false, "configurationClass": "org.apache.camel.component.debezium.configuration.SqlServerConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Whether the connector par [...]
+ "incrementalSnapshotAllowSchemaChanges": { "kind": "parameter", "displayName": "Incremental Snapshot Allow Schema Changes", "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", "descri [...]
+ "incrementalSnapshotChunkSize": { "kind": "parameter", "displayName": "Incremental Snapshot Chunk Size", "group": "sqlserver", "label": "consumer,sqlserver", "required": false, "type": "integer", "javaType": "int", "deprecated": false, "autowired": false, "secret": false, "defaultValue": 1024, "configurationClass": "org.apache.camel.component.debezium.configuration.SqlServerConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The maximum siz [...]
+ "incrementalSnapshotOptionRecompile": { "kind": "parameter", "displayName": "Incremental Snapshot Option Recompile", "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": [...]
"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 [...]
@@ -170,6 +181,7 @@
"tableIncludeList": { "kind": "parameter", "displayName": "Table Include 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": "The tables for which changes are to be captured" },
"tableWhitelist": { "kind": "parameter", "displayName": "Table Whitelist", "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 tables for which changes are to be captured (deprec [...]
"timePrecisionMode": { "kind": "parameter", "displayName": "Time Precision Mode", "group": "sqlserver", "label": "consumer,sqlserver", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "adaptive", "configurationClass": "org.apache.camel.component.debezium.configuration.SqlServerConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Time, date, and time [...]
- "tombstonesOnDelete": { "kind": "parameter", "displayName": "Tombstones On Delete", "group": "sqlserver", "label": "consumer,sqlserver", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": false, "configurationClass": "org.apache.camel.component.debezium.configuration.SqlServerConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Whether delete operations shoul [...]
+ "tombstonesOnDelete": { "kind": "parameter", "displayName": "Tombstones On Delete", "group": "sqlserver", "label": "consumer,sqlserver", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": false, "configurationClass": "org.apache.camel.component.debezium.configuration.SqlServerConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Whether delete operations shoul [...]
+ "transactionTopic": { "kind": "parameter", "displayName": "Transaction Topic", "group": "sqlserver", "label": "consumer,sqlserver", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "${database.server.name}.transaction", "configurationClass": "org.apache.camel.component.debezium.configuration.SqlServerConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description [...]
}
}
diff --git a/dsl/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/DebeziumMongodbComponentBuilderFactory.java b/dsl/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/DebeziumMongodbComponentBuilderFactory.java
index ced59ad..75a8ec8 100644
--- a/dsl/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/DebeziumMongodbComponentBuilderFactory.java
+++ b/dsl/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/DebeziumMongodbComponentBuilderFactory.java
@@ -302,6 +302,27 @@ public interface DebeziumMongodbComponentBuilderFactory {
return this;
}
/**
+ * The method used to capture changes from MongoDB server. Options
+ * include: 'oplog' to capture changes from the oplog; 'change_streams'
+ * to capture changes via MongoDB Change Streams, update events do not
+ * contain full documents; 'change_streams_update_full' (the default) to
+ * capture changes via MongoDB Change Streams, update events contain
+ * full documents.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Default: change_streams_update_full
+ * Group: mongodb
+ *
+ * @param captureMode the value to set
+ * @return the dsl builder
+ */
+ default DebeziumMongodbComponentBuilder captureMode(
+ java.lang.String captureMode) {
+ doSetProperty("captureMode", captureMode);
+ return this;
+ }
+ /**
* A comma-separated list of regular expressions that match the
* collection names for which changes are to be excluded.
*
@@ -1065,6 +1086,24 @@ public interface DebeziumMongodbComponentBuilderFactory {
doSetProperty("tombstonesOnDelete", tombstonesOnDelete);
return this;
}
+ /**
+ * The name of the transaction metadata topic. The placeholder
+ * ${database.server.name} can be used for referring to the connector's
+ * logical name; defaults to ${database.server.name}.transaction.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Default: ${database.server.name}.transaction
+ * Group: mongodb
+ *
+ * @param transactionTopic the value to set
+ * @return the dsl builder
+ */
+ default DebeziumMongodbComponentBuilder transactionTopic(
+ java.lang.String transactionTopic) {
+ doSetProperty("transactionTopic", transactionTopic);
+ return this;
+ }
}
class DebeziumMongodbComponentBuilderImpl
@@ -1103,6 +1142,7 @@ public interface DebeziumMongodbComponentBuilderFactory {
case "offsetStorageReplicationFactor": getOrCreateConfiguration((DebeziumMongodbComponent) component).setOffsetStorageReplicationFactor((int) value); return true;
case "offsetStorageTopic": getOrCreateConfiguration((DebeziumMongodbComponent) component).setOffsetStorageTopic((java.lang.String) value); return true;
case "autowiredEnabled": ((DebeziumMongodbComponent) component).setAutowiredEnabled((boolean) value); return true;
+ case "captureMode": getOrCreateConfiguration((DebeziumMongodbComponent) component).setCaptureMode((java.lang.String) value); return true;
case "collectionExcludeList": getOrCreateConfiguration((DebeziumMongodbComponent) component).setCollectionExcludeList((java.lang.String) value); return true;
case "collectionIncludeList": getOrCreateConfiguration((DebeziumMongodbComponent) component).setCollectionIncludeList((java.lang.String) value); return true;
case "connectBackoffInitialDelayMs": getOrCreateConfiguration((DebeziumMongodbComponent) component).setConnectBackoffInitialDelayMs((long) value); return true;
@@ -1148,6 +1188,7 @@ public interface DebeziumMongodbComponentBuilderFactory {
case "snapshotMode": getOrCreateConfiguration((DebeziumMongodbComponent) component).setSnapshotMode((java.lang.String) value); return true;
case "sourceStructVersion": getOrCreateConfiguration((DebeziumMongodbComponent) component).setSourceStructVersion((java.lang.String) value); return true;
case "tombstonesOnDelete": getOrCreateConfiguration((DebeziumMongodbComponent) component).setTombstonesOnDelete((boolean) value); return true;
+ case "transactionTopic": getOrCreateConfiguration((DebeziumMongodbComponent) component).setTransactionTopic((java.lang.String) value); return true;
default: return false;
}
}
diff --git a/dsl/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/DebeziumMysqlComponentBuilderFactory.java b/dsl/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/DebeziumMysqlComponentBuilderFactory.java
index 4f59696..83a8eae 100644
--- a/dsl/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/DebeziumMysqlComponentBuilderFactory.java
+++ b/dsl/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/DebeziumMysqlComponentBuilderFactory.java
@@ -1106,6 +1106,21 @@ public interface DebeziumMysqlComponentBuilderFactory {
return this;
}
/**
+ * The query executed with every heartbeat.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: mysql
+ *
+ * @param heartbeatActionQuery the value to set
+ * @return the dsl builder
+ */
+ default DebeziumMysqlComponentBuilder heartbeatActionQuery(
+ java.lang.String heartbeatActionQuery) {
+ doSetProperty("heartbeatActionQuery", heartbeatActionQuery);
+ return this;
+ }
+ /**
* Length of an interval in milli-seconds in in which the connector
* periodically sends heartbeat messages to a heartbeat topic. Use 0 to
* disable heartbeat messages. Disabled by default.
@@ -1183,6 +1198,27 @@ public interface DebeziumMysqlComponentBuilderFactory {
return this;
}
/**
+ * Whether the connector parse table and column's comment to metadata
+ * object.Note: Enable this option will bring the implications on memory
+ * usage. The number and size of ColumnImpl objects is what largely
+ * impacts how much memory is consumed by the Debezium connectors, and
+ * adding a String to each of them can potentially be quite heavy. The
+ * default is 'false'.
+ *
+ * The option is a: <code>boolean</code> type.
+ *
+ * Default: false
+ * Group: mysql
+ *
+ * @param includeSchemaComments the value to set
+ * @return the dsl builder
+ */
+ default DebeziumMysqlComponentBuilder includeSchemaComments(
+ boolean includeSchemaComments) {
+ doSetProperty("includeSchemaComments", includeSchemaComments);
+ return this;
+ }
+ /**
* 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
@@ -1205,6 +1241,29 @@ public interface DebeziumMysqlComponentBuilderFactory {
return this;
}
/**
+ * Detect schema change during an incremental snapshot and re-select a
+ * current chunk to avoid locking DDLs. Note that changes to a primary
+ * key are not supported and can cause incorrect results if performed
+ * during an incremental snapshot. Another limitation is that if a
+ * schema change affects only columns' default values, then the change
+ * won't be detected until the DDL is processed from the binlog stream.
+ * This doesn't affect the snapshot events' values, but the schema of
+ * snapshot events may have outdated defaults.
+ *
+ * The option is a: <code>boolean</code> type.
+ *
+ * Default: false
+ * Group: mysql
+ *
+ * @param incrementalSnapshotAllowSchemaChanges the value to set
+ * @return the dsl builder
+ */
+ default DebeziumMysqlComponentBuilder incrementalSnapshotAllowSchemaChanges(
+ boolean incrementalSnapshotAllowSchemaChanges) {
+ doSetProperty("incrementalSnapshotAllowSchemaChanges", incrementalSnapshotAllowSchemaChanges);
+ return this;
+ }
+ /**
* The maximum size of chunk for incremental snapshotting.
*
* The option is a: <code>int</code> type.
@@ -1760,6 +1819,24 @@ public interface DebeziumMysqlComponentBuilderFactory {
doSetProperty("tombstonesOnDelete", tombstonesOnDelete);
return this;
}
+ /**
+ * The name of the transaction metadata topic. The placeholder
+ * ${database.server.name} can be used for referring to the connector's
+ * logical name; defaults to ${database.server.name}.transaction.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Default: ${database.server.name}.transaction
+ * Group: mysql
+ *
+ * @param transactionTopic the value to set
+ * @return the dsl builder
+ */
+ default DebeziumMysqlComponentBuilder transactionTopic(
+ java.lang.String transactionTopic) {
+ doSetProperty("transactionTopic", transactionTopic);
+ return this;
+ }
}
class DebeziumMysqlComponentBuilderImpl
@@ -1843,11 +1920,14 @@ public interface DebeziumMysqlComponentBuilderFactory {
case "gtidSourceExcludes": getOrCreateConfiguration((DebeziumMySqlComponent) component).setGtidSourceExcludes((java.lang.String) value); return true;
case "gtidSourceFilterDmlEvents": getOrCreateConfiguration((DebeziumMySqlComponent) component).setGtidSourceFilterDmlEvents((boolean) value); return true;
case "gtidSourceIncludes": getOrCreateConfiguration((DebeziumMySqlComponent) component).setGtidSourceIncludes((java.lang.String) value); return true;
+ case "heartbeatActionQuery": getOrCreateConfiguration((DebeziumMySqlComponent) component).setHeartbeatActionQuery((java.lang.String) value); return true;
case "heartbeatIntervalMs": getOrCreateConfiguration((DebeziumMySqlComponent) component).setHeartbeatIntervalMs((int) value); return true;
case "heartbeatTopicsPrefix": getOrCreateConfiguration((DebeziumMySqlComponent) component).setHeartbeatTopicsPrefix((java.lang.String) value); return true;
case "includeQuery": getOrCreateConfiguration((DebeziumMySqlComponent) component).setIncludeQuery((boolean) value); return true;
case "includeSchemaChanges": getOrCreateConfiguration((DebeziumMySqlComponent) component).setIncludeSchemaChanges((boolean) value); return true;
+ case "includeSchemaComments": getOrCreateConfiguration((DebeziumMySqlComponent) component).setIncludeSchemaComments((boolean) value); return true;
case "inconsistentSchemaHandlingMode": getOrCreateConfiguration((DebeziumMySqlComponent) component).setInconsistentSchemaHandlingMode((java.lang.String) value); return true;
+ case "incrementalSnapshotAllowSchemaChanges": getOrCreateConfiguration((DebeziumMySqlComponent) component).setIncrementalSnapshotAllowSchemaChanges((boolean) value); return true;
case "incrementalSnapshotChunkSize": getOrCreateConfiguration((DebeziumMySqlComponent) component).setIncrementalSnapshotChunkSize((int) value); return true;
case "maxBatchSize": getOrCreateConfiguration((DebeziumMySqlComponent) component).setMaxBatchSize((int) value); return true;
case "maxQueueSize": getOrCreateConfiguration((DebeziumMySqlComponent) component).setMaxQueueSize((int) value); return true;
@@ -1878,6 +1958,7 @@ public interface DebeziumMysqlComponentBuilderFactory {
case "tableWhitelist": getOrCreateConfiguration((DebeziumMySqlComponent) component).setTableWhitelist((java.lang.String) value); return true;
case "timePrecisionMode": getOrCreateConfiguration((DebeziumMySqlComponent) component).setTimePrecisionMode((java.lang.String) value); return true;
case "tombstonesOnDelete": getOrCreateConfiguration((DebeziumMySqlComponent) component).setTombstonesOnDelete((boolean) value); return true;
+ case "transactionTopic": getOrCreateConfiguration((DebeziumMySqlComponent) component).setTransactionTopic((java.lang.String) value); return true;
default: return false;
}
}
diff --git a/dsl/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/DebeziumPostgresComponentBuilderFactory.java b/dsl/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/DebeziumPostgresComponentBuilderFactory.java
index 08b213c..b7f0872 100644
--- a/dsl/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/DebeziumPostgresComponentBuilderFactory.java
+++ b/dsl/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/DebeziumPostgresComponentBuilderFactory.java
@@ -801,6 +801,27 @@ public interface DebeziumPostgresComponentBuilderFactory {
return this;
}
/**
+ * Whether the connector parse table and column's comment to metadata
+ * object.Note: Enable this option will bring the implications on memory
+ * usage. The number and size of ColumnImpl objects is what largely
+ * impacts how much memory is consumed by the Debezium connectors, and
+ * adding a String to each of them can potentially be quite heavy. The
+ * default is 'false'.
+ *
+ * The option is a: <code>boolean</code> type.
+ *
+ * Default: false
+ * Group: postgres
+ *
+ * @param includeSchemaComments the value to set
+ * @return the dsl builder
+ */
+ default DebeziumPostgresComponentBuilder includeSchemaComments(
+ boolean includeSchemaComments) {
+ doSetProperty("includeSchemaComments", includeSchemaComments);
+ return this;
+ }
+ /**
* 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
@@ -928,6 +949,39 @@ public interface DebeziumPostgresComponentBuilderFactory {
return this;
}
/**
+ * A comma-separated list of regular expressions that match the logical
+ * decoding message prefixes to be excluded from monitoring.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: postgres
+ *
+ * @param messagePrefixExcludeList the value to set
+ * @return the dsl builder
+ */
+ default DebeziumPostgresComponentBuilder messagePrefixExcludeList(
+ java.lang.String messagePrefixExcludeList) {
+ doSetProperty("messagePrefixExcludeList", messagePrefixExcludeList);
+ return this;
+ }
+ /**
+ * A comma-separated list of regular expressions that match the logical
+ * decoding message prefixes to be monitored. All prefixes are monitored
+ * by default.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: postgres
+ *
+ * @param messagePrefixIncludeList the value to set
+ * @return the dsl builder
+ */
+ default DebeziumPostgresComponentBuilder messagePrefixIncludeList(
+ java.lang.String messagePrefixIncludeList) {
+ doSetProperty("messagePrefixIncludeList", messagePrefixIncludeList);
+ return this;
+ }
+ /**
* The name of the Postgres logical decoding plugin installed on the
* server. Supported values are 'decoderbufs', 'wal2json', 'pgoutput',
* 'wal2json_streaming', 'wal2json_rds' and 'wal2json_rds_streaming'.
@@ -1578,25 +1632,6 @@ public interface DebeziumPostgresComponentBuilderFactory {
return this;
}
/**
- * Specify the constant that will be provided by Debezium to indicate
- * that the original value is a toasted value not provided by the
- * database. If starts with 'hex:' prefix it is expected that the rest
- * of the string repesents hexadecimally encoded octets.
- *
- * The option is a: <code>java.lang.String</code> type.
- *
- * Default: __debezium_unavailable_value
- * Group: postgres
- *
- * @param toastedValuePlaceholder the value to set
- * @return the dsl builder
- */
- default DebeziumPostgresComponentBuilder toastedValuePlaceholder(
- java.lang.String toastedValuePlaceholder) {
- doSetProperty("toastedValuePlaceholder", toastedValuePlaceholder);
- return this;
- }
- /**
* Whether delete operations should be represented by a delete event and
* a subsquenttombstone event (true) or only by a delete event (false).
* Emitting the tombstone event (the default behavior) allows Kafka to
@@ -1617,6 +1652,24 @@ public interface DebeziumPostgresComponentBuilderFactory {
return this;
}
/**
+ * The name of the transaction metadata topic. The placeholder
+ * ${database.server.name} can be used for referring to the connector's
+ * logical name; defaults to ${database.server.name}.transaction.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Default: ${database.server.name}.transaction
+ * Group: postgres
+ *
+ * @param transactionTopic the value to set
+ * @return the dsl builder
+ */
+ default DebeziumPostgresComponentBuilder transactionTopic(
+ java.lang.String transactionTopic) {
+ doSetProperty("transactionTopic", transactionTopic);
+ return this;
+ }
+ /**
* Specify how TRUNCATE operations are handled for change events
* (supported only on pg11 pgoutput plugin), including: 'skip' to skip /
* ignore TRUNCATE events (default), 'include' to handle and include
@@ -1636,6 +1689,25 @@ public interface DebeziumPostgresComponentBuilderFactory {
return this;
}
/**
+ * Specify the constant that will be provided by Debezium to indicate
+ * that the original value is a toasted value not provided by the
+ * database. If starts with 'hex:' prefix it is expected that the rest
+ * of the string represents hexadecimal encoded octets.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Default: __debezium_unavailable_value
+ * Group: postgres
+ *
+ * @param unavailableValuePlaceholder the value to set
+ * @return the dsl builder
+ */
+ default DebeziumPostgresComponentBuilder unavailableValuePlaceholder(
+ java.lang.String unavailableValuePlaceholder) {
+ doSetProperty("unavailableValuePlaceholder", unavailableValuePlaceholder);
+ return this;
+ }
+ /**
* Specify how often (in ms) the xmin will be fetched from the
* replication slot. This xmin value is exposed by the slot which gives
* a lower bound of where a new replication slot could start from. The
@@ -1725,6 +1797,7 @@ public interface DebeziumPostgresComponentBuilderFactory {
case "heartbeatIntervalMs": getOrCreateConfiguration((DebeziumPostgresComponent) component).setHeartbeatIntervalMs((int) value); return true;
case "heartbeatTopicsPrefix": getOrCreateConfiguration((DebeziumPostgresComponent) component).setHeartbeatTopicsPrefix((java.lang.String) value); return true;
case "hstoreHandlingMode": getOrCreateConfiguration((DebeziumPostgresComponent) component).setHstoreHandlingMode((java.lang.String) value); return true;
+ case "includeSchemaComments": getOrCreateConfiguration((DebeziumPostgresComponent) component).setIncludeSchemaComments((boolean) value); return true;
case "includeUnknownDatatypes": getOrCreateConfiguration((DebeziumPostgresComponent) component).setIncludeUnknownDatatypes((boolean) value); return true;
case "incrementalSnapshotChunkSize": getOrCreateConfiguration((DebeziumPostgresComponent) component).setIncrementalSnapshotChunkSize((int) value); return true;
case "intervalHandlingMode": getOrCreateConfiguration((DebeziumPostgresComponent) component).setIntervalHandlingMode((java.lang.String) value); return true;
@@ -1732,6 +1805,8 @@ public interface DebeziumPostgresComponentBuilderFactory {
case "maxQueueSize": getOrCreateConfiguration((DebeziumPostgresComponent) component).setMaxQueueSize((int) value); return true;
case "maxQueueSizeInBytes": getOrCreateConfiguration((DebeziumPostgresComponent) component).setMaxQueueSizeInBytes((long) value); return true;
case "messageKeyColumns": getOrCreateConfiguration((DebeziumPostgresComponent) component).setMessageKeyColumns((java.lang.String) value); return true;
+ case "messagePrefixExcludeList": getOrCreateConfiguration((DebeziumPostgresComponent) component).setMessagePrefixExcludeList((java.lang.String) value); return true;
+ case "messagePrefixIncludeList": getOrCreateConfiguration((DebeziumPostgresComponent) component).setMessagePrefixIncludeList((java.lang.String) value); return true;
case "pluginName": getOrCreateConfiguration((DebeziumPostgresComponent) component).setPluginName((java.lang.String) value); return true;
case "pollIntervalMs": getOrCreateConfiguration((DebeziumPostgresComponent) component).setPollIntervalMs((long) value); return true;
case "provideTransactionMetadata": getOrCreateConfiguration((DebeziumPostgresComponent) component).setProvideTransactionMetadata((boolean) value); return true;
@@ -1768,9 +1843,10 @@ public interface DebeziumPostgresComponentBuilderFactory {
case "tableIncludeList": getOrCreateConfiguration((DebeziumPostgresComponent) component).setTableIncludeList((java.lang.String) value); return true;
case "tableWhitelist": getOrCreateConfiguration((DebeziumPostgresComponent) component).setTableWhitelist((java.lang.String) value); return true;
case "timePrecisionMode": getOrCreateConfiguration((DebeziumPostgresComponent) component).setTimePrecisionMode((java.lang.String) value); return true;
- case "toastedValuePlaceholder": getOrCreateConfiguration((DebeziumPostgresComponent) component).setToastedValuePlaceholder((java.lang.String) value); return true;
case "tombstonesOnDelete": getOrCreateConfiguration((DebeziumPostgresComponent) component).setTombstonesOnDelete((boolean) value); return true;
+ case "transactionTopic": getOrCreateConfiguration((DebeziumPostgresComponent) component).setTransactionTopic((java.lang.String) value); return true;
case "truncateHandlingMode": getOrCreateConfiguration((DebeziumPostgresComponent) component).setTruncateHandlingMode((java.lang.String) value); return true;
+ case "unavailableValuePlaceholder": getOrCreateConfiguration((DebeziumPostgresComponent) component).setUnavailableValuePlaceholder((java.lang.String) value); return true;
case "xminFetchIntervalMs": getOrCreateConfiguration((DebeziumPostgresComponent) component).setXminFetchIntervalMs((long) value); return true;
default: return false;
}
diff --git a/dsl/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/DebeziumSqlserverComponentBuilderFactory.java b/dsl/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/DebeziumSqlserverComponentBuilderFactory.java
index a06274e..afb667a 100644
--- a/dsl/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/DebeziumSqlserverComponentBuilderFactory.java
+++ b/dsl/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/DebeziumSqlserverComponentBuilderFactory.java
@@ -768,6 +768,21 @@ public interface DebeziumSqlserverComponentBuilderFactory {
return this;
}
/**
+ * The query executed with every heartbeat.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: sqlserver
+ *
+ * @param heartbeatActionQuery the value to set
+ * @return the dsl builder
+ */
+ default DebeziumSqlserverComponentBuilder heartbeatActionQuery(
+ java.lang.String heartbeatActionQuery) {
+ doSetProperty("heartbeatActionQuery", heartbeatActionQuery);
+ return this;
+ }
+ /**
* Length of an interval in milli-seconds in in which the connector
* periodically sends heartbeat messages to a heartbeat topic. Use 0 to
* disable heartbeat messages. Disabled by default.
@@ -824,6 +839,84 @@ public interface DebeziumSqlserverComponentBuilderFactory {
return this;
}
/**
+ * Whether the connector parse table and column's comment to metadata
+ * object.Note: Enable this option will bring the implications on memory
+ * usage. The number and size of ColumnImpl objects is what largely
+ * impacts how much memory is consumed by the Debezium connectors, and
+ * adding a String to each of them can potentially be quite heavy. The
+ * default is 'false'.
+ *
+ * The option is a: <code>boolean</code> type.
+ *
+ * Default: false
+ * Group: sqlserver
+ *
+ * @param includeSchemaComments the value to set
+ * @return the dsl builder
+ */
+ default DebeziumSqlserverComponentBuilder includeSchemaComments(
+ boolean includeSchemaComments) {
+ doSetProperty("includeSchemaComments", includeSchemaComments);
+ return this;
+ }
+ /**
+ * Detect schema change during an incremental snapshot and re-select a
+ * current chunk to avoid locking DDLs. Note that changes to a primary
+ * key are not supported and can cause incorrect results if performed
+ * during an incremental snapshot. Another limitation is that if a
+ * schema change affects only columns' default values, then the change
+ * won't be detected until the DDL is processed from the binlog stream.
+ * This doesn't affect the snapshot events' values, but the schema of
+ * snapshot events may have outdated defaults.
+ *
+ * The option is a: <code>boolean</code> type.
+ *
+ * Default: false
+ * Group: sqlserver
+ *
+ * @param incrementalSnapshotAllowSchemaChanges the value to set
+ * @return the dsl builder
+ */
+ default DebeziumSqlserverComponentBuilder incrementalSnapshotAllowSchemaChanges(
+ boolean incrementalSnapshotAllowSchemaChanges) {
+ doSetProperty("incrementalSnapshotAllowSchemaChanges", incrementalSnapshotAllowSchemaChanges);
+ return this;
+ }
+ /**
+ * The maximum size of chunk for incremental snapshotting.
+ *
+ * The option is a: <code>int</code> type.
+ *
+ * Default: 1024
+ * Group: sqlserver
+ *
+ * @param incrementalSnapshotChunkSize the value to set
+ * @return the dsl builder
+ */
+ default DebeziumSqlserverComponentBuilder incrementalSnapshotChunkSize(
+ int incrementalSnapshotChunkSize) {
+ doSetProperty("incrementalSnapshotChunkSize", incrementalSnapshotChunkSize);
+ return this;
+ }
+ /**
+ * Add OPTION(RECOMPILE) on each SELECT statement during the incremental
+ * snapshot process. This prevents parameter sniffing but can cause CPU
+ * pressure on the source database.
+ *
+ * The option is a: <code>boolean</code> type.
+ *
+ * Default: false
+ * Group: sqlserver
+ *
+ * @param incrementalSnapshotOptionRecompile the value to set
+ * @return the dsl builder
+ */
+ default DebeziumSqlserverComponentBuilder incrementalSnapshotOptionRecompile(
+ boolean incrementalSnapshotOptionRecompile) {
+ doSetProperty("incrementalSnapshotOptionRecompile", incrementalSnapshotOptionRecompile);
+ return this;
+ }
+ /**
* Maximum size of each batch of source records. Defaults to 2048.
*
* The option is a: <code>int</code> type.
@@ -1352,6 +1445,24 @@ public interface DebeziumSqlserverComponentBuilderFactory {
doSetProperty("tombstonesOnDelete", tombstonesOnDelete);
return this;
}
+ /**
+ * The name of the transaction metadata topic. The placeholder
+ * ${database.server.name} can be used for referring to the connector's
+ * logical name; defaults to ${database.server.name}.transaction.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Default: ${database.server.name}.transaction
+ * Group: sqlserver
+ *
+ * @param transactionTopic the value to set
+ * @return the dsl builder
+ */
+ default DebeziumSqlserverComponentBuilder transactionTopic(
+ java.lang.String transactionTopic) {
+ doSetProperty("transactionTopic", transactionTopic);
+ return this;
+ }
}
class DebeziumSqlserverComponentBuilderImpl
@@ -1417,9 +1528,14 @@ public interface DebeziumSqlserverComponentBuilderFactory {
case "datatypePropagateSourceType": getOrCreateConfiguration((DebeziumSqlserverComponent) component).setDatatypePropagateSourceType((java.lang.String) value); return true;
case "decimalHandlingMode": getOrCreateConfiguration((DebeziumSqlserverComponent) component).setDecimalHandlingMode((java.lang.String) value); return true;
case "eventProcessingFailureHandlingMode": getOrCreateConfiguration((DebeziumSqlserverComponent) component).setEventProcessingFailureHandlingMode((java.lang.String) value); return true;
+ case "heartbeatActionQuery": getOrCreateConfiguration((DebeziumSqlserverComponent) component).setHeartbeatActionQuery((java.lang.String) value); return true;
case "heartbeatIntervalMs": getOrCreateConfiguration((DebeziumSqlserverComponent) component).setHeartbeatIntervalMs((int) value); return true;
case "heartbeatTopicsPrefix": getOrCreateConfiguration((DebeziumSqlserverComponent) component).setHeartbeatTopicsPrefix((java.lang.String) value); return true;
case "includeSchemaChanges": getOrCreateConfiguration((DebeziumSqlserverComponent) component).setIncludeSchemaChanges((boolean) value); return true;
+ case "includeSchemaComments": getOrCreateConfiguration((DebeziumSqlserverComponent) component).setIncludeSchemaComments((boolean) value); return true;
+ case "incrementalSnapshotAllowSchemaChanges": getOrCreateConfiguration((DebeziumSqlserverComponent) component).setIncrementalSnapshotAllowSchemaChanges((boolean) value); return true;
+ case "incrementalSnapshotChunkSize": getOrCreateConfiguration((DebeziumSqlserverComponent) component).setIncrementalSnapshotChunkSize((int) value); return true;
+ case "incrementalSnapshotOptionRecompile": getOrCreateConfiguration((DebeziumSqlserverComponent) component).setIncrementalSnapshotOptionRecompile((boolean) value); return true;
case "maxBatchSize": getOrCreateConfiguration((DebeziumSqlserverComponent) component).setMaxBatchSize((int) value); return true;
case "maxIterationTransactions": getOrCreateConfiguration((DebeziumSqlserverComponent) component).setMaxIterationTransactions((int) value); return true;
case "maxQueueSize": getOrCreateConfiguration((DebeziumSqlserverComponent) component).setMaxQueueSize((int) value); return true;
@@ -1449,6 +1565,7 @@ public interface DebeziumSqlserverComponentBuilderFactory {
case "tableWhitelist": getOrCreateConfiguration((DebeziumSqlserverComponent) component).setTableWhitelist((java.lang.String) value); return true;
case "timePrecisionMode": getOrCreateConfiguration((DebeziumSqlserverComponent) component).setTimePrecisionMode((java.lang.String) value); return true;
case "tombstonesOnDelete": getOrCreateConfiguration((DebeziumSqlserverComponent) component).setTombstonesOnDelete((boolean) value); return true;
+ case "transactionTopic": getOrCreateConfiguration((DebeziumSqlserverComponent) component).setTransactionTopic((java.lang.String) value); return true;
default: return false;
}
}
diff --git a/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/DebeziumMongodbEndpointBuilderFactory.java b/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/DebeziumMongodbEndpointBuilderFactory.java
index 19d60d3..53e6667 100644
--- a/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/DebeziumMongodbEndpointBuilderFactory.java
+++ b/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/DebeziumMongodbEndpointBuilderFactory.java
@@ -377,6 +377,26 @@ public interface DebeziumMongodbEndpointBuilderFactory {
return this;
}
/**
+ * The method used to capture changes from MongoDB server. Options
+ * include: 'oplog' to capture changes from the oplog; 'change_streams'
+ * to capture changes via MongoDB Change Streams, update events do not
+ * contain full documents; 'change_streams_update_full' (the default) to
+ * capture changes via MongoDB Change Streams, update events contain
+ * full documents.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Default: change_streams_update_full
+ * Group: mongodb
+ *
+ * @param captureMode the value to set
+ * @return the dsl builder
+ */
+ default DebeziumMongodbEndpointBuilder captureMode(String captureMode) {
+ doSetProperty("captureMode", captureMode);
+ return this;
+ }
+ /**
* A comma-separated list of regular expressions that match the
* collection names for which changes are to be excluded.
*
@@ -1553,6 +1573,24 @@ public interface DebeziumMongodbEndpointBuilderFactory {
doSetProperty("tombstonesOnDelete", tombstonesOnDelete);
return this;
}
+ /**
+ * The name of the transaction metadata topic. The placeholder
+ * ${database.server.name} can be used for referring to the connector's
+ * logical name; defaults to ${database.server.name}.transaction.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Default: ${database.server.name}.transaction
+ * Group: mongodb
+ *
+ * @param transactionTopic the value to set
+ * @return the dsl builder
+ */
+ default DebeziumMongodbEndpointBuilder transactionTopic(
+ String transactionTopic) {
+ doSetProperty("transactionTopic", transactionTopic);
+ return this;
+ }
}
/**
diff --git a/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/DebeziumMySqlEndpointBuilderFactory.java b/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/DebeziumMySqlEndpointBuilderFactory.java
index 41f06ff..863a308 100644
--- a/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/DebeziumMySqlEndpointBuilderFactory.java
+++ b/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/DebeziumMySqlEndpointBuilderFactory.java
@@ -1442,6 +1442,21 @@ public interface DebeziumMySqlEndpointBuilderFactory {
return this;
}
/**
+ * The query executed with every heartbeat.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: mysql
+ *
+ * @param heartbeatActionQuery the value to set
+ * @return the dsl builder
+ */
+ default DebeziumMySqlEndpointBuilder heartbeatActionQuery(
+ String heartbeatActionQuery) {
+ doSetProperty("heartbeatActionQuery", heartbeatActionQuery);
+ return this;
+ }
+ /**
* Length of an interval in milli-seconds in in which the connector
* periodically sends heartbeat messages to a heartbeat topic. Use 0 to
* disable heartbeat messages. Disabled by default.
@@ -1581,6 +1596,49 @@ public interface DebeziumMySqlEndpointBuilderFactory {
return this;
}
/**
+ * Whether the connector parse table and column's comment to metadata
+ * object.Note: Enable this option will bring the implications on memory
+ * usage. The number and size of ColumnImpl objects is what largely
+ * impacts how much memory is consumed by the Debezium connectors, and
+ * adding a String to each of them can potentially be quite heavy. The
+ * default is 'false'.
+ *
+ * The option is a: <code>boolean</code> type.
+ *
+ * Default: false
+ * Group: mysql
+ *
+ * @param includeSchemaComments the value to set
+ * @return the dsl builder
+ */
+ default DebeziumMySqlEndpointBuilder includeSchemaComments(
+ boolean includeSchemaComments) {
+ doSetProperty("includeSchemaComments", includeSchemaComments);
+ return this;
+ }
+ /**
+ * Whether the connector parse table and column's comment to metadata
+ * object.Note: Enable this option will bring the implications on memory
+ * usage. The number and size of ColumnImpl objects is what largely
+ * impacts how much memory is consumed by the Debezium connectors, and
+ * adding a String to each of them can potentially be quite heavy. The
+ * default is 'false'.
+ *
+ * The option will be converted to a <code>boolean</code>
+ * type.
+ *
+ * Default: false
+ * Group: mysql
+ *
+ * @param includeSchemaComments the value to set
+ * @return the dsl builder
+ */
+ default DebeziumMySqlEndpointBuilder includeSchemaComments(
+ String includeSchemaComments) {
+ doSetProperty("includeSchemaComments", includeSchemaComments);
+ return this;
+ }
+ /**
* 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
@@ -1603,6 +1661,53 @@ public interface DebeziumMySqlEndpointBuilderFactory {
return this;
}
/**
+ * Detect schema change during an incremental snapshot and re-select a
+ * current chunk to avoid locking DDLs. Note that changes to a primary
+ * key are not supported and can cause incorrect results if performed
+ * during an incremental snapshot. Another limitation is that if a
+ * schema change affects only columns' default values, then the change
+ * won't be detected until the DDL is processed from the binlog stream.
+ * This doesn't affect the snapshot events' values, but the schema of
+ * snapshot events may have outdated defaults.
+ *
+ * The option is a: <code>boolean</code> type.
+ *
+ * Default: false
+ * Group: mysql
+ *
+ * @param incrementalSnapshotAllowSchemaChanges the value to set
+ * @return the dsl builder
+ */
+ default DebeziumMySqlEndpointBuilder incrementalSnapshotAllowSchemaChanges(
+ boolean incrementalSnapshotAllowSchemaChanges) {
+ doSetProperty("incrementalSnapshotAllowSchemaChanges", incrementalSnapshotAllowSchemaChanges);
+ return this;
+ }
+ /**
+ * Detect schema change during an incremental snapshot and re-select a
+ * current chunk to avoid locking DDLs. Note that changes to a primary
+ * key are not supported and can cause incorrect results if performed
+ * during an incremental snapshot. Another limitation is that if a
+ * schema change affects only columns' default values, then the change
+ * won't be detected until the DDL is processed from the binlog stream.
+ * This doesn't affect the snapshot events' values, but the schema of
+ * snapshot events may have outdated defaults.
+ *
+ * The option will be converted to a <code>boolean</code>
+ * type.
+ *
+ * Default: false
+ * Group: mysql
+ *
+ * @param incrementalSnapshotAllowSchemaChanges the value to set
+ * @return the dsl builder
+ */
+ default DebeziumMySqlEndpointBuilder incrementalSnapshotAllowSchemaChanges(
+ String incrementalSnapshotAllowSchemaChanges) {
+ doSetProperty("incrementalSnapshotAllowSchemaChanges", incrementalSnapshotAllowSchemaChanges);
+ return this;
+ }
+ /**
* The maximum size of chunk for incremental snapshotting.
*
* The option is a: <code>int</code> type.
@@ -2433,6 +2538,24 @@ public interface DebeziumMySqlEndpointBuilderFactory {
doSetProperty("tombstonesOnDelete", tombstonesOnDelete);
return this;
}
+ /**
+ * The name of the transaction metadata topic. The placeholder
+ * ${database.server.name} can be used for referring to the connector's
+ * logical name; defaults to ${database.server.name}.transaction.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Default: ${database.server.name}.transaction
+ * Group: mysql
+ *
+ * @param transactionTopic the value to set
+ * @return the dsl builder
+ */
+ default DebeziumMySqlEndpointBuilder transactionTopic(
+ String transactionTopic) {
+ doSetProperty("transactionTopic", transactionTopic);
+ return this;
+ }
}
/**
diff --git a/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/DebeziumPostgresEndpointBuilderFactory.java b/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/DebeziumPostgresEndpointBuilderFactory.java
index 53e0e4b..58b6b60 100644
--- a/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/DebeziumPostgresEndpointBuilderFactory.java
+++ b/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/DebeziumPostgresEndpointBuilderFactory.java
@@ -927,6 +927,49 @@ public interface DebeziumPostgresEndpointBuilderFactory {
return this;
}
/**
+ * Whether the connector parse table and column's comment to metadata
+ * object.Note: Enable this option will bring the implications on memory
+ * usage. The number and size of ColumnImpl objects is what largely
+ * impacts how much memory is consumed by the Debezium connectors, and
+ * adding a String to each of them can potentially be quite heavy. The
+ * default is 'false'.
+ *
+ * The option is a: <code>boolean</code> type.
+ *
+ * Default: false
+ * Group: postgres
+ *
+ * @param includeSchemaComments the value to set
+ * @return the dsl builder
+ */
+ default DebeziumPostgresEndpointBuilder includeSchemaComments(
+ boolean includeSchemaComments) {
+ doSetProperty("includeSchemaComments", includeSchemaComments);
+ return this;
+ }
+ /**
+ * Whether the connector parse table and column's comment to metadata
+ * object.Note: Enable this option will bring the implications on memory
+ * usage. The number and size of ColumnImpl objects is what largely
+ * impacts how much memory is consumed by the Debezium connectors, and
+ * adding a String to each of them can potentially be quite heavy. The
+ * default is 'false'.
+ *
+ * The option will be converted to a <code>boolean</code>
+ * type.
+ *
+ * Default: false
+ * Group: postgres
+ *
+ * @param includeSchemaComments the value to set
+ * @return the dsl builder
+ */
+ default DebeziumPostgresEndpointBuilder includeSchemaComments(
+ String includeSchemaComments) {
+ doSetProperty("includeSchemaComments", includeSchemaComments);
+ return this;
+ }
+ /**
* 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
@@ -1140,6 +1183,39 @@ public interface DebeziumPostgresEndpointBuilderFactory {
return this;
}
/**
+ * A comma-separated list of regular expressions that match the logical
+ * decoding message prefixes to be excluded from monitoring.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: postgres
+ *
+ * @param messagePrefixExcludeList the value to set
+ * @return the dsl builder
+ */
+ default DebeziumPostgresEndpointBuilder messagePrefixExcludeList(
+ String messagePrefixExcludeList) {
+ doSetProperty("messagePrefixExcludeList", messagePrefixExcludeList);
+ return this;
+ }
+ /**
+ * A comma-separated list of regular expressions that match the logical
+ * decoding message prefixes to be monitored. All prefixes are monitored
+ * by default.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: postgres
+ *
+ * @param messagePrefixIncludeList the value to set
+ * @return the dsl builder
+ */
+ default DebeziumPostgresEndpointBuilder messagePrefixIncludeList(
+ String messagePrefixIncludeList) {
+ doSetProperty("messagePrefixIncludeList", messagePrefixIncludeList);
+ return this;
+ }
+ /**
* The name of the Postgres logical decoding plugin installed on the
* server. Supported values are 'decoderbufs', 'wal2json', 'pgoutput',
* 'wal2json_streaming', 'wal2json_rds' and 'wal2json_rds_streaming'.
@@ -2028,25 +2104,6 @@ public interface DebeziumPostgresEndpointBuilderFactory {
return this;
}
/**
- * Specify the constant that will be provided by Debezium to indicate
- * that the original value is a toasted value not provided by the
- * database. If starts with 'hex:' prefix it is expected that the rest
- * of the string repesents hexadecimally encoded octets.
- *
- * The option is a: <code>java.lang.String</code> type.
- *
- * Default: __debezium_unavailable_value
- * Group: postgres
- *
- * @param toastedValuePlaceholder the value to set
- * @return the dsl builder
- */
- default DebeziumPostgresEndpointBuilder toastedValuePlaceholder(
- String toastedValuePlaceholder) {
- doSetProperty("toastedValuePlaceholder", toastedValuePlaceholder);
- return this;
- }
- /**
* Whether delete operations should be represented by a delete event and
* a subsquenttombstone event (true) or only by a delete event (false).
* Emitting the tombstone event (the default behavior) allows Kafka to
@@ -2088,6 +2145,24 @@ public interface DebeziumPostgresEndpointBuilderFactory {
return this;
}
/**
+ * The name of the transaction metadata topic. The placeholder
+ * ${database.server.name} can be used for referring to the connector's
+ * logical name; defaults to ${database.server.name}.transaction.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Default: ${database.server.name}.transaction
+ * Group: postgres
+ *
+ * @param transactionTopic the value to set
+ * @return the dsl builder
+ */
+ default DebeziumPostgresEndpointBuilder transactionTopic(
+ String transactionTopic) {
+ doSetProperty("transactionTopic", transactionTopic);
+ return this;
+ }
+ /**
* Specify how TRUNCATE operations are handled for change events
* (supported only on pg11 pgoutput plugin), including: 'skip' to skip /
* ignore TRUNCATE events (default), 'include' to handle and include
@@ -2107,6 +2182,25 @@ public interface DebeziumPostgresEndpointBuilderFactory {
return this;
}
/**
+ * Specify the constant that will be provided by Debezium to indicate
+ * that the original value is a toasted value not provided by the
+ * database. If starts with 'hex:' prefix it is expected that the rest
+ * of the string represents hexadecimal encoded octets.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Default: __debezium_unavailable_value
+ * Group: postgres
+ *
+ * @param unavailableValuePlaceholder the value to set
+ * @return the dsl builder
+ */
+ default DebeziumPostgresEndpointBuilder unavailableValuePlaceholder(
+ String unavailableValuePlaceholder) {
+ doSetProperty("unavailableValuePlaceholder", unavailableValuePlaceholder);
+ return this;
+ }
+ /**
* Specify how often (in ms) the xmin will be fetched from the
* replication slot. This xmin value is exposed by the slot which gives
* a lower bound of where a new replication slot could start from. The
diff --git a/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/DebeziumSqlserverEndpointBuilderFactory.java b/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/DebeziumSqlserverEndpointBuilderFactory.java
index ea253c2..f92c950 100644
--- a/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/DebeziumSqlserverEndpointBuilderFactory.java
+++ b/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/DebeziumSqlserverEndpointBuilderFactory.java
@@ -957,6 +957,21 @@ public interface DebeziumSqlserverEndpointBuilderFactory {
return this;
}
/**
+ * The query executed with every heartbeat.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: sqlserver
+ *
+ * @param heartbeatActionQuery the value to set
+ * @return the dsl builder
+ */
+ default DebeziumSqlserverEndpointBuilder heartbeatActionQuery(
+ String heartbeatActionQuery) {
+ doSetProperty("heartbeatActionQuery", heartbeatActionQuery);
+ return this;
+ }
+ /**
* Length of an interval in milli-seconds in in which the connector
* periodically sends heartbeat messages to a heartbeat topic. Use 0 to
* disable heartbeat messages. Disabled by default.
@@ -1053,6 +1068,165 @@ public interface DebeziumSqlserverEndpointBuilderFactory {
return this;
}
/**
+ * Whether the connector parse table and column's comment to metadata
+ * object.Note: Enable this option will bring the implications on memory
+ * usage. The number and size of ColumnImpl objects is what largely
+ * impacts how much memory is consumed by the Debezium connectors, and
+ * adding a String to each of them can potentially be quite heavy. The
+ * default is 'false'.
+ *
+ * The option is a: <code>boolean</code> type.
+ *
+ * Default: false
+ * Group: sqlserver
+ *
+ * @param includeSchemaComments the value to set
+ * @return the dsl builder
+ */
+ default DebeziumSqlserverEndpointBuilder includeSchemaComments(
+ boolean includeSchemaComments) {
+ doSetProperty("includeSchemaComments", includeSchemaComments);
+ return this;
+ }
+ /**
+ * Whether the connector parse table and column's comment to metadata
+ * object.Note: Enable this option will bring the implications on memory
+ * usage. The number and size of ColumnImpl objects is what largely
+ * impacts how much memory is consumed by the Debezium connectors, and
+ * adding a String to each of them can potentially be quite heavy. The
+ * default is 'false'.
+ *
+ * The option will be converted to a <code>boolean</code>
+ * type.
+ *
+ * Default: false
+ * Group: sqlserver
+ *
+ * @param includeSchemaComments the value to set
+ * @return the dsl builder
+ */
+ default DebeziumSqlserverEndpointBuilder includeSchemaComments(
+ String includeSchemaComments) {
+ doSetProperty("includeSchemaComments", includeSchemaComments);
+ return this;
+ }
+ /**
+ * Detect schema change during an incremental snapshot and re-select a
+ * current chunk to avoid locking DDLs. Note that changes to a primary
+ * key are not supported and can cause incorrect results if performed
+ * during an incremental snapshot. Another limitation is that if a
+ * schema change affects only columns' default values, then the change
+ * won't be detected until the DDL is processed from the binlog stream.
+ * This doesn't affect the snapshot events' values, but the schema of
+ * snapshot events may have outdated defaults.
+ *
+ * The option is a: <code>boolean</code> type.
+ *
+ * Default: false
+ * Group: sqlserver
+ *
+ * @param incrementalSnapshotAllowSchemaChanges the value to set
+ * @return the dsl builder
+ */
+ default DebeziumSqlserverEndpointBuilder incrementalSnapshotAllowSchemaChanges(
+ boolean incrementalSnapshotAllowSchemaChanges) {
+ doSetProperty("incrementalSnapshotAllowSchemaChanges", incrementalSnapshotAllowSchemaChanges);
+ return this;
+ }
+ /**
+ * Detect schema change during an incremental snapshot and re-select a
+ * current chunk to avoid locking DDLs. Note that changes to a primary
+ * key are not supported and can cause incorrect results if performed
+ * during an incremental snapshot. Another limitation is that if a
+ * schema change affects only columns' default values, then the change
+ * won't be detected until the DDL is processed from the binlog stream.
+ * This doesn't affect the snapshot events' values, but the schema of
+ * snapshot events may have outdated defaults.
+ *
+ * The option will be converted to a <code>boolean</code>
+ * type.
+ *
+ * Default: false
+ * Group: sqlserver
+ *
+ * @param incrementalSnapshotAllowSchemaChanges the value to set
+ * @return the dsl builder
+ */
+ default DebeziumSqlserverEndpointBuilder incrementalSnapshotAllowSchemaChanges(
+ String incrementalSnapshotAllowSchemaChanges) {
+ doSetProperty("incrementalSnapshotAllowSchemaChanges", incrementalSnapshotAllowSchemaChanges);
+ return this;
+ }
+ /**
+ * The maximum size of chunk for incremental snapshotting.
+ *
+ * The option is a: <code>int</code> type.
+ *
+ * Default: 1024
+ * Group: sqlserver
+ *
+ * @param incrementalSnapshotChunkSize the value to set
+ * @return the dsl builder
+ */
+ default DebeziumSqlserverEndpointBuilder incrementalSnapshotChunkSize(
+ int incrementalSnapshotChunkSize) {
+ doSetProperty("incrementalSnapshotChunkSize", incrementalSnapshotChunkSize);
+ return this;
+ }
+ /**
+ * The maximum size of chunk for incremental snapshotting.
+ *
+ * The option will be converted to a <code>int</code> type.
+ *
+ * Default: 1024
+ * Group: sqlserver
+ *
+ * @param incrementalSnapshotChunkSize the value to set
+ * @return the dsl builder
+ */
+ default DebeziumSqlserverEndpointBuilder incrementalSnapshotChunkSize(
+ String incrementalSnapshotChunkSize) {
+ doSetProperty("incrementalSnapshotChunkSize", incrementalSnapshotChunkSize);
+ return this;
+ }
+ /**
+ * Add OPTION(RECOMPILE) on each SELECT statement during the incremental
+ * snapshot process. This prevents parameter sniffing but can cause CPU
+ * pressure on the source database.
+ *
+ * The option is a: <code>boolean</code> type.
+ *
+ * Default: false
+ * Group: sqlserver
+ *
+ * @param incrementalSnapshotOptionRecompile the value to set
+ * @return the dsl builder
+ */
+ default DebeziumSqlserverEndpointBuilder incrementalSnapshotOptionRecompile(
+ boolean incrementalSnapshotOptionRecompile) {
+ doSetProperty("incrementalSnapshotOptionRecompile", incrementalSnapshotOptionRecompile);
+ return this;
+ }
+ /**
+ * Add OPTION(RECOMPILE) on each SELECT statement during the incremental
+ * snapshot process. This prevents parameter sniffing but can cause CPU
+ * pressure on the source database.
+ *
+ * The option will be converted to a <code>boolean</code>
+ * type.
+ *
+ * Default: false
+ * Group: sqlserver
+ *
+ * @param incrementalSnapshotOptionRecompile the value to set
+ * @return the dsl builder
+ */
+ default DebeziumSqlserverEndpointBuilder incrementalSnapshotOptionRecompile(
+ String incrementalSnapshotOptionRecompile) {
+ doSetProperty("incrementalSnapshotOptionRecompile", incrementalSnapshotOptionRecompile);
+ return this;
+ }
+ /**
* Maximum size of each batch of source records. Defaults to 2048.
*
* The option is a: <code>int</code> type.
@@ -1842,6 +2016,24 @@ public interface DebeziumSqlserverEndpointBuilderFactory {
doSetProperty("tombstonesOnDelete", tombstonesOnDelete);
return this;
}
+ /**
+ * The name of the transaction metadata topic. The placeholder
+ * ${database.server.name} can be used for referring to the connector's
+ * logical name; defaults to ${database.server.name}.transaction.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Default: ${database.server.name}.transaction
+ * Group: sqlserver
+ *
+ * @param transactionTopic the value to set
+ * @return the dsl builder
+ */
+ default DebeziumSqlserverEndpointBuilder transactionTopic(
+ String transactionTopic) {
+ doSetProperty("transactionTopic", transactionTopic);
+ return this;
+ }
}
/**