You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by da...@apache.org on 2023/05/24 07:17:55 UTC
[camel] branch main updated (f0f6c3cd9e9 -> aef3b6b9904)
This is an automated email from the ASF dual-hosted git repository.
davsclaus pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/camel.git
from f0f6c3cd9e9 Regen for commit dff7d5389e890b0ff185e697c6e71cc4363e895b
new fe7aec4a274 Upgrade to debezium 2.2.1
new aef3b6b9904 Upgrade to debezium 2.2.1
The 2 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
camel-dependencies/pom.xml | 2 +-
.../camel/catalog/components/debezium-oracle.json | 4 +--
.../DebeziumOracleComponentConfigurer.java | 12 ++++----
.../debezium/DebeziumOracleEndpointConfigurer.java | 12 ++++----
.../debezium/DebeziumOracleEndpointUriFactory.java | 2 +-
...acleConnectorEmbeddedDebeziumConfiguration.java | 33 +++++++++++-----------
.../camel/component/debezium/debezium-oracle.json | 4 +--
.../dsl/DebeziumOracleComponentBuilderFactory.java | 17 +++++------
parent/pom.xml | 2 +-
9 files changed, 45 insertions(+), 43 deletions(-)
[camel] 01/02: Upgrade to debezium 2.2.1
Posted by da...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
davsclaus pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel.git
commit fe7aec4a2743e8c47d2ae810c41194a8d8ce624c
Author: Claus Ibsen <cl...@gmail.com>
AuthorDate: Wed May 24 08:55:41 2023 +0200
Upgrade to debezium 2.2.1
---
camel-dependencies/pom.xml | 2 +-
.../DebeziumOracleComponentConfigurer.java | 12 ++++----
.../debezium/DebeziumOracleEndpointConfigurer.java | 12 ++++----
.../debezium/DebeziumOracleEndpointUriFactory.java | 2 +-
...acleConnectorEmbeddedDebeziumConfiguration.java | 33 +++++++++++-----------
.../camel/component/debezium/debezium-oracle.json | 4 +--
parent/pom.xml | 2 +-
7 files changed, 34 insertions(+), 33 deletions(-)
diff --git a/camel-dependencies/pom.xml b/camel-dependencies/pom.xml
index bdd1eaf209d..4e1ed3b9081 100644
--- a/camel-dependencies/pom.xml
+++ b/camel-dependencies/pom.xml
@@ -128,7 +128,7 @@
<cxf-xjc-plugin-version>4.0.0</cxf-xjc-plugin-version>
<cxf-xjc-utils-version>4.0.0</cxf-xjc-utils-version>
<datasonnet-mapper-version>2.5.2-jakarta4</datasonnet-mapper-version>
- <debezium-version>2.2.0.Final</debezium-version>
+ <debezium-version>2.2.1.Final</debezium-version>
<debezium-mysql-connector-version>8.0.32</debezium-mysql-connector-version>
<depends-maven-plugin-version>1.4.0</depends-maven-plugin-version>
<derby-version>10.14.2.0</derby-version>
diff --git a/components/camel-debezium/camel-debezium-oracle/src/generated/java/org/apache/camel/component/debezium/DebeziumOracleComponentConfigurer.java b/components/camel-debezium/camel-debezium-oracle/src/generated/java/org/apache/camel/component/debezium/DebeziumOracleComponentConfigurer.java
index 884011b1ded..e73a2f90c3e 100644
--- a/components/camel-debezium/camel-debezium-oracle/src/generated/java/org/apache/camel/component/debezium/DebeziumOracleComponentConfigurer.java
+++ b/components/camel-debezium/camel-debezium-oracle/src/generated/java/org/apache/camel/component/debezium/DebeziumOracleComponentConfigurer.java
@@ -130,8 +130,8 @@ public class DebeziumOracleComponentConfigurer extends PropertyConfigurerSupport
case "logMiningSleepTimeMinMs": getOrCreateConfiguration(target).setLogMiningSleepTimeMinMs(property(camelContext, java.time.Duration.class, value).toMillis()); return true;
case "logminingstrategy":
case "logMiningStrategy": getOrCreateConfiguration(target).setLogMiningStrategy(property(camelContext, java.lang.String.class, value)); return true;
- case "logminingtransactionretentionhours":
- case "logMiningTransactionRetentionHours": getOrCreateConfiguration(target).setLogMiningTransactionRetentionHours(property(camelContext, long.class, value)); return true;
+ case "logminingtransactionretentionms":
+ case "logMiningTransactionRetentionMs": getOrCreateConfiguration(target).setLogMiningTransactionRetentionMs(property(camelContext, java.time.Duration.class, value).toMillis()); return true;
case "logminingusernameexcludelist":
case "logMiningUsernameExcludeList": getOrCreateConfiguration(target).setLogMiningUsernameExcludeList(property(camelContext, java.lang.String.class, value)); return true;
case "maxbatchsize":
@@ -327,8 +327,8 @@ public class DebeziumOracleComponentConfigurer extends PropertyConfigurerSupport
case "logMiningSleepTimeMinMs": return long.class;
case "logminingstrategy":
case "logMiningStrategy": return java.lang.String.class;
- case "logminingtransactionretentionhours":
- case "logMiningTransactionRetentionHours": return long.class;
+ case "logminingtransactionretentionms":
+ case "logMiningTransactionRetentionMs": return long.class;
case "logminingusernameexcludelist":
case "logMiningUsernameExcludeList": return java.lang.String.class;
case "maxbatchsize":
@@ -525,8 +525,8 @@ public class DebeziumOracleComponentConfigurer extends PropertyConfigurerSupport
case "logMiningSleepTimeMinMs": return getOrCreateConfiguration(target).getLogMiningSleepTimeMinMs();
case "logminingstrategy":
case "logMiningStrategy": return getOrCreateConfiguration(target).getLogMiningStrategy();
- case "logminingtransactionretentionhours":
- case "logMiningTransactionRetentionHours": return getOrCreateConfiguration(target).getLogMiningTransactionRetentionHours();
+ case "logminingtransactionretentionms":
+ case "logMiningTransactionRetentionMs": return getOrCreateConfiguration(target).getLogMiningTransactionRetentionMs();
case "logminingusernameexcludelist":
case "logMiningUsernameExcludeList": return getOrCreateConfiguration(target).getLogMiningUsernameExcludeList();
case "maxbatchsize":
diff --git a/components/camel-debezium/camel-debezium-oracle/src/generated/java/org/apache/camel/component/debezium/DebeziumOracleEndpointConfigurer.java b/components/camel-debezium/camel-debezium-oracle/src/generated/java/org/apache/camel/component/debezium/DebeziumOracleEndpointConfigurer.java
index 1be27304564..183248e53fd 100644
--- a/components/camel-debezium/camel-debezium-oracle/src/generated/java/org/apache/camel/component/debezium/DebeziumOracleEndpointConfigurer.java
+++ b/components/camel-debezium/camel-debezium-oracle/src/generated/java/org/apache/camel/component/debezium/DebeziumOracleEndpointConfigurer.java
@@ -124,8 +124,8 @@ public class DebeziumOracleEndpointConfigurer extends PropertyConfigurerSupport
case "logMiningSleepTimeMinMs": target.getConfiguration().setLogMiningSleepTimeMinMs(property(camelContext, java.time.Duration.class, value).toMillis()); return true;
case "logminingstrategy":
case "logMiningStrategy": target.getConfiguration().setLogMiningStrategy(property(camelContext, java.lang.String.class, value)); return true;
- case "logminingtransactionretentionhours":
- case "logMiningTransactionRetentionHours": target.getConfiguration().setLogMiningTransactionRetentionHours(property(camelContext, long.class, value)); return true;
+ case "logminingtransactionretentionms":
+ case "logMiningTransactionRetentionMs": target.getConfiguration().setLogMiningTransactionRetentionMs(property(camelContext, java.time.Duration.class, value).toMillis()); return true;
case "logminingusernameexcludelist":
case "logMiningUsernameExcludeList": target.getConfiguration().setLogMiningUsernameExcludeList(property(camelContext, java.lang.String.class, value)); return true;
case "maxbatchsize":
@@ -322,8 +322,8 @@ public class DebeziumOracleEndpointConfigurer extends PropertyConfigurerSupport
case "logMiningSleepTimeMinMs": return long.class;
case "logminingstrategy":
case "logMiningStrategy": return java.lang.String.class;
- case "logminingtransactionretentionhours":
- case "logMiningTransactionRetentionHours": return long.class;
+ case "logminingtransactionretentionms":
+ case "logMiningTransactionRetentionMs": return long.class;
case "logminingusernameexcludelist":
case "logMiningUsernameExcludeList": return java.lang.String.class;
case "maxbatchsize":
@@ -521,8 +521,8 @@ public class DebeziumOracleEndpointConfigurer extends PropertyConfigurerSupport
case "logMiningSleepTimeMinMs": return target.getConfiguration().getLogMiningSleepTimeMinMs();
case "logminingstrategy":
case "logMiningStrategy": return target.getConfiguration().getLogMiningStrategy();
- case "logminingtransactionretentionhours":
- case "logMiningTransactionRetentionHours": return target.getConfiguration().getLogMiningTransactionRetentionHours();
+ case "logminingtransactionretentionms":
+ case "logMiningTransactionRetentionMs": return target.getConfiguration().getLogMiningTransactionRetentionMs();
case "logminingusernameexcludelist":
case "logMiningUsernameExcludeList": return target.getConfiguration().getLogMiningUsernameExcludeList();
case "maxbatchsize":
diff --git a/components/camel-debezium/camel-debezium-oracle/src/generated/java/org/apache/camel/component/debezium/DebeziumOracleEndpointUriFactory.java b/components/camel-debezium/camel-debezium-oracle/src/generated/java/org/apache/camel/component/debezium/DebeziumOracleEndpointUriFactory.java
index 7d4f4c94d5c..240e19f6308 100644
--- a/components/camel-debezium/camel-debezium-oracle/src/generated/java/org/apache/camel/component/debezium/DebeziumOracleEndpointUriFactory.java
+++ b/components/camel-debezium/camel-debezium-oracle/src/generated/java/org/apache/camel/component/debezium/DebeziumOracleEndpointUriFactory.java
@@ -74,7 +74,7 @@ public class DebeziumOracleEndpointUriFactory extends org.apache.camel.support.c
props.add("logMiningSleepTimeMaxMs");
props.add("logMiningSleepTimeMinMs");
props.add("logMiningStrategy");
- props.add("logMiningTransactionRetentionHours");
+ props.add("logMiningTransactionRetentionMs");
props.add("logMiningUsernameExcludeList");
props.add("maxBatchSize");
props.add("maxQueueSize");
diff --git a/components/camel-debezium/camel-debezium-oracle/src/generated/java/org/apache/camel/component/debezium/configuration/OracleConnectorEmbeddedDebeziumConfiguration.java b/components/camel-debezium/camel-debezium-oracle/src/generated/java/org/apache/camel/component/debezium/configuration/OracleConnectorEmbeddedDebeziumConfiguration.java
index 5d647c44f70..8270f5099f0 100644
--- a/components/camel-debezium/camel-debezium-oracle/src/generated/java/org/apache/camel/component/debezium/configuration/OracleConnectorEmbeddedDebeziumConfiguration.java
+++ b/components/camel-debezium/camel-debezium-oracle/src/generated/java/org/apache/camel/component/debezium/configuration/OracleConnectorEmbeddedDebeziumConfiguration.java
@@ -108,6 +108,8 @@ public class OracleConnectorEmbeddedDebeziumConfiguration
@UriParam(label = LABEL_NAME, defaultValue = "10s", javaType = "java.time.Duration")
private long retriableRestartConnectorWaitMs = 10000;
@UriParam(label = LABEL_NAME, defaultValue = "0ms", javaType = "java.time.Duration")
+ private long logMiningTransactionRetentionMs = 0;
+ @UriParam(label = LABEL_NAME, defaultValue = "0ms", javaType = "java.time.Duration")
private long snapshotDelayMs = 0;
@UriParam(label = LABEL_NAME, defaultValue = "redo_log_catalog")
private String logMiningStrategy = "redo_log_catalog";
@@ -134,8 +136,6 @@ public class OracleConnectorEmbeddedDebeziumConfiguration
private String databaseOutServerName;
@UriParam(label = LABEL_NAME, defaultValue = "0")
private long logMiningArchiveLogHours = 0;
- @UriParam(label = LABEL_NAME, defaultValue = "0")
- private long logMiningTransactionRetentionHours = 0;
@UriParam(label = LABEL_NAME)
private String snapshotIncludeCollectionList;
@UriParam(label = LABEL_NAME, defaultValue = "100000")
@@ -815,6 +815,20 @@ public class OracleConnectorEmbeddedDebeziumConfiguration
return retriableRestartConnectorWaitMs;
}
+ /**
+ * Duration in milliseconds to keep long running transactions in transaction
+ * buffer between log mining sessions. By default, all transactions are
+ * retained.
+ */
+ public void setLogMiningTransactionRetentionMs(
+ long logMiningTransactionRetentionMs) {
+ this.logMiningTransactionRetentionMs = logMiningTransactionRetentionMs;
+ }
+
+ public long getLogMiningTransactionRetentionMs() {
+ return logMiningTransactionRetentionMs;
+ }
+
/**
* A delay period before a snapshot will begin, given in milliseconds.
* Defaults to 0 ms.
@@ -993,19 +1007,6 @@ public class OracleConnectorEmbeddedDebeziumConfiguration
return logMiningArchiveLogHours;
}
- /**
- * Hours to keep long running transactions in transaction buffer between log
- * mining sessions. By default, all transactions are retained.
- */
- public void setLogMiningTransactionRetentionHours(
- long logMiningTransactionRetentionHours) {
- this.logMiningTransactionRetentionHours = logMiningTransactionRetentionHours;
- }
-
- public long getLogMiningTransactionRetentionHours() {
- return logMiningTransactionRetentionHours;
- }
-
/**
* This setting must be set to specify a list of tables/collections whose
* snapshot must be taken on creating or restarting the connector.
@@ -1337,6 +1338,7 @@ public class OracleConnectorEmbeddedDebeziumConfiguration
addPropertyIfNotNull(configBuilder, "rac.nodes", racNodes);
addPropertyIfNotNull(configBuilder, "log.mining.buffer.transaction.events.threshold", logMiningBufferTransactionEventsThreshold);
addPropertyIfNotNull(configBuilder, "retriable.restart.connector.wait.ms", retriableRestartConnectorWaitMs);
+ addPropertyIfNotNull(configBuilder, "log.mining.transaction.retention.ms", logMiningTransactionRetentionMs);
addPropertyIfNotNull(configBuilder, "snapshot.delay.ms", snapshotDelayMs);
addPropertyIfNotNull(configBuilder, "log.mining.strategy", logMiningStrategy);
addPropertyIfNotNull(configBuilder, "provide.transaction.metadata", provideTransactionMetadata);
@@ -1350,7 +1352,6 @@ public class OracleConnectorEmbeddedDebeziumConfiguration
addPropertyIfNotNull(configBuilder, "include.schema.comments", includeSchemaComments);
addPropertyIfNotNull(configBuilder, "database.out.server.name", databaseOutServerName);
addPropertyIfNotNull(configBuilder, "log.mining.archive.log.hours", logMiningArchiveLogHours);
- addPropertyIfNotNull(configBuilder, "log.mining.transaction.retention.hours", logMiningTransactionRetentionHours);
addPropertyIfNotNull(configBuilder, "snapshot.include.collection.list", snapshotIncludeCollectionList);
addPropertyIfNotNull(configBuilder, "log.mining.batch.size.max", logMiningBatchSizeMax);
addPropertyIfNotNull(configBuilder, "database.pdb.name", databasePdbName);
diff --git a/components/camel-debezium/camel-debezium-oracle/src/generated/resources/org/apache/camel/component/debezium/debezium-oracle.json b/components/camel-debezium/camel-debezium-oracle/src/generated/resources/org/apache/camel/component/debezium/debezium-oracle.json
index ea417aa714a..8477fa8cb51 100644
--- a/components/camel-debezium/camel-debezium-oracle/src/generated/resources/org/apache/camel/component/debezium/debezium-oracle.json
+++ b/components/camel-debezium/camel-debezium-oracle/src/generated/resources/org/apache/camel/component/debezium/debezium-oracle.json
@@ -82,7 +82,7 @@
"logMiningSleepTimeMaxMs": { "index": 57, "kind": "property", "displayName": "Log Mining Sleep Time Max Ms", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "duration", "javaType": "long", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "3s", "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The maximum amount [...]
"logMiningSleepTimeMinMs": { "index": 58, "kind": "property", "displayName": "Log Mining Sleep Time Min Ms", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "duration", "javaType": "long", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "0ms", "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The minimum amoun [...]
"logMiningStrategy": { "index": 59, "kind": "property", "displayName": "Log Mining Strategy", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "redo_log_catalog", "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "There are [...]
- "logMiningTransactionRetentionHours": { "index": 60, "kind": "property", "displayName": "Log Mining Transaction Retention Hours", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "integer", "javaType": "long", "deprecated": false, "autowired": false, "secret": false, "defaultValue": 0, "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "H [...]
+ "logMiningTransactionRetentionMs": { "index": 60, "kind": "property", "displayName": "Log Mining Transaction Retention Ms", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "duration", "javaType": "long", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "0ms", "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Du [...]
"logMiningUsernameExcludeList": { "index": 61, "kind": "property", "displayName": "Log Mining Username Exclude List", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Comma separated list [...]
"maxBatchSize": { "index": 62, "kind": "property", "displayName": "Max Batch Size", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "integer", "javaType": "int", "deprecated": false, "autowired": false, "secret": false, "defaultValue": 2048, "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Maximum size of each batch of source records. [...]
"maxQueueSize": { "index": 63, "kind": "property", "displayName": "Max Queue Size", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "integer", "javaType": "int", "deprecated": false, "autowired": false, "secret": false, "defaultValue": 8192, "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Maximum size of the queue for change events r [...]
@@ -190,7 +190,7 @@
"logMiningSleepTimeMaxMs": { "index": 58, "kind": "parameter", "displayName": "Log Mining Sleep Time Max Ms", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "duration", "javaType": "long", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "3s", "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The maximum amoun [...]
"logMiningSleepTimeMinMs": { "index": 59, "kind": "parameter", "displayName": "Log Mining Sleep Time Min Ms", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "duration", "javaType": "long", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "0ms", "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The minimum amou [...]
"logMiningStrategy": { "index": 60, "kind": "parameter", "displayName": "Log Mining Strategy", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "redo_log_catalog", "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "There ar [...]
- "logMiningTransactionRetentionHours": { "index": 61, "kind": "parameter", "displayName": "Log Mining Transaction Retention Hours", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "integer", "javaType": "long", "deprecated": false, "autowired": false, "secret": false, "defaultValue": 0, "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": " [...]
+ "logMiningTransactionRetentionMs": { "index": 61, "kind": "parameter", "displayName": "Log Mining Transaction Retention Ms", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "duration", "javaType": "long", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "0ms", "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "D [...]
"logMiningUsernameExcludeList": { "index": 62, "kind": "parameter", "displayName": "Log Mining Username Exclude List", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Comma separated list [...]
"maxBatchSize": { "index": 63, "kind": "parameter", "displayName": "Max Batch Size", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "integer", "javaType": "int", "deprecated": false, "autowired": false, "secret": false, "defaultValue": 2048, "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Maximum size of each batch of source records [...]
"maxQueueSize": { "index": 64, "kind": "parameter", "displayName": "Max Queue Size", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "integer", "javaType": "int", "deprecated": false, "autowired": false, "secret": false, "defaultValue": 8192, "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Maximum size of the queue for change events [...]
diff --git a/parent/pom.xml b/parent/pom.xml
index a6a03e2cd51..d6569e7738f 100644
--- a/parent/pom.xml
+++ b/parent/pom.xml
@@ -123,7 +123,7 @@
<cxf-xjc-plugin-version>4.0.0</cxf-xjc-plugin-version>
<cxf-xjc-utils-version>4.0.0</cxf-xjc-utils-version>
<datasonnet-mapper-version>2.5.2-jakarta4</datasonnet-mapper-version>
- <debezium-version>2.2.0.Final</debezium-version>
+ <debezium-version>2.2.1.Final</debezium-version>
<debezium-mysql-connector-version>8.0.32</debezium-mysql-connector-version>
<depends-maven-plugin-version>1.4.0</depends-maven-plugin-version>
<derby-version>10.14.2.0</derby-version>
[camel] 02/02: Upgrade to debezium 2.2.1
Posted by da...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
davsclaus pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel.git
commit aef3b6b990477e826e42938657fa0be181939dcd
Author: Claus Ibsen <cl...@gmail.com>
AuthorDate: Wed May 24 09:17:28 2023 +0200
Upgrade to debezium 2.2.1
---
.../camel/catalog/components/debezium-oracle.json | 4 ++--
.../dsl/DebeziumOracleComponentBuilderFactory.java | 17 +++++++++--------
2 files changed, 11 insertions(+), 10 deletions(-)
diff --git a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/debezium-oracle.json b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/debezium-oracle.json
index ea417aa714a..8477fa8cb51 100644
--- a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/debezium-oracle.json
+++ b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/debezium-oracle.json
@@ -82,7 +82,7 @@
"logMiningSleepTimeMaxMs": { "index": 57, "kind": "property", "displayName": "Log Mining Sleep Time Max Ms", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "duration", "javaType": "long", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "3s", "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The maximum amount [...]
"logMiningSleepTimeMinMs": { "index": 58, "kind": "property", "displayName": "Log Mining Sleep Time Min Ms", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "duration", "javaType": "long", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "0ms", "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The minimum amoun [...]
"logMiningStrategy": { "index": 59, "kind": "property", "displayName": "Log Mining Strategy", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "redo_log_catalog", "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "There are [...]
- "logMiningTransactionRetentionHours": { "index": 60, "kind": "property", "displayName": "Log Mining Transaction Retention Hours", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "integer", "javaType": "long", "deprecated": false, "autowired": false, "secret": false, "defaultValue": 0, "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "H [...]
+ "logMiningTransactionRetentionMs": { "index": 60, "kind": "property", "displayName": "Log Mining Transaction Retention Ms", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "duration", "javaType": "long", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "0ms", "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Du [...]
"logMiningUsernameExcludeList": { "index": 61, "kind": "property", "displayName": "Log Mining Username Exclude List", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Comma separated list [...]
"maxBatchSize": { "index": 62, "kind": "property", "displayName": "Max Batch Size", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "integer", "javaType": "int", "deprecated": false, "autowired": false, "secret": false, "defaultValue": 2048, "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Maximum size of each batch of source records. [...]
"maxQueueSize": { "index": 63, "kind": "property", "displayName": "Max Queue Size", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "integer", "javaType": "int", "deprecated": false, "autowired": false, "secret": false, "defaultValue": 8192, "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Maximum size of the queue for change events r [...]
@@ -190,7 +190,7 @@
"logMiningSleepTimeMaxMs": { "index": 58, "kind": "parameter", "displayName": "Log Mining Sleep Time Max Ms", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "duration", "javaType": "long", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "3s", "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The maximum amoun [...]
"logMiningSleepTimeMinMs": { "index": 59, "kind": "parameter", "displayName": "Log Mining Sleep Time Min Ms", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "duration", "javaType": "long", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "0ms", "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The minimum amou [...]
"logMiningStrategy": { "index": 60, "kind": "parameter", "displayName": "Log Mining Strategy", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "redo_log_catalog", "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "There ar [...]
- "logMiningTransactionRetentionHours": { "index": 61, "kind": "parameter", "displayName": "Log Mining Transaction Retention Hours", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "integer", "javaType": "long", "deprecated": false, "autowired": false, "secret": false, "defaultValue": 0, "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": " [...]
+ "logMiningTransactionRetentionMs": { "index": 61, "kind": "parameter", "displayName": "Log Mining Transaction Retention Ms", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "duration", "javaType": "long", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "0ms", "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "D [...]
"logMiningUsernameExcludeList": { "index": 62, "kind": "parameter", "displayName": "Log Mining Username Exclude List", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Comma separated list [...]
"maxBatchSize": { "index": 63, "kind": "parameter", "displayName": "Max Batch Size", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "integer", "javaType": "int", "deprecated": false, "autowired": false, "secret": false, "defaultValue": 2048, "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Maximum size of each batch of source records [...]
"maxQueueSize": { "index": 64, "kind": "parameter", "displayName": "Max Queue Size", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "integer", "javaType": "int", "deprecated": false, "autowired": false, "secret": false, "defaultValue": 8192, "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Maximum size of the queue for change events [...]
diff --git a/dsl/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/DebeziumOracleComponentBuilderFactory.java b/dsl/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/DebeziumOracleComponentBuilderFactory.java
index 50b25f0c385..5090434aa4f 100644
--- a/dsl/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/DebeziumOracleComponentBuilderFactory.java
+++ b/dsl/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/DebeziumOracleComponentBuilderFactory.java
@@ -1115,20 +1115,21 @@ public interface DebeziumOracleComponentBuilderFactory {
return this;
}
/**
- * Hours to keep long running transactions in transaction buffer between
- * log mining sessions. By default, all transactions are retained.
+ * Duration in milliseconds to keep long running transactions in
+ * transaction buffer between log mining sessions. By default, all
+ * transactions are retained.
*
* The option is a: <code>long</code> type.
*
- * Default: 0
+ * Default: 0ms
* Group: oracle
*
- * @param logMiningTransactionRetentionHours the value to set
+ * @param logMiningTransactionRetentionMs the value to set
* @return the dsl builder
*/
- default DebeziumOracleComponentBuilder logMiningTransactionRetentionHours(
- long logMiningTransactionRetentionHours) {
- doSetProperty("logMiningTransactionRetentionHours", logMiningTransactionRetentionHours);
+ default DebeziumOracleComponentBuilder logMiningTransactionRetentionMs(
+ long logMiningTransactionRetentionMs) {
+ doSetProperty("logMiningTransactionRetentionMs", logMiningTransactionRetentionMs);
return this;
}
/**
@@ -1857,7 +1858,7 @@ public interface DebeziumOracleComponentBuilderFactory {
case "logMiningSleepTimeMaxMs": getOrCreateConfiguration((DebeziumOracleComponent) component).setLogMiningSleepTimeMaxMs((long) value); return true;
case "logMiningSleepTimeMinMs": getOrCreateConfiguration((DebeziumOracleComponent) component).setLogMiningSleepTimeMinMs((long) value); return true;
case "logMiningStrategy": getOrCreateConfiguration((DebeziumOracleComponent) component).setLogMiningStrategy((java.lang.String) value); return true;
- case "logMiningTransactionRetentionHours": getOrCreateConfiguration((DebeziumOracleComponent) component).setLogMiningTransactionRetentionHours((long) value); return true;
+ case "logMiningTransactionRetentionMs": getOrCreateConfiguration((DebeziumOracleComponent) component).setLogMiningTransactionRetentionMs((long) value); return true;
case "logMiningUsernameExcludeList": getOrCreateConfiguration((DebeziumOracleComponent) component).setLogMiningUsernameExcludeList((java.lang.String) value); return true;
case "maxBatchSize": getOrCreateConfiguration((DebeziumOracleComponent) component).setMaxBatchSize((int) value); return true;
case "maxQueueSize": getOrCreateConfiguration((DebeziumOracleComponent) component).setMaxQueueSize((int) value); return true;