You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by ac...@apache.org on 2021/10/05 08:01:12 UTC
[camel] 01/02: CAMEL-17044 - camel-debezium - Upgrade to 1.7
This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel.git
commit 2c03bf3f0224b5961d40f6d463550b8d034e9944
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Tue Oct 5 09:57:50 2021 +0200
CAMEL-17044 - camel-debezium - Upgrade to 1.7
---
.../DebeziumMongodbComponentConfigurer.java | 6 +++
.../DebeziumMongodbEndpointConfigurer.java | 6 +++
.../DebeziumMongodbEndpointUriFactory.java | 3 +-
...goDbConnectorEmbeddedDebeziumConfiguration.java | 24 ++++++++-
.../camel/component/debezium/debezium-mongodb.json | 6 ++-
.../debezium/DebeziumMySqlComponentConfigurer.java | 12 +++++
.../debezium/DebeziumMySqlEndpointConfigurer.java | 12 +++++
.../debezium/DebeziumMySqlEndpointUriFactory.java | 4 +-
...ySqlConnectorEmbeddedDebeziumConfiguration.java | 33 +++++++++++++
.../camel/component/debezium/debezium-mysql.json | 4 ++
.../DebeziumPostgresComponentConfigurer.java | 6 +++
.../DebeziumPostgresEndpointConfigurer.java | 6 +++
.../DebeziumPostgresEndpointUriFactory.java | 3 +-
...gresConnectorEmbeddedDebeziumConfiguration.java | 19 +++++++-
.../component/debezium/debezium-postgres.json | 6 ++-
.../DebeziumSqlserverComponentConfigurer.java | 12 ++---
.../DebeziumSqlserverEndpointConfigurer.java | 12 ++---
.../DebeziumSqlserverEndpointUriFactory.java | 2 +-
...rverConnectorEmbeddedDebeziumConfiguration.java | 32 ++++++------
.../component/debezium/debezium-sqlserver.json | 8 +--
.../DebeziumMongodbComponentBuilderFactory.java | 23 ++++++++-
.../dsl/DebeziumMysqlComponentBuilderFactory.java | 40 +++++++++++++++
.../DebeziumPostgresComponentBuilderFactory.java | 23 ++++++++-
.../DebeziumSqlserverComponentBuilderFactory.java | 38 +++++++--------
.../dsl/DebeziumMongodbEndpointBuilderFactory.java | 38 ++++++++++++++-
.../dsl/DebeziumMySqlEndpointBuilderFactory.java | 57 ++++++++++++++++++++++
.../DebeziumPostgresEndpointBuilderFactory.java | 22 ++++++++-
.../DebeziumSqlserverEndpointBuilderFactory.java | 36 +++++++-------
parent/pom.xml | 2 +-
29 files changed, 408 insertions(+), 87 deletions(-)
diff --git a/components/camel-debezium/camel-debezium-mongodb/src/generated/java/org/apache/camel/component/debezium/DebeziumMongodbComponentConfigurer.java b/components/camel-debezium/camel-debezium-mongodb/src/generated/java/org/apache/camel/component/debezium/DebeziumMongodbComponentConfigurer.java
index 34de4e5..5103b28 100644
--- a/components/camel-debezium/camel-debezium-mongodb/src/generated/java/org/apache/camel/component/debezium/DebeziumMongodbComponentConfigurer.java
+++ b/components/camel-debezium/camel-debezium-mongodb/src/generated/java/org/apache/camel/component/debezium/DebeziumMongodbComponentConfigurer.java
@@ -46,6 +46,8 @@ public class DebeziumMongodbComponentConfigurer extends PropertyConfigurerSuppor
case "connectmaxattempts":
case "connectMaxAttempts": getOrCreateConfiguration(target).setConnectMaxAttempts(property(camelContext, int.class, value)); return true;
case "converters": getOrCreateConfiguration(target).setConverters(property(camelContext, java.lang.String.class, value)); return true;
+ case "cursormaxawaittimems":
+ case "cursorMaxAwaitTimeMs": getOrCreateConfiguration(target).setCursorMaxAwaitTimeMs(property(camelContext, int.class, value)); return true;
case "databaseexcludelist":
case "databaseExcludeList": getOrCreateConfiguration(target).setDatabaseExcludeList(property(camelContext, java.lang.String.class, value)); return true;
case "databasehistoryfilefilename":
@@ -167,6 +169,8 @@ public class DebeziumMongodbComponentConfigurer extends PropertyConfigurerSuppor
case "connectmaxattempts":
case "connectMaxAttempts": return int.class;
case "converters": return java.lang.String.class;
+ case "cursormaxawaittimems":
+ case "cursorMaxAwaitTimeMs": return int.class;
case "databaseexcludelist":
case "databaseExcludeList": return java.lang.String.class;
case "databasehistoryfilefilename":
@@ -289,6 +293,8 @@ public class DebeziumMongodbComponentConfigurer extends PropertyConfigurerSuppor
case "connectmaxattempts":
case "connectMaxAttempts": return getOrCreateConfiguration(target).getConnectMaxAttempts();
case "converters": return getOrCreateConfiguration(target).getConverters();
+ case "cursormaxawaittimems":
+ case "cursorMaxAwaitTimeMs": return getOrCreateConfiguration(target).getCursorMaxAwaitTimeMs();
case "databaseexcludelist":
case "databaseExcludeList": return getOrCreateConfiguration(target).getDatabaseExcludeList();
case "databasehistoryfilefilename":
diff --git a/components/camel-debezium/camel-debezium-mongodb/src/generated/java/org/apache/camel/component/debezium/DebeziumMongodbEndpointConfigurer.java b/components/camel-debezium/camel-debezium-mongodb/src/generated/java/org/apache/camel/component/debezium/DebeziumMongodbEndpointConfigurer.java
index 275945e..ad1af2b 100644
--- a/components/camel-debezium/camel-debezium-mongodb/src/generated/java/org/apache/camel/component/debezium/DebeziumMongodbEndpointConfigurer.java
+++ b/components/camel-debezium/camel-debezium-mongodb/src/generated/java/org/apache/camel/component/debezium/DebeziumMongodbEndpointConfigurer.java
@@ -36,6 +36,8 @@ public class DebeziumMongodbEndpointConfigurer extends PropertyConfigurerSupport
case "connectmaxattempts":
case "connectMaxAttempts": target.getConfiguration().setConnectMaxAttempts(property(camelContext, int.class, value)); return true;
case "converters": target.getConfiguration().setConverters(property(camelContext, java.lang.String.class, value)); return true;
+ case "cursormaxawaittimems":
+ case "cursorMaxAwaitTimeMs": target.getConfiguration().setCursorMaxAwaitTimeMs(property(camelContext, int.class, value)); return true;
case "databaseexcludelist":
case "databaseExcludeList": target.getConfiguration().setDatabaseExcludeList(property(camelContext, java.lang.String.class, value)); return true;
case "databasehistoryfilefilename":
@@ -158,6 +160,8 @@ public class DebeziumMongodbEndpointConfigurer extends PropertyConfigurerSupport
case "connectmaxattempts":
case "connectMaxAttempts": return int.class;
case "converters": return java.lang.String.class;
+ case "cursormaxawaittimems":
+ case "cursorMaxAwaitTimeMs": return int.class;
case "databaseexcludelist":
case "databaseExcludeList": return java.lang.String.class;
case "databasehistoryfilefilename":
@@ -281,6 +285,8 @@ public class DebeziumMongodbEndpointConfigurer extends PropertyConfigurerSupport
case "connectmaxattempts":
case "connectMaxAttempts": return target.getConfiguration().getConnectMaxAttempts();
case "converters": return target.getConfiguration().getConverters();
+ case "cursormaxawaittimems":
+ case "cursorMaxAwaitTimeMs": return target.getConfiguration().getCursorMaxAwaitTimeMs();
case "databaseexcludelist":
case "databaseExcludeList": return target.getConfiguration().getDatabaseExcludeList();
case "databasehistoryfilefilename":
diff --git a/components/camel-debezium/camel-debezium-mongodb/src/generated/java/org/apache/camel/component/debezium/DebeziumMongodbEndpointUriFactory.java b/components/camel-debezium/camel-debezium-mongodb/src/generated/java/org/apache/camel/component/debezium/DebeziumMongodbEndpointUriFactory.java
index 5e9d458..1ff05e2 100644
--- a/components/camel-debezium/camel-debezium-mongodb/src/generated/java/org/apache/camel/component/debezium/DebeziumMongodbEndpointUriFactory.java
+++ b/components/camel-debezium/camel-debezium-mongodb/src/generated/java/org/apache/camel/component/debezium/DebeziumMongodbEndpointUriFactory.java
@@ -20,7 +20,7 @@ public class DebeziumMongodbEndpointUriFactory extends org.apache.camel.support.
private static final Set<String> PROPERTY_NAMES;
private static final Set<String> SECRET_PROPERTY_NAMES;
static {
- Set<String> props = new HashSet<>(59);
+ Set<String> props = new HashSet<>(60);
props.add("mongodbServerSelectionTimeoutMs");
props.add("maxBatchSize");
props.add("internalKeyConverter");
@@ -60,6 +60,7 @@ public class DebeziumMongodbEndpointUriFactory extends org.apache.camel.support.
props.add("mongodbConnectTimeoutMs");
props.add("snapshotIncludeCollectionList");
props.add("databaseHistoryFileFilename");
+ props.add("cursorMaxAwaitTimeMs");
props.add("offsetStorage");
props.add("internalValueConverter");
props.add("snapshotMaxThreads");
diff --git a/components/camel-debezium/camel-debezium-mongodb/src/generated/java/org/apache/camel/component/debezium/configuration/MongoDbConnectorEmbeddedDebeziumConfiguration.java b/components/camel-debezium/camel-debezium-mongodb/src/generated/java/org/apache/camel/component/debezium/configuration/MongoDbConnectorEmbeddedDebeziumConfiguration.java
index d2a1f05..0e1c5db 100644
--- a/components/camel-debezium/camel-debezium-mongodb/src/generated/java/org/apache/camel/component/debezium/configuration/MongoDbConnectorEmbeddedDebeziumConfiguration.java
+++ b/components/camel-debezium/camel-debezium-mongodb/src/generated/java/org/apache/camel/component/debezium/configuration/MongoDbConnectorEmbeddedDebeziumConfiguration.java
@@ -19,6 +19,8 @@ public class MongoDbConnectorEmbeddedDebeziumConfiguration
private int queryFetchSize = 0;
@UriParam(label = LABEL_NAME, defaultValue = "false")
private boolean mongodbSslEnabled = false;
+ @UriParam(label = LABEL_NAME, javaType = "java.time.Duration")
+ private int cursorMaxAwaitTimeMs;
@UriParam(label = LABEL_NAME, defaultValue = "true")
private boolean mongodbMembersAutoDiscover = true;
@UriParam(label = LABEL_NAME)
@@ -138,6 +140,18 @@ public class MongoDbConnectorEmbeddedDebeziumConfiguration
}
/**
+ * The maximum processing time in milliseconds to wait for the oplog cursor
+ * to process a single poll request
+ */
+ public void setCursorMaxAwaitTimeMs(int cursorMaxAwaitTimeMs) {
+ this.cursorMaxAwaitTimeMs = cursorMaxAwaitTimeMs;
+ }
+
+ public int getCursorMaxAwaitTimeMs() {
+ return cursorMaxAwaitTimeMs;
+ }
+
+ /**
* Specifies whether the addresses in 'hosts' are seeds that should be used
* to discover all members of the cluster or replica set ('true'), or
* whether the address(es) in 'hosts' should be used as is ('false'). The
@@ -152,8 +166,13 @@ public class MongoDbConnectorEmbeddedDebeziumConfiguration
}
/**
- * Description is not available here, please check Debezium website for
- * corresponding key 'field.renames' description.
+ * A comma-separated list of the fully-qualified replacements of fields that
+ * should be used to rename fields in change event message values.
+ * Fully-qualified replacements for fields are of the form
+ * databaseName.collectionName.fieldName.nestedFieldName:newNestedFieldName,
+ * where databaseName and collectionName may contain the wildcard (*) which
+ * matches any characters, the colon character (:) is used to determine
+ * rename mapping of field.
*/
public void setFieldRenames(String fieldRenames) {
this.fieldRenames = fieldRenames;
@@ -663,6 +682,7 @@ public class MongoDbConnectorEmbeddedDebeziumConfiguration
addPropertyIfNotNull(configBuilder, "mongodb.password", mongodbPassword);
addPropertyIfNotNull(configBuilder, "query.fetch.size", queryFetchSize);
addPropertyIfNotNull(configBuilder, "mongodb.ssl.enabled", mongodbSslEnabled);
+ addPropertyIfNotNull(configBuilder, "cursor.max.await.time.ms", cursorMaxAwaitTimeMs);
addPropertyIfNotNull(configBuilder, "mongodb.members.auto.discover", mongodbMembersAutoDiscover);
addPropertyIfNotNull(configBuilder, "field.renames", fieldRenames);
addPropertyIfNotNull(configBuilder, "mongodb.server.selection.timeout.ms", mongodbServerSelectionTimeoutMs);
diff --git a/components/camel-debezium/camel-debezium-mongodb/src/generated/resources/org/apache/camel/component/debezium/debezium-mongodb.json b/components/camel-debezium/camel-debezium-mongodb/src/generated/resources/org/apache/camel/component/debezium/debezium-mongodb.json
index 1f07941..ad07d31 100644
--- a/components/camel-debezium/camel-debezium-mongodb/src/generated/resources/org/apache/camel/component/debezium/debezium-mongodb.json
+++ b/components/camel-debezium/camel-debezium-mongodb/src/generated/resources/org/apache/camel/component/debezium/debezium-mongodb.json
@@ -42,12 +42,13 @@
"connectBackoffMaxDelayMs": { "kind": "property", "displayName": "Connect Backoff Max Delay Ms", "group": "mongodb", "label": "consumer,mongodb", "required": false, "type": "duration", "javaType": "long", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "2m", "configurationClass": "org.apache.camel.component.debezium.configuration.MongoDbConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The maximum delay when tryi [...]
"connectMaxAttempts": { "kind": "property", "displayName": "Connect Max Attempts", "group": "mongodb", "label": "consumer,mongodb", "required": false, "type": "integer", "javaType": "int", "deprecated": false, "autowired": false, "secret": false, "defaultValue": 16, "configurationClass": "org.apache.camel.component.debezium.configuration.MongoDbConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Maximum number of failed connection attempts [...]
"converters": { "kind": "property", "displayName": "Converters", "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": "Optional list of custom converters that would be used instead of defaul [...]
+ "cursorMaxAwaitTimeMs": { "kind": "property", "displayName": "Cursor Max Await Time Ms", "group": "mongodb", "label": "consumer,mongodb", "required": false, "type": "duration", "javaType": "int", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.MongoDbConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The maximum processing time in milliseconds to wait for th [...]
"databaseExcludeList": { "kind": "property", "displayName": "Database 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 that [...]
"databaseHistoryFileFilename": { "kind": "property", "displayName": "Database History File Filename", "group": "mongodb", "label": "consumer,mongodb", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.MongoDbConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The path to the file that will be [...]
"databaseIncludeList": { "kind": "property", "displayName": "Database 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 that [...]
"eventProcessingFailureHandlingMode": { "kind": "property", "displayName": "Event Processing Failure Handling Mode", "group": "mongodb", "label": "consumer,mongodb", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "fail", "configurationClass": "org.apache.camel.component.debezium.configuration.MongoDbConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "descriptio [...]
"fieldExcludeList": { "kind": "property", "displayName": "Field 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 the fully-qualified names of fi [...]
- "fieldRenames": { "kind": "property", "displayName": "Field Renames", "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": "Description is not available here, please check Debezium website f [...]
+ "fieldRenames": { "kind": "property", "displayName": "Field Renames", "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 the fully-qualified replacements of fiel [...]
"heartbeatIntervalMs": { "kind": "property", "displayName": "Heartbeat Interval Ms", "group": "mongodb", "label": "consumer,mongodb", "required": false, "type": "duration", "javaType": "int", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "0ms", "configurationClass": "org.apache.camel.component.debezium.configuration.MongoDbConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Length of an interval in milli-seconds [...]
"heartbeatTopicsPrefix": { "kind": "property", "displayName": "Heartbeat Topics Prefix", "group": "mongodb", "label": "consumer,mongodb", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "__debezium-heartbeat", "configurationClass": "org.apache.camel.component.debezium.configuration.MongoDbConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The pre [...]
"maxBatchSize": { "kind": "property", "displayName": "Max Batch Size", "group": "mongodb", "label": "consumer,mongodb", "required": false, "type": "integer", "javaType": "int", "deprecated": false, "autowired": false, "secret": false, "defaultValue": 2048, "configurationClass": "org.apache.camel.component.debezium.configuration.MongoDbConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Maximum size of each batch of source records. Defaults [...]
@@ -103,12 +104,13 @@
"connectBackoffMaxDelayMs": { "kind": "parameter", "displayName": "Connect Backoff Max Delay Ms", "group": "mongodb", "label": "consumer,mongodb", "required": false, "type": "duration", "javaType": "long", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "2m", "configurationClass": "org.apache.camel.component.debezium.configuration.MongoDbConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The maximum delay when try [...]
"connectMaxAttempts": { "kind": "parameter", "displayName": "Connect Max Attempts", "group": "mongodb", "label": "consumer,mongodb", "required": false, "type": "integer", "javaType": "int", "deprecated": false, "autowired": false, "secret": false, "defaultValue": 16, "configurationClass": "org.apache.camel.component.debezium.configuration.MongoDbConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Maximum number of failed connection attempts [...]
"converters": { "kind": "parameter", "displayName": "Converters", "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": "Optional list of custom converters that would be used instead of defau [...]
+ "cursorMaxAwaitTimeMs": { "kind": "parameter", "displayName": "Cursor Max Await Time Ms", "group": "mongodb", "label": "consumer,mongodb", "required": false, "type": "duration", "javaType": "int", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.MongoDbConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The maximum processing time in milliseconds to wait for t [...]
"databaseExcludeList": { "kind": "parameter", "displayName": "Database 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 that [...]
"databaseHistoryFileFilename": { "kind": "parameter", "displayName": "Database History File Filename", "group": "mongodb", "label": "consumer,mongodb", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.MongoDbConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The path to the file that will be [...]
"databaseIncludeList": { "kind": "parameter", "displayName": "Database 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 that [...]
"eventProcessingFailureHandlingMode": { "kind": "parameter", "displayName": "Event Processing Failure Handling Mode", "group": "mongodb", "label": "consumer,mongodb", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "fail", "configurationClass": "org.apache.camel.component.debezium.configuration.MongoDbConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "descripti [...]
"fieldExcludeList": { "kind": "parameter", "displayName": "Field 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 the fully-qualified names of f [...]
- "fieldRenames": { "kind": "parameter", "displayName": "Field Renames", "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": "Description is not available here, please check Debezium website [...]
+ "fieldRenames": { "kind": "parameter", "displayName": "Field Renames", "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 the fully-qualified replacements of fie [...]
"heartbeatIntervalMs": { "kind": "parameter", "displayName": "Heartbeat Interval Ms", "group": "mongodb", "label": "consumer,mongodb", "required": false, "type": "duration", "javaType": "int", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "0ms", "configurationClass": "org.apache.camel.component.debezium.configuration.MongoDbConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Length of an interval in milli-seconds [...]
"heartbeatTopicsPrefix": { "kind": "parameter", "displayName": "Heartbeat Topics Prefix", "group": "mongodb", "label": "consumer,mongodb", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "__debezium-heartbeat", "configurationClass": "org.apache.camel.component.debezium.configuration.MongoDbConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The pr [...]
"maxBatchSize": { "kind": "parameter", "displayName": "Max Batch Size", "group": "mongodb", "label": "consumer,mongodb", "required": false, "type": "integer", "javaType": "int", "deprecated": false, "autowired": false, "secret": false, "defaultValue": 2048, "configurationClass": "org.apache.camel.component.debezium.configuration.MongoDbConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Maximum size of each batch of source records. Defaults [...]
diff --git a/components/camel-debezium/camel-debezium-mysql/src/generated/java/org/apache/camel/component/debezium/DebeziumMySqlComponentConfigurer.java b/components/camel-debezium/camel-debezium-mysql/src/generated/java/org/apache/camel/component/debezium/DebeziumMySqlComponentConfigurer.java
index 33cc5c5..bec0871 100644
--- a/components/camel-debezium/camel-debezium-mysql/src/generated/java/org/apache/camel/component/debezium/DebeziumMySqlComponentConfigurer.java
+++ b/components/camel-debezium/camel-debezium-mysql/src/generated/java/org/apache/camel/component/debezium/DebeziumMySqlComponentConfigurer.java
@@ -34,6 +34,8 @@ public class DebeziumMySqlComponentConfigurer extends PropertyConfigurerSupport
case "autowiredEnabled": target.setAutowiredEnabled(property(camelContext, boolean.class, value)); return true;
case "bigintunsignedhandlingmode":
case "bigintUnsignedHandlingMode": getOrCreateConfiguration(target).setBigintUnsignedHandlingMode(property(camelContext, java.lang.String.class, value)); return true;
+ case "binaryhandlingmode":
+ case "binaryHandlingMode": getOrCreateConfiguration(target).setBinaryHandlingMode(property(camelContext, java.lang.String.class, value)); return true;
case "binlogbuffersize":
case "binlogBufferSize": getOrCreateConfiguration(target).setBinlogBufferSize(property(camelContext, int.class, value)); return true;
case "bridgeerrorhandler":
@@ -146,6 +148,8 @@ public class DebeziumMySqlComponentConfigurer extends PropertyConfigurerSupport
case "maxQueueSizeInBytes": getOrCreateConfiguration(target).setMaxQueueSizeInBytes(property(camelContext, long.class, value)); return true;
case "messagekeycolumns":
case "messageKeyColumns": getOrCreateConfiguration(target).setMessageKeyColumns(property(camelContext, java.lang.String.class, value)); return true;
+ case "minrowcounttostreamresults":
+ case "minRowCountToStreamResults": getOrCreateConfiguration(target).setMinRowCountToStreamResults(property(camelContext, int.class, value)); return true;
case "offsetcommitpolicy":
case "offsetCommitPolicy": getOrCreateConfiguration(target).setOffsetCommitPolicy(property(camelContext, java.lang.String.class, value)); return true;
case "offsetcommittimeoutms":
@@ -223,6 +227,8 @@ public class DebeziumMySqlComponentConfigurer extends PropertyConfigurerSupport
case "autowiredEnabled": return boolean.class;
case "bigintunsignedhandlingmode":
case "bigintUnsignedHandlingMode": return java.lang.String.class;
+ case "binaryhandlingmode":
+ case "binaryHandlingMode": return java.lang.String.class;
case "binlogbuffersize":
case "binlogBufferSize": return int.class;
case "bridgeerrorhandler":
@@ -335,6 +341,8 @@ public class DebeziumMySqlComponentConfigurer extends PropertyConfigurerSupport
case "maxQueueSizeInBytes": return long.class;
case "messagekeycolumns":
case "messageKeyColumns": return java.lang.String.class;
+ case "minrowcounttostreamresults":
+ case "minRowCountToStreamResults": return int.class;
case "offsetcommitpolicy":
case "offsetCommitPolicy": return java.lang.String.class;
case "offsetcommittimeoutms":
@@ -413,6 +421,8 @@ public class DebeziumMySqlComponentConfigurer extends PropertyConfigurerSupport
case "autowiredEnabled": return target.isAutowiredEnabled();
case "bigintunsignedhandlingmode":
case "bigintUnsignedHandlingMode": return getOrCreateConfiguration(target).getBigintUnsignedHandlingMode();
+ case "binaryhandlingmode":
+ case "binaryHandlingMode": return getOrCreateConfiguration(target).getBinaryHandlingMode();
case "binlogbuffersize":
case "binlogBufferSize": return getOrCreateConfiguration(target).getBinlogBufferSize();
case "bridgeerrorhandler":
@@ -525,6 +535,8 @@ public class DebeziumMySqlComponentConfigurer extends PropertyConfigurerSupport
case "maxQueueSizeInBytes": return getOrCreateConfiguration(target).getMaxQueueSizeInBytes();
case "messagekeycolumns":
case "messageKeyColumns": return getOrCreateConfiguration(target).getMessageKeyColumns();
+ case "minrowcounttostreamresults":
+ case "minRowCountToStreamResults": return getOrCreateConfiguration(target).getMinRowCountToStreamResults();
case "offsetcommitpolicy":
case "offsetCommitPolicy": return getOrCreateConfiguration(target).getOffsetCommitPolicy();
case "offsetcommittimeoutms":
diff --git a/components/camel-debezium/camel-debezium-mysql/src/generated/java/org/apache/camel/component/debezium/DebeziumMySqlEndpointConfigurer.java b/components/camel-debezium/camel-debezium-mysql/src/generated/java/org/apache/camel/component/debezium/DebeziumMySqlEndpointConfigurer.java
index 55ef158..a4fb85f 100644
--- a/components/camel-debezium/camel-debezium-mysql/src/generated/java/org/apache/camel/component/debezium/DebeziumMySqlEndpointConfigurer.java
+++ b/components/camel-debezium/camel-debezium-mysql/src/generated/java/org/apache/camel/component/debezium/DebeziumMySqlEndpointConfigurer.java
@@ -25,6 +25,8 @@ public class DebeziumMySqlEndpointConfigurer extends PropertyConfigurerSupport i
case "additionalProperties": target.getConfiguration().setAdditionalProperties(property(camelContext, java.util.Map.class, value)); return true;
case "bigintunsignedhandlingmode":
case "bigintUnsignedHandlingMode": target.getConfiguration().setBigintUnsignedHandlingMode(property(camelContext, java.lang.String.class, value)); return true;
+ case "binaryhandlingmode":
+ case "binaryHandlingMode": target.getConfiguration().setBinaryHandlingMode(property(camelContext, java.lang.String.class, value)); return true;
case "binlogbuffersize":
case "binlogBufferSize": target.getConfiguration().setBinlogBufferSize(property(camelContext, int.class, value)); return true;
case "bridgeerrorhandler":
@@ -140,6 +142,8 @@ public class DebeziumMySqlEndpointConfigurer extends PropertyConfigurerSupport i
case "maxQueueSizeInBytes": target.getConfiguration().setMaxQueueSizeInBytes(property(camelContext, long.class, value)); return true;
case "messagekeycolumns":
case "messageKeyColumns": target.getConfiguration().setMessageKeyColumns(property(camelContext, java.lang.String.class, value)); return true;
+ case "minrowcounttostreamresults":
+ case "minRowCountToStreamResults": target.getConfiguration().setMinRowCountToStreamResults(property(camelContext, int.class, value)); return true;
case "offsetcommitpolicy":
case "offsetCommitPolicy": target.getConfiguration().setOffsetCommitPolicy(property(camelContext, java.lang.String.class, value)); return true;
case "offsetcommittimeoutms":
@@ -215,6 +219,8 @@ public class DebeziumMySqlEndpointConfigurer extends PropertyConfigurerSupport i
case "additionalProperties": return java.util.Map.class;
case "bigintunsignedhandlingmode":
case "bigintUnsignedHandlingMode": return java.lang.String.class;
+ case "binaryhandlingmode":
+ case "binaryHandlingMode": return java.lang.String.class;
case "binlogbuffersize":
case "binlogBufferSize": return int.class;
case "bridgeerrorhandler":
@@ -330,6 +336,8 @@ public class DebeziumMySqlEndpointConfigurer extends PropertyConfigurerSupport i
case "maxQueueSizeInBytes": return long.class;
case "messagekeycolumns":
case "messageKeyColumns": return java.lang.String.class;
+ case "minrowcounttostreamresults":
+ case "minRowCountToStreamResults": return int.class;
case "offsetcommitpolicy":
case "offsetCommitPolicy": return java.lang.String.class;
case "offsetcommittimeoutms":
@@ -406,6 +414,8 @@ public class DebeziumMySqlEndpointConfigurer extends PropertyConfigurerSupport i
case "additionalProperties": return target.getConfiguration().getAdditionalProperties();
case "bigintunsignedhandlingmode":
case "bigintUnsignedHandlingMode": return target.getConfiguration().getBigintUnsignedHandlingMode();
+ case "binaryhandlingmode":
+ case "binaryHandlingMode": return target.getConfiguration().getBinaryHandlingMode();
case "binlogbuffersize":
case "binlogBufferSize": return target.getConfiguration().getBinlogBufferSize();
case "bridgeerrorhandler":
@@ -521,6 +531,8 @@ public class DebeziumMySqlEndpointConfigurer extends PropertyConfigurerSupport i
case "maxQueueSizeInBytes": return target.getConfiguration().getMaxQueueSizeInBytes();
case "messagekeycolumns":
case "messageKeyColumns": return target.getConfiguration().getMessageKeyColumns();
+ case "minrowcounttostreamresults":
+ case "minRowCountToStreamResults": return target.getConfiguration().getMinRowCountToStreamResults();
case "offsetcommitpolicy":
case "offsetCommitPolicy": return target.getConfiguration().getOffsetCommitPolicy();
case "offsetcommittimeoutms":
diff --git a/components/camel-debezium/camel-debezium-mysql/src/generated/java/org/apache/camel/component/debezium/DebeziumMySqlEndpointUriFactory.java b/components/camel-debezium/camel-debezium-mysql/src/generated/java/org/apache/camel/component/debezium/DebeziumMySqlEndpointUriFactory.java
index 78cfe10..e8aea73 100644
--- a/components/camel-debezium/camel-debezium-mysql/src/generated/java/org/apache/camel/component/debezium/DebeziumMySqlEndpointUriFactory.java
+++ b/components/camel-debezium/camel-debezium-mysql/src/generated/java/org/apache/camel/component/debezium/DebeziumMySqlEndpointUriFactory.java
@@ -20,7 +20,7 @@ public class DebeziumMySqlEndpointUriFactory extends org.apache.camel.support.co
private static final Set<String> PROPERTY_NAMES;
private static final Set<String> SECRET_PROPERTY_NAMES;
static {
- Set<String> props = new HashSet<>(93);
+ Set<String> props = new HashSet<>(95);
props.add("databaseJdbcDriver");
props.add("maxBatchSize");
props.add("internalKeyConverter");
@@ -42,6 +42,7 @@ public class DebeziumMySqlEndpointUriFactory extends org.apache.camel.support.co
props.add("decimalHandlingMode");
props.add("skippedOperations");
props.add("sourceStructVersion");
+ props.add("binaryHandlingMode");
props.add("bigintUnsignedHandlingMode");
props.add("databaseHostname");
props.add("databaseHistorySkipUnparseableDdl");
@@ -52,6 +53,7 @@ public class DebeziumMySqlEndpointUriFactory extends org.apache.camel.support.co
props.add("snapshotSelectStatementOverrides");
props.add("databaseIncludeList");
props.add("gtidSourceFilterDmlEvents");
+ props.add("minRowCountToStreamResults");
props.add("offsetFlushIntervalMs");
props.add("offsetStorageFileName");
props.add("columnBlacklist");
diff --git a/components/camel-debezium/camel-debezium-mysql/src/generated/java/org/apache/camel/component/debezium/configuration/MySqlConnectorEmbeddedDebeziumConfiguration.java b/components/camel-debezium/camel-debezium-mysql/src/generated/java/org/apache/camel/component/debezium/configuration/MySqlConnectorEmbeddedDebeziumConfiguration.java
index d20b561..bdee5c9 100644
--- a/components/camel-debezium/camel-debezium-mysql/src/generated/java/org/apache/camel/component/debezium/configuration/MySqlConnectorEmbeddedDebeziumConfiguration.java
+++ b/components/camel-debezium/camel-debezium-mysql/src/generated/java/org/apache/camel/component/debezium/configuration/MySqlConnectorEmbeddedDebeziumConfiguration.java
@@ -78,6 +78,8 @@ public class MySqlConnectorEmbeddedDebeziumConfiguration
private String columnPropagateSourceType;
@UriParam(label = LABEL_NAME, defaultValue = "fail")
private String inconsistentSchemaHandlingMode = "fail";
+ @UriParam(label = LABEL_NAME, defaultValue = "1000")
+ private int minRowCountToStreamResults = 1000;
@UriParam(label = LABEL_NAME)
private String tableExcludeList;
@UriParam(label = LABEL_NAME)
@@ -121,6 +123,8 @@ public class MySqlConnectorEmbeddedDebeziumConfiguration
private boolean tombstonesOnDelete = false;
@UriParam(label = LABEL_NAME, defaultValue = "precise")
private String decimalHandlingMode = "precise";
+ @UriParam(label = LABEL_NAME, defaultValue = "bytes")
+ private String binaryHandlingMode = "bytes";
@UriParam(label = LABEL_NAME, defaultValue = "off")
private String snapshotNewTables = "off";
@UriParam(label = LABEL_NAME, defaultValue = "false")
@@ -631,6 +635,19 @@ public class MySqlConnectorEmbeddedDebeziumConfiguration
}
/**
+ * The number of rows a table must contain to stream results rather than
+ * pull all into memory during snapshots. Defaults to 1,000. Use 0 to stream
+ * all results and completely avoid checking the size of each table.
+ */
+ public void setMinRowCountToStreamResults(int minRowCountToStreamResults) {
+ this.minRowCountToStreamResults = minRowCountToStreamResults;
+ }
+
+ public int getMinRowCountToStreamResults() {
+ return minRowCountToStreamResults;
+ }
+
+ /**
* A comma-separated list of regular expressions that match the
* fully-qualified names of tables to be excluded from monitoring
*/
@@ -908,6 +925,20 @@ public class MySqlConnectorEmbeddedDebeziumConfiguration
}
/**
+ * Specify how binary (blob, binary, etc.) columns should be represented in
+ * change events, including:'bytes' represents binary data as byte array
+ * (default)'base64' represents binary data as base64-encoded string'hex'
+ * represents binary data as hex-encoded (base16) string
+ */
+ public void setBinaryHandlingMode(String binaryHandlingMode) {
+ this.binaryHandlingMode = binaryHandlingMode;
+ }
+
+ public String getBinaryHandlingMode() {
+ return binaryHandlingMode;
+ }
+
+ /**
* BETA FEATURE: On connector restart, the connector will check if there
* have been any new tables added to the configuration, and snapshot them.
* There is presently only two options:'off': Default behavior. Do not
@@ -1285,6 +1316,7 @@ public class MySqlConnectorEmbeddedDebeziumConfiguration
addPropertyIfNotNull(configBuilder, "enable.time.adjuster", enableTimeAdjuster);
addPropertyIfNotNull(configBuilder, "column.propagate.source.type", columnPropagateSourceType);
addPropertyIfNotNull(configBuilder, "inconsistent.schema.handling.mode", inconsistentSchemaHandlingMode);
+ addPropertyIfNotNull(configBuilder, "min.row.count.to.stream.results", minRowCountToStreamResults);
addPropertyIfNotNull(configBuilder, "table.exclude.list", tableExcludeList);
addPropertyIfNotNull(configBuilder, "database.password", databasePassword);
addPropertyIfNotNull(configBuilder, "database.exclude.list", databaseExcludeList);
@@ -1306,6 +1338,7 @@ public class MySqlConnectorEmbeddedDebeziumConfiguration
addPropertyIfNotNull(configBuilder, "table.whitelist", tableWhitelist);
addPropertyIfNotNull(configBuilder, "tombstones.on.delete", tombstonesOnDelete);
addPropertyIfNotNull(configBuilder, "decimal.handling.mode", decimalHandlingMode);
+ addPropertyIfNotNull(configBuilder, "binary.handling.mode", binaryHandlingMode);
addPropertyIfNotNull(configBuilder, "snapshot.new.tables", snapshotNewTables);
addPropertyIfNotNull(configBuilder, "database.history.skip.unparseable.ddl", databaseHistorySkipUnparseableDdl);
addPropertyIfNotNull(configBuilder, "table.ignore.builtin", tableIgnoreBuiltin);
diff --git a/components/camel-debezium/camel-debezium-mysql/src/generated/resources/org/apache/camel/component/debezium/debezium-mysql.json b/components/camel-debezium/camel-debezium-mysql/src/generated/resources/org/apache/camel/component/debezium/debezium-mysql.json
index 31108f2..b6b9ce7 100644
--- a/components/camel-debezium/camel-debezium-mysql/src/generated/resources/org/apache/camel/component/debezium/debezium-mysql.json
+++ b/components/camel-debezium/camel-debezium-mysql/src/generated/resources/org/apache/camel/component/debezium/debezium-mysql.json
@@ -37,6 +37,7 @@
"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.MySqlConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The name of the Kafka topic where offsets are to be stored. Re [...]
"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 [...]
"bigintUnsignedHandlingMode": { "kind": "property", "displayName": "Bigint Unsigned Handling Mode", "group": "mysql", "label": "consumer,mysql", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "long", "configurationClass": "org.apache.camel.component.debezium.configuration.MySqlConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Specify how BIGINT [...]
+ "binaryHandlingMode": { "kind": "property", "displayName": "Binary Handling Mode", "group": "mysql", "label": "consumer,mysql", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "bytes", "configurationClass": "org.apache.camel.component.debezium.configuration.MySqlConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Specify how binary (blob, binary, [...]
"binlogBufferSize": { "kind": "property", "displayName": "Binlog Buffer Size", "group": "mysql", "label": "consumer,mysql", "required": false, "type": "integer", "javaType": "int", "deprecated": false, "autowired": false, "secret": false, "defaultValue": 0, "configurationClass": "org.apache.camel.component.debezium.configuration.MySqlConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The size of a look-ahead buffer used by the binlog reade [...]
"columnBlacklist": { "kind": "property", "displayName": "Column Blacklist", "group": "mysql", "label": "consumer,mysql", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.MySqlConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Regular expressions matching columns to exclude from change events [...]
"columnExcludeList": { "kind": "property", "displayName": "Column Exclude List", "group": "mysql", "label": "consumer,mysql", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.MySqlConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Regular expressions matching columns to exclude from change e [...]
@@ -90,6 +91,7 @@
"maxQueueSize": { "kind": "property", "displayName": "Max Queue Size", "group": "mysql", "label": "consumer,mysql", "required": false, "type": "integer", "javaType": "int", "deprecated": false, "autowired": false, "secret": false, "defaultValue": 8192, "configurationClass": "org.apache.camel.component.debezium.configuration.MySqlConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Maximum size of the queue for change events read from the dat [...]
"maxQueueSizeInBytes": { "kind": "property", "displayName": "Max Queue Size In Bytes", "group": "mysql", "label": "consumer,mysql", "required": false, "type": "integer", "javaType": "long", "deprecated": false, "autowired": false, "secret": false, "defaultValue": 0, "configurationClass": "org.apache.camel.component.debezium.configuration.MySqlConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Maximum size of the queue in bytes for change e [...]
"messageKeyColumns": { "kind": "property", "displayName": "Message Key Columns", "group": "mysql", "label": "consumer,mysql", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.MySqlConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "A semicolon-separated list of expressions that match fully-qu [...]
+ "minRowCountToStreamResults": { "kind": "property", "displayName": "Min Row Count To Stream Results", "group": "mysql", "label": "consumer,mysql", "required": false, "type": "integer", "javaType": "int", "deprecated": false, "autowired": false, "secret": false, "defaultValue": 1000, "configurationClass": "org.apache.camel.component.debezium.configuration.MySqlConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The number of rows a table mus [...]
"pollIntervalMs": { "kind": "property", "displayName": "Poll Interval Ms", "group": "mysql", "label": "consumer,mysql", "required": false, "type": "duration", "javaType": "long", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "500ms", "configurationClass": "org.apache.camel.component.debezium.configuration.MySqlConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Time to wait for new change events to appear after r [...]
"provideTransactionMetadata": { "kind": "property", "displayName": "Provide Transaction Metadata", "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": "Enables transaction metadata [...]
"queryFetchSize": { "kind": "property", "displayName": "Query Fetch Size", "group": "mysql", "label": "consumer,mysql", "required": false, "type": "integer", "javaType": "int", "deprecated": false, "autowired": false, "secret": false, "defaultValue": 0, "configurationClass": "org.apache.camel.component.debezium.configuration.MySqlConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The maximum number of records that should be loaded into mem [...]
@@ -132,6 +134,7 @@
"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." },
"bigintUnsignedHandlingMode": { "kind": "parameter", "displayName": "Bigint Unsigned Handling Mode", "group": "mysql", "label": "consumer,mysql", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "long", "configurationClass": "org.apache.camel.component.debezium.configuration.MySqlConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Specify how BIGIN [...]
+ "binaryHandlingMode": { "kind": "parameter", "displayName": "Binary Handling Mode", "group": "mysql", "label": "consumer,mysql", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "bytes", "configurationClass": "org.apache.camel.component.debezium.configuration.MySqlConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Specify how binary (blob, binary, [...]
"binlogBufferSize": { "kind": "parameter", "displayName": "Binlog Buffer Size", "group": "mysql", "label": "consumer,mysql", "required": false, "type": "integer", "javaType": "int", "deprecated": false, "autowired": false, "secret": false, "defaultValue": 0, "configurationClass": "org.apache.camel.component.debezium.configuration.MySqlConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The size of a look-ahead buffer used by the binlog read [...]
"columnBlacklist": { "kind": "parameter", "displayName": "Column Blacklist", "group": "mysql", "label": "consumer,mysql", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.MySqlConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Regular expressions matching columns to exclude from change event [...]
"columnExcludeList": { "kind": "parameter", "displayName": "Column Exclude List", "group": "mysql", "label": "consumer,mysql", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.MySqlConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Regular expressions matching columns to exclude from change [...]
@@ -185,6 +188,7 @@
"maxQueueSize": { "kind": "parameter", "displayName": "Max Queue Size", "group": "mysql", "label": "consumer,mysql", "required": false, "type": "integer", "javaType": "int", "deprecated": false, "autowired": false, "secret": false, "defaultValue": 8192, "configurationClass": "org.apache.camel.component.debezium.configuration.MySqlConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Maximum size of the queue for change events read from the da [...]
"maxQueueSizeInBytes": { "kind": "parameter", "displayName": "Max Queue Size In Bytes", "group": "mysql", "label": "consumer,mysql", "required": false, "type": "integer", "javaType": "long", "deprecated": false, "autowired": false, "secret": false, "defaultValue": 0, "configurationClass": "org.apache.camel.component.debezium.configuration.MySqlConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Maximum size of the queue in bytes for change [...]
"messageKeyColumns": { "kind": "parameter", "displayName": "Message Key Columns", "group": "mysql", "label": "consumer,mysql", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.MySqlConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "A semicolon-separated list of expressions that match fully-q [...]
+ "minRowCountToStreamResults": { "kind": "parameter", "displayName": "Min Row Count To Stream Results", "group": "mysql", "label": "consumer,mysql", "required": false, "type": "integer", "javaType": "int", "deprecated": false, "autowired": false, "secret": false, "defaultValue": 1000, "configurationClass": "org.apache.camel.component.debezium.configuration.MySqlConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The number of rows a table mu [...]
"pollIntervalMs": { "kind": "parameter", "displayName": "Poll Interval Ms", "group": "mysql", "label": "consumer,mysql", "required": false, "type": "duration", "javaType": "long", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "500ms", "configurationClass": "org.apache.camel.component.debezium.configuration.MySqlConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Time to wait for new change events to appear after [...]
"provideTransactionMetadata": { "kind": "parameter", "displayName": "Provide Transaction Metadata", "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": "Enables transaction metadat [...]
"queryFetchSize": { "kind": "parameter", "displayName": "Query Fetch Size", "group": "mysql", "label": "consumer,mysql", "required": false, "type": "integer", "javaType": "int", "deprecated": false, "autowired": false, "secret": false, "defaultValue": 0, "configurationClass": "org.apache.camel.component.debezium.configuration.MySqlConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The maximum number of records that should be loaded into me [...]
diff --git a/components/camel-debezium/camel-debezium-postgres/src/generated/java/org/apache/camel/component/debezium/DebeziumPostgresComponentConfigurer.java b/components/camel-debezium/camel-debezium-postgres/src/generated/java/org/apache/camel/component/debezium/DebeziumPostgresComponentConfigurer.java
index 5933498..deebfe0 100644
--- a/components/camel-debezium/camel-debezium-postgres/src/generated/java/org/apache/camel/component/debezium/DebeziumPostgresComponentConfigurer.java
+++ b/components/camel-debezium/camel-debezium-postgres/src/generated/java/org/apache/camel/component/debezium/DebeziumPostgresComponentConfigurer.java
@@ -202,6 +202,8 @@ public class DebeziumPostgresComponentConfigurer extends PropertyConfigurerSuppo
case "toastedValuePlaceholder": getOrCreateConfiguration(target).setToastedValuePlaceholder(property(camelContext, java.lang.String.class, value)); return true;
case "tombstonesondelete":
case "tombstonesOnDelete": getOrCreateConfiguration(target).setTombstonesOnDelete(property(camelContext, boolean.class, value)); return true;
+ case "truncatehandlingmode":
+ case "truncateHandlingMode": getOrCreateConfiguration(target).setTruncateHandlingMode(property(camelContext, java.lang.String.class, value)); return true;
case "xminfetchintervalms":
case "xminFetchIntervalMs": getOrCreateConfiguration(target).setXminFetchIntervalMs(property(camelContext, java.time.Duration.class, value).toMillis()); return true;
default: return false;
@@ -385,6 +387,8 @@ public class DebeziumPostgresComponentConfigurer extends PropertyConfigurerSuppo
case "toastedValuePlaceholder": return java.lang.String.class;
case "tombstonesondelete":
case "tombstonesOnDelete": return boolean.class;
+ case "truncatehandlingmode":
+ case "truncateHandlingMode": return java.lang.String.class;
case "xminfetchintervalms":
case "xminFetchIntervalMs": return long.class;
default: return null;
@@ -569,6 +573,8 @@ public class DebeziumPostgresComponentConfigurer extends PropertyConfigurerSuppo
case "toastedValuePlaceholder": return getOrCreateConfiguration(target).getToastedValuePlaceholder();
case "tombstonesondelete":
case "tombstonesOnDelete": return getOrCreateConfiguration(target).isTombstonesOnDelete();
+ case "truncatehandlingmode":
+ case "truncateHandlingMode": return getOrCreateConfiguration(target).getTruncateHandlingMode();
case "xminfetchintervalms":
case "xminFetchIntervalMs": return getOrCreateConfiguration(target).getXminFetchIntervalMs();
default: return null;
diff --git a/components/camel-debezium/camel-debezium-postgres/src/generated/java/org/apache/camel/component/debezium/DebeziumPostgresEndpointConfigurer.java b/components/camel-debezium/camel-debezium-postgres/src/generated/java/org/apache/camel/component/debezium/DebeziumPostgresEndpointConfigurer.java
index 34fa1e9..27ad563 100644
--- a/components/camel-debezium/camel-debezium-postgres/src/generated/java/org/apache/camel/component/debezium/DebeziumPostgresEndpointConfigurer.java
+++ b/components/camel-debezium/camel-debezium-postgres/src/generated/java/org/apache/camel/component/debezium/DebeziumPostgresEndpointConfigurer.java
@@ -196,6 +196,8 @@ public class DebeziumPostgresEndpointConfigurer extends PropertyConfigurerSuppor
case "toastedValuePlaceholder": target.getConfiguration().setToastedValuePlaceholder(property(camelContext, java.lang.String.class, value)); return true;
case "tombstonesondelete":
case "tombstonesOnDelete": target.getConfiguration().setTombstonesOnDelete(property(camelContext, boolean.class, value)); return true;
+ case "truncatehandlingmode":
+ case "truncateHandlingMode": target.getConfiguration().setTruncateHandlingMode(property(camelContext, java.lang.String.class, value)); return true;
case "xminfetchintervalms":
case "xminFetchIntervalMs": target.getConfiguration().setXminFetchIntervalMs(property(camelContext, java.time.Duration.class, value).toMillis()); return true;
default: return false;
@@ -380,6 +382,8 @@ public class DebeziumPostgresEndpointConfigurer extends PropertyConfigurerSuppor
case "toastedValuePlaceholder": return java.lang.String.class;
case "tombstonesondelete":
case "tombstonesOnDelete": return boolean.class;
+ case "truncatehandlingmode":
+ case "truncateHandlingMode": return java.lang.String.class;
case "xminfetchintervalms":
case "xminFetchIntervalMs": return long.class;
default: return null;
@@ -565,6 +569,8 @@ public class DebeziumPostgresEndpointConfigurer extends PropertyConfigurerSuppor
case "toastedValuePlaceholder": return target.getConfiguration().getToastedValuePlaceholder();
case "tombstonesondelete":
case "tombstonesOnDelete": return target.getConfiguration().isTombstonesOnDelete();
+ case "truncatehandlingmode":
+ case "truncateHandlingMode": return target.getConfiguration().getTruncateHandlingMode();
case "xminfetchintervalms":
case "xminFetchIntervalMs": return target.getConfiguration().getXminFetchIntervalMs();
default: return null;
diff --git a/components/camel-debezium/camel-debezium-postgres/src/generated/java/org/apache/camel/component/debezium/DebeziumPostgresEndpointUriFactory.java b/components/camel-debezium/camel-debezium-postgres/src/generated/java/org/apache/camel/component/debezium/DebeziumPostgresEndpointUriFactory.java
index 8e28e7a..073c932 100644
--- a/components/camel-debezium/camel-debezium-postgres/src/generated/java/org/apache/camel/component/debezium/DebeziumPostgresEndpointUriFactory.java
+++ b/components/camel-debezium/camel-debezium-postgres/src/generated/java/org/apache/camel/component/debezium/DebeziumPostgresEndpointUriFactory.java
@@ -20,7 +20,7 @@ public class DebeziumPostgresEndpointUriFactory extends org.apache.camel.support
private static final Set<String> PROPERTY_NAMES;
private static final Set<String> SECRET_PROPERTY_NAMES;
static {
- Set<String> props = new HashSet<>(90);
+ Set<String> props = new HashSet<>(91);
props.add("slotDropOnStop");
props.add("includeUnknownDatatypes");
props.add("maxBatchSize");
@@ -84,6 +84,7 @@ public class DebeziumPostgresEndpointUriFactory extends org.apache.camel.support
props.add("maxQueueSize");
props.add("messageKeyColumns");
props.add("timePrecisionMode");
+ props.add("truncateHandlingMode");
props.add("columnWhitelist");
props.add("pollIntervalMs");
props.add("sanitizeFieldNames");
diff --git a/components/camel-debezium/camel-debezium-postgres/src/generated/java/org/apache/camel/component/debezium/configuration/PostgresConnectorEmbeddedDebeziumConfiguration.java b/components/camel-debezium/camel-debezium-postgres/src/generated/java/org/apache/camel/component/debezium/configuration/PostgresConnectorEmbeddedDebeziumConfiguration.java
index 16c565a..d43ff91 100644
--- a/components/camel-debezium/camel-debezium-postgres/src/generated/java/org/apache/camel/component/debezium/configuration/PostgresConnectorEmbeddedDebeziumConfiguration.java
+++ b/components/camel-debezium/camel-debezium-postgres/src/generated/java/org/apache/camel/component/debezium/configuration/PostgresConnectorEmbeddedDebeziumConfiguration.java
@@ -125,6 +125,8 @@ public class PostgresConnectorEmbeddedDebeziumConfiguration
private String decimalHandlingMode = "precise";
@UriParam(label = LABEL_NAME, defaultValue = "bytes")
private String binaryHandlingMode = "bytes";
+ @UriParam(label = LABEL_NAME, defaultValue = "skip")
+ private String truncateHandlingMode = "skip";
@UriParam(label = LABEL_NAME, defaultValue = "true")
private boolean tableIgnoreBuiltin = true;
@UriParam(label = LABEL_NAME, defaultValue = "true")
@@ -471,7 +473,7 @@ public class PostgresConnectorEmbeddedDebeziumConfiguration
}
/**
- * The name of the database the connector should be monitoring
+ * The name of the database from which the connector should capture changes
*/
public void setDatabaseDbname(String databaseDbname) {
this.databaseDbname = databaseDbname;
@@ -909,6 +911,20 @@ public class PostgresConnectorEmbeddedDebeziumConfiguration
}
/**
+ * Specify how TRUNCATE operations are handled for change events (supported
+ * only on pg11+ pgoutput plugin), including: 'skip' to skip / ignore
+ * TRUNCATE events (default), 'include' to handle and include TRUNCATE
+ * events
+ */
+ public void setTruncateHandlingMode(String truncateHandlingMode) {
+ this.truncateHandlingMode = truncateHandlingMode;
+ }
+
+ public String getTruncateHandlingMode() {
+ return truncateHandlingMode;
+ }
+
+ /**
* Flag specifying whether built-in tables should be ignored.
*/
public void setTableIgnoreBuiltin(boolean tableIgnoreBuiltin) {
@@ -1223,6 +1239,7 @@ public class PostgresConnectorEmbeddedDebeziumConfiguration
addPropertyIfNotNull(configBuilder, "slot.retry.delay.ms", slotRetryDelayMs);
addPropertyIfNotNull(configBuilder, "decimal.handling.mode", decimalHandlingMode);
addPropertyIfNotNull(configBuilder, "binary.handling.mode", binaryHandlingMode);
+ addPropertyIfNotNull(configBuilder, "truncate.handling.mode", truncateHandlingMode);
addPropertyIfNotNull(configBuilder, "table.ignore.builtin", tableIgnoreBuiltin);
addPropertyIfNotNull(configBuilder, "database.tcpKeepAlive", databaseTcpkeepalive);
addPropertyIfNotNull(configBuilder, "schema.exclude.list", schemaExcludeList);
diff --git a/components/camel-debezium/camel-debezium-postgres/src/generated/resources/org/apache/camel/component/debezium/debezium-postgres.json b/components/camel-debezium/camel-debezium-postgres/src/generated/resources/org/apache/camel/component/debezium/debezium-postgres.json
index 39d7f4d..00da6df 100644
--- a/components/camel-debezium/camel-debezium-postgres/src/generated/resources/org/apache/camel/component/debezium/debezium-postgres.json
+++ b/components/camel-debezium/camel-debezium-postgres/src/generated/resources/org/apache/camel/component/debezium/debezium-postgres.json
@@ -43,7 +43,7 @@
"columnPropagateSourceType": { "kind": "property", "displayName": "Column Propagate Source Type", "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 e [...]
"columnWhitelist": { "kind": "property", "displayName": "Column 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": "Regular expressions matching columns to include in change [...]
"converters": { "kind": "property", "displayName": "Converters", "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": "Optional list of custom converters that would be used instead of def [...]
- "databaseDbname": { "kind": "property", "displayName": "Database Dbname", "group": "postgres", "label": "consumer,postgres", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.PostgresConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The name of the database the connector should be monitoring" },
+ "databaseDbname": { "kind": "property", "displayName": "Database Dbname", "group": "postgres", "label": "consumer,postgres", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.PostgresConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The name of the database from which the connector should ca [...]
"databaseHistoryFileFilename": { "kind": "property", "displayName": "Database History File Filename", "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 path to the file that will [...]
"databaseHostname": { "kind": "property", "displayName": "Database Hostname", "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": "Resolvable hostname or IP address of the database server." },
"databaseInitialStatements": { "kind": "property", "displayName": "Database Initial Statements", "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 SQL st [...]
@@ -110,6 +110,7 @@
"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 [...]
+ "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 [...]
"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": {
@@ -135,7 +136,7 @@
"columnPropagateSourceType": { "kind": "parameter", "displayName": "Column Propagate Source Type", "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 [...]
"columnWhitelist": { "kind": "parameter", "displayName": "Column 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": "Regular expressions matching columns to include in chang [...]
"converters": { "kind": "parameter", "displayName": "Converters", "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": "Optional list of custom converters that would be used instead of de [...]
- "databaseDbname": { "kind": "parameter", "displayName": "Database Dbname", "group": "postgres", "label": "consumer,postgres", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.PostgresConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The name of the database the connector should be monitoring" },
+ "databaseDbname": { "kind": "parameter", "displayName": "Database Dbname", "group": "postgres", "label": "consumer,postgres", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.PostgresConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The name of the database from which the connector should c [...]
"databaseHistoryFileFilename": { "kind": "parameter", "displayName": "Database History File Filename", "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 path to the file that will [...]
"databaseHostname": { "kind": "parameter", "displayName": "Database Hostname", "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": "Resolvable hostname or IP address of the database server." },
"databaseInitialStatements": { "kind": "parameter", "displayName": "Database Initial Statements", "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 SQL s [...]
@@ -202,6 +203,7 @@
"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 [...]
+ "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 [...]
"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/components/camel-debezium/camel-debezium-sqlserver/src/generated/java/org/apache/camel/component/debezium/DebeziumSqlserverComponentConfigurer.java b/components/camel-debezium/camel-debezium-sqlserver/src/generated/java/org/apache/camel/component/debezium/DebeziumSqlserverComponentConfigurer.java
index d9a7348..941c90d 100644
--- a/components/camel-debezium/camel-debezium-sqlserver/src/generated/java/org/apache/camel/component/debezium/DebeziumSqlserverComponentConfigurer.java
+++ b/components/camel-debezium/camel-debezium-sqlserver/src/generated/java/org/apache/camel/component/debezium/DebeziumSqlserverComponentConfigurer.java
@@ -72,14 +72,14 @@ public class DebeziumSqlserverComponentConfigurer extends PropertyConfigurerSupp
case "databaseHostname": getOrCreateConfiguration(target).setDatabaseHostname(property(camelContext, java.lang.String.class, value)); return true;
case "databaseinstance":
case "databaseInstance": getOrCreateConfiguration(target).setDatabaseInstance(property(camelContext, java.lang.String.class, value)); return true;
+ case "databasenames":
+ case "databaseNames": getOrCreateConfiguration(target).setDatabaseNames(property(camelContext, java.lang.String.class, value)); return true;
case "databasepassword":
case "databasePassword": getOrCreateConfiguration(target).setDatabasePassword(property(camelContext, java.lang.String.class, value)); return true;
case "databaseport":
case "databasePort": getOrCreateConfiguration(target).setDatabasePort(property(camelContext, int.class, value)); return true;
case "databaseservername":
case "databaseServerName": getOrCreateConfiguration(target).setDatabaseServerName(property(camelContext, java.lang.String.class, value)); return true;
- case "databaseservertimezone":
- case "databaseServerTimezone": getOrCreateConfiguration(target).setDatabaseServerTimezone(property(camelContext, java.lang.String.class, value)); return true;
case "databaseuser":
case "databaseUser": getOrCreateConfiguration(target).setDatabaseUser(property(camelContext, java.lang.String.class, value)); return true;
case "datatypepropagatesourcetype":
@@ -223,14 +223,14 @@ public class DebeziumSqlserverComponentConfigurer extends PropertyConfigurerSupp
case "databaseHostname": return java.lang.String.class;
case "databaseinstance":
case "databaseInstance": return java.lang.String.class;
+ case "databasenames":
+ case "databaseNames": return java.lang.String.class;
case "databasepassword":
case "databasePassword": return java.lang.String.class;
case "databaseport":
case "databasePort": return int.class;
case "databaseservername":
case "databaseServerName": return java.lang.String.class;
- case "databaseservertimezone":
- case "databaseServerTimezone": return java.lang.String.class;
case "databaseuser":
case "databaseUser": return java.lang.String.class;
case "datatypepropagatesourcetype":
@@ -375,14 +375,14 @@ public class DebeziumSqlserverComponentConfigurer extends PropertyConfigurerSupp
case "databaseHostname": return getOrCreateConfiguration(target).getDatabaseHostname();
case "databaseinstance":
case "databaseInstance": return getOrCreateConfiguration(target).getDatabaseInstance();
+ case "databasenames":
+ case "databaseNames": return getOrCreateConfiguration(target).getDatabaseNames();
case "databasepassword":
case "databasePassword": return getOrCreateConfiguration(target).getDatabasePassword();
case "databaseport":
case "databasePort": return getOrCreateConfiguration(target).getDatabasePort();
case "databaseservername":
case "databaseServerName": return getOrCreateConfiguration(target).getDatabaseServerName();
- case "databaseservertimezone":
- case "databaseServerTimezone": return getOrCreateConfiguration(target).getDatabaseServerTimezone();
case "databaseuser":
case "databaseUser": return getOrCreateConfiguration(target).getDatabaseUser();
case "datatypepropagatesourcetype":
diff --git a/components/camel-debezium/camel-debezium-sqlserver/src/generated/java/org/apache/camel/component/debezium/DebeziumSqlserverEndpointConfigurer.java b/components/camel-debezium/camel-debezium-sqlserver/src/generated/java/org/apache/camel/component/debezium/DebeziumSqlserverEndpointConfigurer.java
index 6a6cce8..9fb8ec8 100644
--- a/components/camel-debezium/camel-debezium-sqlserver/src/generated/java/org/apache/camel/component/debezium/DebeziumSqlserverEndpointConfigurer.java
+++ b/components/camel-debezium/camel-debezium-sqlserver/src/generated/java/org/apache/camel/component/debezium/DebeziumSqlserverEndpointConfigurer.java
@@ -62,14 +62,14 @@ public class DebeziumSqlserverEndpointConfigurer extends PropertyConfigurerSuppo
case "databaseHostname": target.getConfiguration().setDatabaseHostname(property(camelContext, java.lang.String.class, value)); return true;
case "databaseinstance":
case "databaseInstance": target.getConfiguration().setDatabaseInstance(property(camelContext, java.lang.String.class, value)); return true;
+ case "databasenames":
+ case "databaseNames": target.getConfiguration().setDatabaseNames(property(camelContext, java.lang.String.class, value)); return true;
case "databasepassword":
case "databasePassword": target.getConfiguration().setDatabasePassword(property(camelContext, java.lang.String.class, value)); return true;
case "databaseport":
case "databasePort": target.getConfiguration().setDatabasePort(property(camelContext, int.class, value)); return true;
case "databaseservername":
case "databaseServerName": target.getConfiguration().setDatabaseServerName(property(camelContext, java.lang.String.class, value)); return true;
- case "databaseservertimezone":
- case "databaseServerTimezone": target.getConfiguration().setDatabaseServerTimezone(property(camelContext, java.lang.String.class, value)); return true;
case "databaseuser":
case "databaseUser": target.getConfiguration().setDatabaseUser(property(camelContext, java.lang.String.class, value)); return true;
case "datatypepropagatesourcetype":
@@ -214,14 +214,14 @@ public class DebeziumSqlserverEndpointConfigurer extends PropertyConfigurerSuppo
case "databaseHostname": return java.lang.String.class;
case "databaseinstance":
case "databaseInstance": return java.lang.String.class;
+ case "databasenames":
+ case "databaseNames": return java.lang.String.class;
case "databasepassword":
case "databasePassword": return java.lang.String.class;
case "databaseport":
case "databasePort": return int.class;
case "databaseservername":
case "databaseServerName": return java.lang.String.class;
- case "databaseservertimezone":
- case "databaseServerTimezone": return java.lang.String.class;
case "databaseuser":
case "databaseUser": return java.lang.String.class;
case "datatypepropagatesourcetype":
@@ -367,14 +367,14 @@ public class DebeziumSqlserverEndpointConfigurer extends PropertyConfigurerSuppo
case "databaseHostname": return target.getConfiguration().getDatabaseHostname();
case "databaseinstance":
case "databaseInstance": return target.getConfiguration().getDatabaseInstance();
+ case "databasenames":
+ case "databaseNames": return target.getConfiguration().getDatabaseNames();
case "databasepassword":
case "databasePassword": return target.getConfiguration().getDatabasePassword();
case "databaseport":
case "databasePort": return target.getConfiguration().getDatabasePort();
case "databaseservername":
case "databaseServerName": return target.getConfiguration().getDatabaseServerName();
- case "databaseservertimezone":
- case "databaseServerTimezone": return target.getConfiguration().getDatabaseServerTimezone();
case "databaseuser":
case "databaseUser": return target.getConfiguration().getDatabaseUser();
case "datatypepropagatesourcetype":
diff --git a/components/camel-debezium/camel-debezium-sqlserver/src/generated/java/org/apache/camel/component/debezium/DebeziumSqlserverEndpointUriFactory.java b/components/camel-debezium/camel-debezium-sqlserver/src/generated/java/org/apache/camel/component/debezium/DebeziumSqlserverEndpointUriFactory.java
index bebb359..a707df2 100644
--- a/components/camel-debezium/camel-debezium-sqlserver/src/generated/java/org/apache/camel/component/debezium/DebeziumSqlserverEndpointUriFactory.java
+++ b/components/camel-debezium/camel-debezium-sqlserver/src/generated/java/org/apache/camel/component/debezium/DebeziumSqlserverEndpointUriFactory.java
@@ -38,7 +38,6 @@ public class DebeziumSqlserverEndpointUriFactory extends org.apache.camel.suppor
props.add("decimalHandlingMode");
props.add("skippedOperations");
props.add("sourceStructVersion");
- props.add("databaseServerTimezone");
props.add("binaryHandlingMode");
props.add("databaseHostname");
props.add("databaseHistorySkipUnparseableDdl");
@@ -54,6 +53,7 @@ public class DebeziumSqlserverEndpointUriFactory extends org.apache.camel.suppor
props.add("maxIterationTransactions");
props.add("additionalProperties");
props.add("offsetStorageReplicationFactor");
+ props.add("databaseNames");
props.add("exceptionHandler");
props.add("sourceTimestampMode");
props.add("databasePort");
diff --git a/components/camel-debezium/camel-debezium-sqlserver/src/generated/java/org/apache/camel/component/debezium/configuration/SqlServerConnectorEmbeddedDebeziumConfiguration.java b/components/camel-debezium/camel-debezium-sqlserver/src/generated/java/org/apache/camel/component/debezium/configuration/SqlServerConnectorEmbeddedDebeziumConfiguration.java
index b1889c4..5499861 100644
--- a/components/camel-debezium/camel-debezium-sqlserver/src/generated/java/org/apache/camel/component/debezium/configuration/SqlServerConnectorEmbeddedDebeziumConfiguration.java
+++ b/components/camel-debezium/camel-debezium-sqlserver/src/generated/java/org/apache/camel/component/debezium/configuration/SqlServerConnectorEmbeddedDebeziumConfiguration.java
@@ -48,6 +48,8 @@ public class SqlServerConnectorEmbeddedDebeziumConfiguration
private String databaseUser;
@UriParam(label = LABEL_NAME)
private String datatypePropagateSourceType;
+ @UriParam(label = LABEL_NAME)
+ private String databaseNames;
@UriParam(label = LABEL_NAME, defaultValue = "false")
private boolean sanitizeFieldNames = false;
@UriParam(label = LABEL_NAME)
@@ -93,8 +95,6 @@ public class SqlServerConnectorEmbeddedDebeziumConfiguration
private boolean provideTransactionMetadata = false;
@UriParam(label = LABEL_NAME)
private String tableWhitelist;
- @UriParam(label = LABEL_NAME)
- private String databaseServerTimezone;
@UriParam(label = LABEL_NAME, defaultValue = "false")
private boolean tombstonesOnDelete = false;
@UriParam(label = LABEL_NAME, defaultValue = "precise")
@@ -333,7 +333,7 @@ public class SqlServerConnectorEmbeddedDebeziumConfiguration
}
/**
- * The name of the database the connector should be monitoring
+ * The name of the database from which the connector should capture changes
*/
public void setDatabaseDbname(String databaseDbname) {
this.databaseDbname = databaseDbname;
@@ -370,6 +370,18 @@ public class SqlServerConnectorEmbeddedDebeziumConfiguration
}
/**
+ * The names of the databases from which the connector should capture
+ * changes
+ */
+ public void setDatabaseNames(String databaseNames) {
+ this.databaseNames = databaseNames;
+ }
+
+ public String getDatabaseNames() {
+ return databaseNames;
+ }
+
+ /**
* Whether field names will be sanitized to Avro naming conventions
*/
public void setSanitizeFieldNames(boolean sanitizeFieldNames) {
@@ -658,18 +670,6 @@ public class SqlServerConnectorEmbeddedDebeziumConfiguration
}
/**
- * The timezone of the server used to correctly shift the commit transaction
- * timestamp on the client sideOptions include: Any valid Java ZoneId
- */
- public void setDatabaseServerTimezone(String databaseServerTimezone) {
- this.databaseServerTimezone = databaseServerTimezone;
- }
-
- public String getDatabaseServerTimezone() {
- return databaseServerTimezone;
- }
-
- /**
* 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
@@ -943,6 +943,7 @@ public class SqlServerConnectorEmbeddedDebeziumConfiguration
addPropertyIfNotNull(configBuilder, "database.dbname", databaseDbname);
addPropertyIfNotNull(configBuilder, "database.user", databaseUser);
addPropertyIfNotNull(configBuilder, "datatype.propagate.source.type", datatypePropagateSourceType);
+ addPropertyIfNotNull(configBuilder, "database.names", databaseNames);
addPropertyIfNotNull(configBuilder, "sanitize.field.names", sanitizeFieldNames);
addPropertyIfNotNull(configBuilder, "snapshot.select.statement.overrides", snapshotSelectStatementOverrides);
addPropertyIfNotNull(configBuilder, "database.history.kafka.bootstrap.servers", databaseHistoryKafkaBootstrapServers);
@@ -965,7 +966,6 @@ public class SqlServerConnectorEmbeddedDebeziumConfiguration
addPropertyIfNotNull(configBuilder, "database.history.kafka.recovery.attempts", databaseHistoryKafkaRecoveryAttempts);
addPropertyIfNotNull(configBuilder, "provide.transaction.metadata", provideTransactionMetadata);
addPropertyIfNotNull(configBuilder, "table.whitelist", tableWhitelist);
- addPropertyIfNotNull(configBuilder, "database.server.timezone", databaseServerTimezone);
addPropertyIfNotNull(configBuilder, "tombstones.on.delete", tombstonesOnDelete);
addPropertyIfNotNull(configBuilder, "decimal.handling.mode", decimalHandlingMode);
addPropertyIfNotNull(configBuilder, "binary.handling.mode", binaryHandlingMode);
diff --git a/components/camel-debezium/camel-debezium-sqlserver/src/generated/resources/org/apache/camel/component/debezium/debezium-sqlserver.json b/components/camel-debezium/camel-debezium-sqlserver/src/generated/resources/org/apache/camel/component/debezium/debezium-sqlserver.json
index 681cd85..c8451fa6 100644
--- a/components/camel-debezium/camel-debezium-sqlserver/src/generated/resources/org/apache/camel/component/debezium/debezium-sqlserver.json
+++ b/components/camel-debezium/camel-debezium-sqlserver/src/generated/resources/org/apache/camel/component/debezium/debezium-sqlserver.json
@@ -43,7 +43,7 @@
"columnPropagateSourceType": { "kind": "property", "displayName": "Column 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 regula [...]
"columnWhitelist": { "kind": "property", "displayName": "Column 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": "Regular expressions matching columns to include in cha [...]
"converters": { "kind": "property", "displayName": "Converters", "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": "Optional list of custom converters that would be used instead of [...]
- "databaseDbname": { "kind": "property", "displayName": "Database Dbname", "group": "sqlserver", "label": "consumer,sqlserver", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.SqlServerConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The name of the database the connector should be monitoring" },
+ "databaseDbname": { "kind": "property", "displayName": "Database Dbname", "group": "sqlserver", "label": "consumer,sqlserver", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.SqlServerConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The name of the database from which the connector should [...]
"databaseHistory": { "kind": "property", "displayName": "Database History", "group": "sqlserver", "label": "consumer,sqlserver", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "io.debezium.relational.history.FileDatabaseHistory", "configurationClass": "org.apache.camel.component.debezium.configuration.SqlServerConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", [...]
"databaseHistoryFileFilename": { "kind": "property", "displayName": "Database History File Filename", "group": "sqlserver", "label": "consumer,sqlserver", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.SqlServerConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The path to the file that wi [...]
"databaseHistoryKafkaBootstrapServers": { "kind": "property", "displayName": "Database History Kafka Bootstrap Servers", "group": "sqlserver", "label": "consumer,sqlserver", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.SqlServerConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "A list of [...]
@@ -55,10 +55,10 @@
"databaseHistoryStoreOnlyMonitoredTablesDdl": { "kind": "property", "displayName": "Database History Store Only Monitored Tables Ddl", "group": "sqlserver", "label": "consumer,sqlserver", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": false, "configurationClass": "org.apache.camel.component.debezium.configuration.SqlServerConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuratio [...]
"databaseHostname": { "kind": "property", "displayName": "Database Hostname", "group": "sqlserver", "label": "consumer,sqlserver", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.SqlServerConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Resolvable hostname or IP address of the database se [...]
"databaseInstance": { "kind": "property", "displayName": "Database Instance", "group": "sqlserver", "label": "consumer,sqlserver", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.SqlServerConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The SQL Server instance name" },
+ "databaseNames": { "kind": "property", "displayName": "Database Names", "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 names of the databases from which the connector should [...]
"databasePassword": { "kind": "property", "displayName": "Database Password", "group": "sqlserver", "label": "consumer,sqlserver", "required": true, "type": "string", "javaType": "java.lang.String", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.SqlServerConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Password of the database user [...]
"databasePort": { "kind": "property", "displayName": "Database Port", "group": "sqlserver", "label": "consumer,sqlserver", "required": false, "type": "integer", "javaType": "int", "deprecated": false, "autowired": false, "secret": false, "defaultValue": 1433, "configurationClass": "org.apache.camel.component.debezium.configuration.SqlServerConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Port of the database server." },
"databaseServerName": { "kind": "property", "displayName": "Database Server Name", "group": "sqlserver", "label": "consumer,sqlserver", "required": true, "type": "string", "javaType": "java.lang.String", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.SqlServerConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Unique name that identifi [...]
- "databaseServerTimezone": { "kind": "property", "displayName": "Database Server Timezone", "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 timezone of the server used to corr [...]
"databaseUser": { "kind": "property", "displayName": "Database User", "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": "Name of the database user to be used when connecting to the [...]
"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 [...]
@@ -119,7 +119,7 @@
"columnPropagateSourceType": { "kind": "parameter", "displayName": "Column 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 regul [...]
"columnWhitelist": { "kind": "parameter", "displayName": "Column 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": "Regular expressions matching columns to include in ch [...]
"converters": { "kind": "parameter", "displayName": "Converters", "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": "Optional list of custom converters that would be used instead of [...]
- "databaseDbname": { "kind": "parameter", "displayName": "Database Dbname", "group": "sqlserver", "label": "consumer,sqlserver", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.SqlServerConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The name of the database the connector should be monito [...]
+ "databaseDbname": { "kind": "parameter", "displayName": "Database Dbname", "group": "sqlserver", "label": "consumer,sqlserver", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.SqlServerConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The name of the database from which the connector shoul [...]
"databaseHistory": { "kind": "parameter", "displayName": "Database History", "group": "sqlserver", "label": "consumer,sqlserver", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "io.debezium.relational.history.FileDatabaseHistory", "configurationClass": "org.apache.camel.component.debezium.configuration.SqlServerConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", [...]
"databaseHistoryFileFilename": { "kind": "parameter", "displayName": "Database History File Filename", "group": "sqlserver", "label": "consumer,sqlserver", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.SqlServerConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The path to the file that w [...]
"databaseHistoryKafkaBootstrapServers": { "kind": "parameter", "displayName": "Database History Kafka Bootstrap Servers", "group": "sqlserver", "label": "consumer,sqlserver", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.SqlServerConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "A list o [...]
@@ -131,10 +131,10 @@
"databaseHistoryStoreOnlyMonitoredTablesDdl": { "kind": "parameter", "displayName": "Database History Store Only Monitored Tables Ddl", "group": "sqlserver", "label": "consumer,sqlserver", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": false, "configurationClass": "org.apache.camel.component.debezium.configuration.SqlServerConnectorEmbeddedDebeziumConfiguration", "configurationField": "configurati [...]
"databaseHostname": { "kind": "parameter", "displayName": "Database Hostname", "group": "sqlserver", "label": "consumer,sqlserver", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.SqlServerConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Resolvable hostname or IP address of the database s [...]
"databaseInstance": { "kind": "parameter", "displayName": "Database Instance", "group": "sqlserver", "label": "consumer,sqlserver", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.SqlServerConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The SQL Server instance name" },
+ "databaseNames": { "kind": "parameter", "displayName": "Database Names", "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 names of the databases from which the connector shoul [...]
"databasePassword": { "kind": "parameter", "displayName": "Database Password", "group": "sqlserver", "label": "consumer,sqlserver", "required": true, "type": "string", "javaType": "java.lang.String", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.SqlServerConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Password of the database user [...]
"databasePort": { "kind": "parameter", "displayName": "Database Port", "group": "sqlserver", "label": "consumer,sqlserver", "required": false, "type": "integer", "javaType": "int", "deprecated": false, "autowired": false, "secret": false, "defaultValue": 1433, "configurationClass": "org.apache.camel.component.debezium.configuration.SqlServerConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Port of the database server." },
"databaseServerName": { "kind": "parameter", "displayName": "Database Server Name", "group": "sqlserver", "label": "consumer,sqlserver", "required": true, "type": "string", "javaType": "java.lang.String", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.SqlServerConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Unique name that identif [...]
- "databaseServerTimezone": { "kind": "parameter", "displayName": "Database Server Timezone", "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 timezone of the server used to cor [...]
"databaseUser": { "kind": "parameter", "displayName": "Database User", "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": "Name of the database user to be used when connecting to the [...]
"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 [...]
diff --git a/core/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/DebeziumMongodbComponentBuilderFactory.java b/core/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/DebeziumMongodbComponentBuilderFactory.java
index 96fac7c..a2dfc51 100644
--- a/core/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/DebeziumMongodbComponentBuilderFactory.java
+++ b/core/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/DebeziumMongodbComponentBuilderFactory.java
@@ -407,6 +407,22 @@ public interface DebeziumMongodbComponentBuilderFactory {
return this;
}
/**
+ * The maximum processing time in milliseconds to wait for the oplog
+ * cursor to process a single poll request.
+ *
+ * The option is a: <code>int</code> type.
+ *
+ * Group: mongodb
+ *
+ * @param cursorMaxAwaitTimeMs the value to set
+ * @return the dsl builder
+ */
+ default DebeziumMongodbComponentBuilder cursorMaxAwaitTimeMs(
+ int cursorMaxAwaitTimeMs) {
+ doSetProperty("cursorMaxAwaitTimeMs", cursorMaxAwaitTimeMs);
+ return this;
+ }
+ /**
* A comma-separated list of regular expressions that match the database
* names for which changes are to be excluded.
*
@@ -492,8 +508,10 @@ public interface DebeziumMongodbComponentBuilderFactory {
return this;
}
/**
- * Description is not available here, please check Debezium website for
- * corresponding key 'field.renames' description.
+ * A comma-separated list of the fully-qualified replacements of fields
+ * that should be used to rename fields in change event message values.
+ * Fully-qualified replacements for fields are of the form
+ * databaseName.collectionName.fieldName.nestedFieldName:newNestedFieldName, where databaseName and collectionName may contain the wildcard () which matches any characters, the colon character (:) is used to determine rename mapping of field.
*
* The option is a: <code>java.lang.String</code> type.
*
@@ -1091,6 +1109,7 @@ public interface DebeziumMongodbComponentBuilderFactory {
case "connectBackoffMaxDelayMs": getOrCreateConfiguration((DebeziumMongodbComponent) component).setConnectBackoffMaxDelayMs((long) value); return true;
case "connectMaxAttempts": getOrCreateConfiguration((DebeziumMongodbComponent) component).setConnectMaxAttempts((int) value); return true;
case "converters": getOrCreateConfiguration((DebeziumMongodbComponent) component).setConverters((java.lang.String) value); return true;
+ case "cursorMaxAwaitTimeMs": getOrCreateConfiguration((DebeziumMongodbComponent) component).setCursorMaxAwaitTimeMs((int) value); return true;
case "databaseExcludeList": getOrCreateConfiguration((DebeziumMongodbComponent) component).setDatabaseExcludeList((java.lang.String) value); return true;
case "databaseHistoryFileFilename": getOrCreateConfiguration((DebeziumMongodbComponent) component).setDatabaseHistoryFileFilename((java.lang.String) value); return true;
case "databaseIncludeList": getOrCreateConfiguration((DebeziumMongodbComponent) component).setDatabaseIncludeList((java.lang.String) value); return true;
diff --git a/core/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/DebeziumMysqlComponentBuilderFactory.java b/core/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/DebeziumMysqlComponentBuilderFactory.java
index e71d080..adf31bd 100644
--- a/core/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/DebeziumMysqlComponentBuilderFactory.java
+++ b/core/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/DebeziumMysqlComponentBuilderFactory.java
@@ -324,6 +324,25 @@ public interface DebeziumMysqlComponentBuilderFactory {
return this;
}
/**
+ * Specify how binary (blob, binary, etc.) columns should be represented
+ * in change events, including:'bytes' represents binary data as byte
+ * array (default)'base64' represents binary data as base64-encoded
+ * string'hex' represents binary data as hex-encoded (base16) string.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Default: bytes
+ * Group: mysql
+ *
+ * @param binaryHandlingMode the value to set
+ * @return the dsl builder
+ */
+ default DebeziumMysqlComponentBuilder binaryHandlingMode(
+ java.lang.String binaryHandlingMode) {
+ doSetProperty("binaryHandlingMode", binaryHandlingMode);
+ return this;
+ }
+ /**
* The size of a look-ahead buffer used by the binlog reader to decide
* whether the transaction in progress is going to be committed or
* rolled back. Use 0 to disable look-ahead buffering. Defaults to 0
@@ -1275,6 +1294,25 @@ public interface DebeziumMysqlComponentBuilderFactory {
return this;
}
/**
+ * The number of rows a table must contain to stream results rather than
+ * pull all into memory during snapshots. Defaults to 1,000. Use 0 to
+ * stream all results and completely avoid checking the size of each
+ * table.
+ *
+ * The option is a: <code>int</code> type.
+ *
+ * Default: 1000
+ * Group: mysql
+ *
+ * @param minRowCountToStreamResults the value to set
+ * @return the dsl builder
+ */
+ default DebeziumMysqlComponentBuilder minRowCountToStreamResults(
+ int minRowCountToStreamResults) {
+ doSetProperty("minRowCountToStreamResults", minRowCountToStreamResults);
+ return this;
+ }
+ /**
* Time to wait for new change events to appear after receiving no
* events, given in milliseconds. Defaults to 500 ms.
*
@@ -1761,6 +1799,7 @@ public interface DebeziumMysqlComponentBuilderFactory {
case "offsetStorageTopic": getOrCreateConfiguration((DebeziumMySqlComponent) component).setOffsetStorageTopic((java.lang.String) value); return true;
case "autowiredEnabled": ((DebeziumMySqlComponent) component).setAutowiredEnabled((boolean) value); return true;
case "bigintUnsignedHandlingMode": getOrCreateConfiguration((DebeziumMySqlComponent) component).setBigintUnsignedHandlingMode((java.lang.String) value); return true;
+ case "binaryHandlingMode": getOrCreateConfiguration((DebeziumMySqlComponent) component).setBinaryHandlingMode((java.lang.String) value); return true;
case "binlogBufferSize": getOrCreateConfiguration((DebeziumMySqlComponent) component).setBinlogBufferSize((int) value); return true;
case "columnBlacklist": getOrCreateConfiguration((DebeziumMySqlComponent) component).setColumnBlacklist((java.lang.String) value); return true;
case "columnExcludeList": getOrCreateConfiguration((DebeziumMySqlComponent) component).setColumnExcludeList((java.lang.String) value); return true;
@@ -1814,6 +1853,7 @@ public interface DebeziumMysqlComponentBuilderFactory {
case "maxQueueSize": getOrCreateConfiguration((DebeziumMySqlComponent) component).setMaxQueueSize((int) value); return true;
case "maxQueueSizeInBytes": getOrCreateConfiguration((DebeziumMySqlComponent) component).setMaxQueueSizeInBytes((long) value); return true;
case "messageKeyColumns": getOrCreateConfiguration((DebeziumMySqlComponent) component).setMessageKeyColumns((java.lang.String) value); return true;
+ case "minRowCountToStreamResults": getOrCreateConfiguration((DebeziumMySqlComponent) component).setMinRowCountToStreamResults((int) value); return true;
case "pollIntervalMs": getOrCreateConfiguration((DebeziumMySqlComponent) component).setPollIntervalMs((long) value); return true;
case "provideTransactionMetadata": getOrCreateConfiguration((DebeziumMySqlComponent) component).setProvideTransactionMetadata((boolean) value); return true;
case "queryFetchSize": getOrCreateConfiguration((DebeziumMySqlComponent) component).setQueryFetchSize((int) value); return true;
diff --git a/core/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/DebeziumPostgresComponentBuilderFactory.java b/core/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/DebeziumPostgresComponentBuilderFactory.java
index 4f34e14..beefd6b 100644
--- a/core/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/DebeziumPostgresComponentBuilderFactory.java
+++ b/core/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/DebeziumPostgresComponentBuilderFactory.java
@@ -418,7 +418,8 @@ public interface DebeziumPostgresComponentBuilderFactory {
return this;
}
/**
- * The name of the database the connector should be monitoring.
+ * The name of the database from which the connector should capture
+ * changes.
*
* The option is a: <code>java.lang.String</code> type.
*
@@ -1616,6 +1617,25 @@ public interface DebeziumPostgresComponentBuilderFactory {
return this;
}
/**
+ * Specify how TRUNCATE operations are handled for change events
+ * (supported only on pg11 pgoutput plugin), including: 'skip' to skip /
+ * ignore TRUNCATE events (default), 'include' to handle and include
+ * TRUNCATE events.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Default: skip
+ * Group: postgres
+ *
+ * @param truncateHandlingMode the value to set
+ * @return the dsl builder
+ */
+ default DebeziumPostgresComponentBuilder truncateHandlingMode(
+ java.lang.String truncateHandlingMode) {
+ doSetProperty("truncateHandlingMode", truncateHandlingMode);
+ return this;
+ }
+ /**
* Specify 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
@@ -1750,6 +1770,7 @@ public interface DebeziumPostgresComponentBuilderFactory {
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 "truncateHandlingMode": getOrCreateConfiguration((DebeziumPostgresComponent) component).setTruncateHandlingMode((java.lang.String) value); return true;
case "xminFetchIntervalMs": getOrCreateConfiguration((DebeziumPostgresComponent) component).setXminFetchIntervalMs((long) value); return true;
default: return false;
}
diff --git a/core/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/DebeziumSqlserverComponentBuilderFactory.java b/core/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/DebeziumSqlserverComponentBuilderFactory.java
index 922063a..35fba6d 100644
--- a/core/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/DebeziumSqlserverComponentBuilderFactory.java
+++ b/core/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/DebeziumSqlserverComponentBuilderFactory.java
@@ -418,7 +418,8 @@ public interface DebeziumSqlserverComponentBuilderFactory {
return this;
}
/**
- * The name of the database the connector should be monitoring.
+ * The name of the database from which the connector should capture
+ * changes.
*
* The option is a: <code>java.lang.String</code> type.
*
@@ -625,6 +626,22 @@ public interface DebeziumSqlserverComponentBuilderFactory {
return this;
}
/**
+ * The names of the databases from which the connector should capture
+ * changes.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: sqlserver
+ *
+ * @param databaseNames the value to set
+ * @return the dsl builder
+ */
+ default DebeziumSqlserverComponentBuilder databaseNames(
+ java.lang.String databaseNames) {
+ doSetProperty("databaseNames", databaseNames);
+ return this;
+ }
+ /**
* Password of the database user to be used when connecting to the
* database.
*
@@ -674,23 +691,6 @@ public interface DebeziumSqlserverComponentBuilderFactory {
return this;
}
/**
- * The timezone of the server used to correctly shift the commit
- * transaction timestamp on the client sideOptions include: Any valid
- * Java ZoneId.
- *
- * The option is a: <code>java.lang.String</code> type.
- *
- * Group: sqlserver
- *
- * @param databaseServerTimezone the value to set
- * @return the dsl builder
- */
- default DebeziumSqlserverComponentBuilder databaseServerTimezone(
- java.lang.String databaseServerTimezone) {
- doSetProperty("databaseServerTimezone", databaseServerTimezone);
- return this;
- }
- /**
* Name of the database user to be used when connecting to the database.
*
* The option is a: <code>java.lang.String</code> type.
@@ -1409,10 +1409,10 @@ public interface DebeziumSqlserverComponentBuilderFactory {
case "databaseHistoryStoreOnlyMonitoredTablesDdl": getOrCreateConfiguration((DebeziumSqlserverComponent) component).setDatabaseHistoryStoreOnlyMonitoredTablesDdl((boolean) value); return true;
case "databaseHostname": getOrCreateConfiguration((DebeziumSqlserverComponent) component).setDatabaseHostname((java.lang.String) value); return true;
case "databaseInstance": getOrCreateConfiguration((DebeziumSqlserverComponent) component).setDatabaseInstance((java.lang.String) value); return true;
+ case "databaseNames": getOrCreateConfiguration((DebeziumSqlserverComponent) component).setDatabaseNames((java.lang.String) value); return true;
case "databasePassword": getOrCreateConfiguration((DebeziumSqlserverComponent) component).setDatabasePassword((java.lang.String) value); return true;
case "databasePort": getOrCreateConfiguration((DebeziumSqlserverComponent) component).setDatabasePort((int) value); return true;
case "databaseServerName": getOrCreateConfiguration((DebeziumSqlserverComponent) component).setDatabaseServerName((java.lang.String) value); return true;
- case "databaseServerTimezone": getOrCreateConfiguration((DebeziumSqlserverComponent) component).setDatabaseServerTimezone((java.lang.String) value); return true;
case "databaseUser": getOrCreateConfiguration((DebeziumSqlserverComponent) component).setDatabaseUser((java.lang.String) value); return true;
case "datatypePropagateSourceType": getOrCreateConfiguration((DebeziumSqlserverComponent) component).setDatatypePropagateSourceType((java.lang.String) value); return true;
case "decimalHandlingMode": getOrCreateConfiguration((DebeziumSqlserverComponent) component).setDecimalHandlingMode((java.lang.String) value); return true;
diff --git a/core/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/DebeziumMongodbEndpointBuilderFactory.java b/core/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/DebeziumMongodbEndpointBuilderFactory.java
index d895a56..b7625c7 100644
--- a/core/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/DebeziumMongodbEndpointBuilderFactory.java
+++ b/core/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/DebeziumMongodbEndpointBuilderFactory.java
@@ -535,6 +535,38 @@ public interface DebeziumMongodbEndpointBuilderFactory {
return this;
}
/**
+ * The maximum processing time in milliseconds to wait for the oplog
+ * cursor to process a single poll request.
+ *
+ * The option is a: <code>int</code> type.
+ *
+ * Group: mongodb
+ *
+ * @param cursorMaxAwaitTimeMs the value to set
+ * @return the dsl builder
+ */
+ default DebeziumMongodbEndpointBuilder cursorMaxAwaitTimeMs(
+ int cursorMaxAwaitTimeMs) {
+ doSetProperty("cursorMaxAwaitTimeMs", cursorMaxAwaitTimeMs);
+ return this;
+ }
+ /**
+ * The maximum processing time in milliseconds to wait for the oplog
+ * cursor to process a single poll request.
+ *
+ * The option will be converted to a <code>int</code> type.
+ *
+ * Group: mongodb
+ *
+ * @param cursorMaxAwaitTimeMs the value to set
+ * @return the dsl builder
+ */
+ default DebeziumMongodbEndpointBuilder cursorMaxAwaitTimeMs(
+ String cursorMaxAwaitTimeMs) {
+ doSetProperty("cursorMaxAwaitTimeMs", cursorMaxAwaitTimeMs);
+ return this;
+ }
+ /**
* A comma-separated list of regular expressions that match the database
* names for which changes are to be excluded.
*
@@ -620,8 +652,10 @@ public interface DebeziumMongodbEndpointBuilderFactory {
return this;
}
/**
- * Description is not available here, please check Debezium website for
- * corresponding key 'field.renames' description.
+ * A comma-separated list of the fully-qualified replacements of fields
+ * that should be used to rename fields in change event message values.
+ * Fully-qualified replacements for fields are of the form
+ * databaseName.collectionName.fieldName.nestedFieldName:newNestedFieldName, where databaseName and collectionName may contain the wildcard () which matches any characters, the colon character (:) is used to determine rename mapping of field.
*
* The option is a: <code>java.lang.String</code> type.
*
diff --git a/core/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/DebeziumMySqlEndpointBuilderFactory.java b/core/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/DebeziumMySqlEndpointBuilderFactory.java
index 794a825..501e61a 100644
--- a/core/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/DebeziumMySqlEndpointBuilderFactory.java
+++ b/core/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/DebeziumMySqlEndpointBuilderFactory.java
@@ -396,6 +396,25 @@ public interface DebeziumMySqlEndpointBuilderFactory {
return this;
}
/**
+ * Specify how binary (blob, binary, etc.) columns should be represented
+ * in change events, including:'bytes' represents binary data as byte
+ * array (default)'base64' represents binary data as base64-encoded
+ * string'hex' represents binary data as hex-encoded (base16) string.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Default: bytes
+ * Group: mysql
+ *
+ * @param binaryHandlingMode the value to set
+ * @return the dsl builder
+ */
+ default DebeziumMySqlEndpointBuilder binaryHandlingMode(
+ String binaryHandlingMode) {
+ doSetProperty("binaryHandlingMode", binaryHandlingMode);
+ return this;
+ }
+ /**
* The size of a look-ahead buffer used by the binlog reader to decide
* whether the transaction in progress is going to be committed or
* rolled back. Use 0 to disable look-ahead buffering. Defaults to 0
@@ -1737,6 +1756,44 @@ public interface DebeziumMySqlEndpointBuilderFactory {
return this;
}
/**
+ * The number of rows a table must contain to stream results rather than
+ * pull all into memory during snapshots. Defaults to 1,000. Use 0 to
+ * stream all results and completely avoid checking the size of each
+ * table.
+ *
+ * The option is a: <code>int</code> type.
+ *
+ * Default: 1000
+ * Group: mysql
+ *
+ * @param minRowCountToStreamResults the value to set
+ * @return the dsl builder
+ */
+ default DebeziumMySqlEndpointBuilder minRowCountToStreamResults(
+ int minRowCountToStreamResults) {
+ doSetProperty("minRowCountToStreamResults", minRowCountToStreamResults);
+ return this;
+ }
+ /**
+ * The number of rows a table must contain to stream results rather than
+ * pull all into memory during snapshots. Defaults to 1,000. Use 0 to
+ * stream all results and completely avoid checking the size of each
+ * table.
+ *
+ * The option will be converted to a <code>int</code> type.
+ *
+ * Default: 1000
+ * Group: mysql
+ *
+ * @param minRowCountToStreamResults the value to set
+ * @return the dsl builder
+ */
+ default DebeziumMySqlEndpointBuilder minRowCountToStreamResults(
+ String minRowCountToStreamResults) {
+ doSetProperty("minRowCountToStreamResults", minRowCountToStreamResults);
+ return this;
+ }
+ /**
* Time to wait for new change events to appear after receiving no
* events, given in milliseconds. Defaults to 500 ms.
*
diff --git a/core/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/DebeziumPostgresEndpointBuilderFactory.java b/core/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/DebeziumPostgresEndpointBuilderFactory.java
index a9d50b2..41bb965 100644
--- a/core/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/DebeziumPostgresEndpointBuilderFactory.java
+++ b/core/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/DebeziumPostgresEndpointBuilderFactory.java
@@ -490,7 +490,8 @@ public interface DebeziumPostgresEndpointBuilderFactory {
return this;
}
/**
- * The name of the database the connector should be monitoring.
+ * The name of the database from which the connector should capture
+ * changes.
*
* The option is a: <code>java.lang.String</code> type.
*
@@ -2085,6 +2086,25 @@ public interface DebeziumPostgresEndpointBuilderFactory {
return this;
}
/**
+ * Specify how TRUNCATE operations are handled for change events
+ * (supported only on pg11 pgoutput plugin), including: 'skip' to skip /
+ * ignore TRUNCATE events (default), 'include' to handle and include
+ * TRUNCATE events.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Default: skip
+ * Group: postgres
+ *
+ * @param truncateHandlingMode the value to set
+ * @return the dsl builder
+ */
+ default DebeziumPostgresEndpointBuilder truncateHandlingMode(
+ String truncateHandlingMode) {
+ doSetProperty("truncateHandlingMode", truncateHandlingMode);
+ return this;
+ }
+ /**
* Specify 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/core/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/DebeziumSqlserverEndpointBuilderFactory.java b/core/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/DebeziumSqlserverEndpointBuilderFactory.java
index 9e95aa9..e6df790 100644
--- a/core/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/DebeziumSqlserverEndpointBuilderFactory.java
+++ b/core/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/DebeziumSqlserverEndpointBuilderFactory.java
@@ -490,7 +490,8 @@ public interface DebeziumSqlserverEndpointBuilderFactory {
return this;
}
/**
- * The name of the database the connector should be monitoring.
+ * The name of the database from which the connector should capture
+ * changes.
*
* The option is a: <code>java.lang.String</code> type.
*
@@ -794,6 +795,22 @@ public interface DebeziumSqlserverEndpointBuilderFactory {
return this;
}
/**
+ * The names of the databases from which the connector should capture
+ * changes.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: sqlserver
+ *
+ * @param databaseNames the value to set
+ * @return the dsl builder
+ */
+ default DebeziumSqlserverEndpointBuilder databaseNames(
+ String databaseNames) {
+ doSetProperty("databaseNames", databaseNames);
+ return this;
+ }
+ /**
* Password of the database user to be used when connecting to the
* database.
*
@@ -861,23 +878,6 @@ public interface DebeziumSqlserverEndpointBuilderFactory {
return this;
}
/**
- * The timezone of the server used to correctly shift the commit
- * transaction timestamp on the client sideOptions include: Any valid
- * Java ZoneId.
- *
- * The option is a: <code>java.lang.String</code> type.
- *
- * Group: sqlserver
- *
- * @param databaseServerTimezone the value to set
- * @return the dsl builder
- */
- default DebeziumSqlserverEndpointBuilder databaseServerTimezone(
- String databaseServerTimezone) {
- doSetProperty("databaseServerTimezone", databaseServerTimezone);
- return this;
- }
- /**
* Name of the database user to be used when connecting to the database.
*
* The option is a: <code>java.lang.String</code> type.
diff --git a/parent/pom.xml b/parent/pom.xml
index d2cc416..2d8f0a7 100644
--- a/parent/pom.xml
+++ b/parent/pom.xml
@@ -156,7 +156,7 @@
<docker-java-version>3.2.11</docker-java-version>
<dozer-version>6.5.2</dozer-version>
<dropbox-version>3.2.0</dropbox-version>
- <debezium-version>1.6.2.Final</debezium-version>
+ <debezium-version>1.7.0.Final</debezium-version>
<debezium-mysql-connector-version>8.0.25</debezium-mysql-connector-version>
<eddsa-version>0.3.0</eddsa-version>
<egit-github-core-version>2.1.5</egit-github-core-version>