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
The following commit(s) were added to refs/heads/main by this push:
new 66cb9d29df42 Regen
66cb9d29df42 is described below
commit 66cb9d29df424bed064fd1d1c8a718ff4444fa41
Author: Claus Ibsen <[email protected]>
AuthorDate: Thu Aug 6 16:14:58 2026 +0200
Regen
---
.../dsl/DebeziumDb2ComponentBuilderFactory.java | 23 +++++++++++++++++++++-
.../DebeziumMongodbComponentBuilderFactory.java | 23 +++++++++++++++++++++-
.../dsl/DebeziumMysqlComponentBuilderFactory.java | 23 +++++++++++++++++++++-
.../dsl/DebeziumOracleComponentBuilderFactory.java | 23 +++++++++++++++++++++-
.../DebeziumPostgresComponentBuilderFactory.java | 23 +++++++++++++++++++++-
.../DebeziumSqlserverComponentBuilderFactory.java | 23 +++++++++++++++++++++-
6 files changed, 132 insertions(+), 6 deletions(-)
diff --git
a/dsl/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/DebeziumDb2ComponentBuilderFactory.java
b/dsl/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/DebeziumDb2ComponentBuilderFactory.java
index 376c24f2c274..1fc1b647d464 100644
---
a/dsl/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/DebeziumDb2ComponentBuilderFactory.java
+++
b/dsl/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/DebeziumDb2ComponentBuilderFactory.java
@@ -458,7 +458,7 @@ public interface DebeziumDb2ComponentBuilderFactory {
* The option is a: <code>java.lang.String</code> type.
*
* Default:
- *
.*secret$|.*password$|.*sasl\.jaas\.config$|.*basic\.auth\.user\.info|.*registry\.auth\.client-secret|.*credentials\.json$
+ *
.*secret$|.*password$|.*sasl\.jaas\.config$|.*basic\.auth\.user\.info|.*registry\.auth\.client-secret|.*credentials\.json$|.*connectionstring$|.*connection\.string$
* Group: db2
*
* @param customSanitizePattern the value to set
@@ -824,6 +824,26 @@ public interface DebeziumDb2ComponentBuilderFactory {
}
+ /**
+ * When enabled, uses the legacy table-per-thread parallel snapshot
+ * algorithm. When set to false (the default), tables are split into
+ * chunks and processed across all snapshot threads, allowing for
higher
+ * concurrency for snapshots.
+ *
+ * The option is a: <code>boolean</code> type.
+ *
+ * Default: false
+ * Group: db2
+ *
+ * @param legacySnapshotMaxThreads the value to set
+ * @return the dsl builder
+ */
+ default DebeziumDb2ComponentBuilder legacySnapshotMaxThreads(boolean
legacySnapshotMaxThreads) {
+ doSetProperty("legacySnapshotMaxThreads",
legacySnapshotMaxThreads);
+ return this;
+ }
+
+
/**
* Maximum size of each batch of source records. Defaults to 2048.
*
@@ -1917,6 +1937,7 @@ public interface DebeziumDb2ComponentBuilderFactory {
case "includeSchemaChanges":
getOrCreateConfiguration((DebeziumDb2Component)
component).setIncludeSchemaChanges((boolean) value); return true;
case "incrementalSnapshotChunkSize":
getOrCreateConfiguration((DebeziumDb2Component)
component).setIncrementalSnapshotChunkSize((int) value); return true;
case "incrementalSnapshotWatermarkingStrategy":
getOrCreateConfiguration((DebeziumDb2Component)
component).setIncrementalSnapshotWatermarkingStrategy((java.lang.String)
value); return true;
+ case "legacySnapshotMaxThreads":
getOrCreateConfiguration((DebeziumDb2Component)
component).setLegacySnapshotMaxThreads((boolean) value); return true;
case "maxBatchSize":
getOrCreateConfiguration((DebeziumDb2Component)
component).setMaxBatchSize((int) value); return true;
case "maxQueueSize":
getOrCreateConfiguration((DebeziumDb2Component)
component).setMaxQueueSize((int) value); return true;
case "maxQueueSizeInBytes":
getOrCreateConfiguration((DebeziumDb2Component)
component).setMaxQueueSizeInBytes((long) value); return true;
diff --git
a/dsl/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/DebeziumMongodbComponentBuilderFactory.java
b/dsl/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/DebeziumMongodbComponentBuilderFactory.java
index 1e86a7066c0b..bed635a39bdd 100644
---
a/dsl/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/DebeziumMongodbComponentBuilderFactory.java
+++
b/dsl/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/DebeziumMongodbComponentBuilderFactory.java
@@ -443,7 +443,7 @@ public interface DebeziumMongodbComponentBuilderFactory {
* The option is a: <code>java.lang.String</code> type.
*
* Default:
- *
.*secret$|.*password$|.*sasl\.jaas\.config$|.*basic\.auth\.user\.info|.*registry\.auth\.client-secret|.*credentials\.json$
+ *
.*secret$|.*password$|.*sasl\.jaas\.config$|.*basic\.auth\.user\.info|.*registry\.auth\.client-secret|.*credentials\.json$|.*connectionstring$|.*connection\.string$
* Group: mongodb
*
* @param customSanitizePattern the value to set
@@ -693,6 +693,26 @@ public interface DebeziumMongodbComponentBuilderFactory {
}
+ /**
+ * When enabled, uses the legacy table-per-thread parallel snapshot
+ * algorithm. When set to false (the default), tables are split into
+ * chunks and processed across all snapshot threads, allowing for
higher
+ * concurrency for snapshots.
+ *
+ * The option is a: <code>boolean</code> type.
+ *
+ * Default: false
+ * Group: mongodb
+ *
+ * @param legacySnapshotMaxThreads the value to set
+ * @return the dsl builder
+ */
+ default DebeziumMongodbComponentBuilder
legacySnapshotMaxThreads(boolean legacySnapshotMaxThreads) {
+ doSetProperty("legacySnapshotMaxThreads",
legacySnapshotMaxThreads);
+ return this;
+ }
+
+
/**
* Maximum size of each batch of source records. Defaults to 2048.
*
@@ -1710,6 +1730,7 @@ public interface DebeziumMongodbComponentBuilderFactory {
case "heartbeatIntervalMs":
getOrCreateConfiguration((DebeziumMongodbComponent)
component).setHeartbeatIntervalMs((int) value); return true;
case "heartbeatTopicsPrefix":
getOrCreateConfiguration((DebeziumMongodbComponent)
component).setHeartbeatTopicsPrefix((java.lang.String) value); return true;
case "incrementalSnapshotWatermarkingStrategy":
getOrCreateConfiguration((DebeziumMongodbComponent)
component).setIncrementalSnapshotWatermarkingStrategy((java.lang.String)
value); return true;
+ case "legacySnapshotMaxThreads":
getOrCreateConfiguration((DebeziumMongodbComponent)
component).setLegacySnapshotMaxThreads((boolean) value); return true;
case "maxBatchSize":
getOrCreateConfiguration((DebeziumMongodbComponent)
component).setMaxBatchSize((int) value); return true;
case "maxQueueSize":
getOrCreateConfiguration((DebeziumMongodbComponent)
component).setMaxQueueSize((int) value); return true;
case "maxQueueSizeInBytes":
getOrCreateConfiguration((DebeziumMongodbComponent)
component).setMaxQueueSizeInBytes((long) value); return true;
diff --git
a/dsl/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/DebeziumMysqlComponentBuilderFactory.java
b/dsl/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/DebeziumMysqlComponentBuilderFactory.java
index 72dc576450cb..d5bc8feddb08 100644
---
a/dsl/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/DebeziumMysqlComponentBuilderFactory.java
+++
b/dsl/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/DebeziumMysqlComponentBuilderFactory.java
@@ -554,7 +554,7 @@ public interface DebeziumMysqlComponentBuilderFactory {
* The option is a: <code>java.lang.String</code> type.
*
* Default:
- *
.*secret$|.*password$|.*sasl\.jaas\.config$|.*basic\.auth\.user\.info|.*registry\.auth\.client-secret|.*credentials\.json$
+ *
.*secret$|.*password$|.*sasl\.jaas\.config$|.*basic\.auth\.user\.info|.*registry\.auth\.client-secret|.*credentials\.json$|.*connectionstring$|.*connection\.string$
* Group: mysql
*
* @param customSanitizePattern the value to set
@@ -1359,6 +1359,26 @@ public interface DebeziumMysqlComponentBuilderFactory {
}
+ /**
+ * When enabled, uses the legacy table-per-thread parallel snapshot
+ * algorithm. When set to false (the default), tables are split into
+ * chunks and processed across all snapshot threads, allowing for
higher
+ * concurrency for snapshots.
+ *
+ * The option is a: <code>boolean</code> type.
+ *
+ * Default: false
+ * Group: mysql
+ *
+ * @param legacySnapshotMaxThreads the value to set
+ * @return the dsl builder
+ */
+ default DebeziumMysqlComponentBuilder legacySnapshotMaxThreads(boolean
legacySnapshotMaxThreads) {
+ doSetProperty("legacySnapshotMaxThreads",
legacySnapshotMaxThreads);
+ return this;
+ }
+
+
/**
* Maximum size of each batch of source records. Defaults to 2048.
*
@@ -2608,6 +2628,7 @@ public interface DebeziumMysqlComponentBuilderFactory {
case "incrementalSnapshotAllowSchemaChanges":
getOrCreateConfiguration((DebeziumMySqlComponent)
component).setIncrementalSnapshotAllowSchemaChanges((boolean) value); return
true;
case "incrementalSnapshotChunkSize":
getOrCreateConfiguration((DebeziumMySqlComponent)
component).setIncrementalSnapshotChunkSize((int) value); return true;
case "incrementalSnapshotWatermarkingStrategy":
getOrCreateConfiguration((DebeziumMySqlComponent)
component).setIncrementalSnapshotWatermarkingStrategy((java.lang.String)
value); return true;
+ case "legacySnapshotMaxThreads":
getOrCreateConfiguration((DebeziumMySqlComponent)
component).setLegacySnapshotMaxThreads((boolean) value); return true;
case "maxBatchSize":
getOrCreateConfiguration((DebeziumMySqlComponent)
component).setMaxBatchSize((int) value); return true;
case "maxQueueSize":
getOrCreateConfiguration((DebeziumMySqlComponent)
component).setMaxQueueSize((int) value); return true;
case "maxQueueSizeInBytes":
getOrCreateConfiguration((DebeziumMySqlComponent)
component).setMaxQueueSizeInBytes((long) value); return true;
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 be7fe17d5755..ab9c9ab1ba1f 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
@@ -498,7 +498,7 @@ public interface DebeziumOracleComponentBuilderFactory {
* The option is a: <code>java.lang.String</code> type.
*
* Default:
- *
.*secret$|.*password$|.*sasl\.jaas\.config$|.*basic\.auth\.user\.info|.*registry\.auth\.client-secret|.*credentials\.json$
+ *
.*secret$|.*password$|.*sasl\.jaas\.config$|.*basic\.auth\.user\.info|.*registry\.auth\.client-secret|.*credentials\.json$|.*connectionstring$|.*connection\.string$
* Group: oracle
*
* @param customSanitizePattern the value to set
@@ -988,6 +988,26 @@ public interface DebeziumOracleComponentBuilderFactory {
}
+ /**
+ * When enabled, uses the legacy table-per-thread parallel snapshot
+ * algorithm. When set to false (the default), tables are split into
+ * chunks and processed across all snapshot threads, allowing for
higher
+ * concurrency for snapshots.
+ *
+ * The option is a: <code>boolean</code> type.
+ *
+ * Default: false
+ * Group: oracle
+ *
+ * @param legacySnapshotMaxThreads the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleComponentBuilder
legacySnapshotMaxThreads(boolean legacySnapshotMaxThreads) {
+ doSetProperty("legacySnapshotMaxThreads",
legacySnapshotMaxThreads);
+ return this;
+ }
+
+
/**
* When set to 'false', the default, LOB fields will not be captured
nor
* emitted. When set to 'true', the connector will capture LOB fields
@@ -3082,6 +3102,7 @@ public interface DebeziumOracleComponentBuilderFactory {
case "incrementalSnapshotWatermarkingStrategy":
getOrCreateConfiguration((DebeziumOracleComponent)
component).setIncrementalSnapshotWatermarkingStrategy((java.lang.String)
value); return true;
case "intervalHandlingMode":
getOrCreateConfiguration((DebeziumOracleComponent)
component).setIntervalHandlingMode((java.lang.String) value); return true;
case "legacyDecimalHandlingStrategy":
getOrCreateConfiguration((DebeziumOracleComponent)
component).setLegacyDecimalHandlingStrategy((boolean) value); return true;
+ case "legacySnapshotMaxThreads":
getOrCreateConfiguration((DebeziumOracleComponent)
component).setLegacySnapshotMaxThreads((boolean) value); return true;
case "lobEnabled":
getOrCreateConfiguration((DebeziumOracleComponent)
component).setLobEnabled((boolean) value); return true;
case "logMiningArchiveLogOnlyMode":
getOrCreateConfiguration((DebeziumOracleComponent)
component).setLogMiningArchiveLogOnlyMode((boolean) value); return true;
case "logMiningArchiveLogOnlyScnPollIntervalMs":
getOrCreateConfiguration((DebeziumOracleComponent)
component).setLogMiningArchiveLogOnlyScnPollIntervalMs((long) value); return
true;
diff --git
a/dsl/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/DebeziumPostgresComponentBuilderFactory.java
b/dsl/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/DebeziumPostgresComponentBuilderFactory.java
index 6b8f0584d5f2..8a0a0132824e 100644
---
a/dsl/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/DebeziumPostgresComponentBuilderFactory.java
+++
b/dsl/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/DebeziumPostgresComponentBuilderFactory.java
@@ -444,7 +444,7 @@ public interface DebeziumPostgresComponentBuilderFactory {
* The option is a: <code>java.lang.String</code> type.
*
* Default:
- *
.*secret$|.*password$|.*sasl\.jaas\.config$|.*basic\.auth\.user\.info|.*registry\.auth\.client-secret|.*credentials\.json$
+ *
.*secret$|.*password$|.*sasl\.jaas\.config$|.*basic\.auth\.user\.info|.*registry\.auth\.client-secret|.*credentials\.json$|.*connectionstring$|.*connection\.string$
* Group: postgres
*
* @param customSanitizePattern the value to set
@@ -1027,6 +1027,26 @@ public interface DebeziumPostgresComponentBuilderFactory
{
return this;
}
+
+ /**
+ * When enabled, uses the legacy table-per-thread parallel snapshot
+ * algorithm. When set to false (the default), tables are split into
+ * chunks and processed across all snapshot threads, allowing for
higher
+ * concurrency for snapshots.
+ *
+ * The option is a: <code>boolean</code> type.
+ *
+ * Default: false
+ * Group: postgres
+ *
+ * @param legacySnapshotMaxThreads the value to set
+ * @return the dsl builder
+ */
+ default DebeziumPostgresComponentBuilder
legacySnapshotMaxThreads(boolean legacySnapshotMaxThreads) {
+ doSetProperty("legacySnapshotMaxThreads",
legacySnapshotMaxThreads);
+ return this;
+ }
+
/**
* Determines the LSN flushing strategy. Options include: 'connector'
* (default) for Debezium managed LSN flushing (replaces deprecated
@@ -2622,6 +2642,7 @@ public interface DebeziumPostgresComponentBuilderFactory {
case "incrementalSnapshotChunkSize":
getOrCreateConfiguration((DebeziumPostgresComponent)
component).setIncrementalSnapshotChunkSize((int) value); return true;
case "incrementalSnapshotWatermarkingStrategy":
getOrCreateConfiguration((DebeziumPostgresComponent)
component).setIncrementalSnapshotWatermarkingStrategy((java.lang.String)
value); return true;
case "intervalHandlingMode":
getOrCreateConfiguration((DebeziumPostgresComponent)
component).setIntervalHandlingMode((java.lang.String) value); return true;
+ case "legacySnapshotMaxThreads":
getOrCreateConfiguration((DebeziumPostgresComponent)
component).setLegacySnapshotMaxThreads((boolean) value); return true;
case "lsnFlushMode":
getOrCreateConfiguration((DebeziumPostgresComponent)
component).setLsnFlushMode((java.lang.String) value); return true;
case "lsnFlushTimeoutAction":
getOrCreateConfiguration((DebeziumPostgresComponent)
component).setLsnFlushTimeoutAction((java.lang.String) value); return true;
case "lsnFlushTimeoutMs":
getOrCreateConfiguration((DebeziumPostgresComponent)
component).setLsnFlushTimeoutMs((long) value); return true;
diff --git
a/dsl/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/DebeziumSqlserverComponentBuilderFactory.java
b/dsl/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/DebeziumSqlserverComponentBuilderFactory.java
index a9e3fc55c14e..8035a33929c0 100644
---
a/dsl/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/DebeziumSqlserverComponentBuilderFactory.java
+++
b/dsl/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/DebeziumSqlserverComponentBuilderFactory.java
@@ -444,7 +444,7 @@ public interface DebeziumSqlserverComponentBuilderFactory {
* The option is a: <code>java.lang.String</code> type.
*
* Default:
- *
.*secret$|.*password$|.*sasl\.jaas\.config$|.*basic\.auth\.user\.info|.*registry\.auth\.client-secret|.*credentials\.json$
+ *
.*secret$|.*password$|.*sasl\.jaas\.config$|.*basic\.auth\.user\.info|.*registry\.auth\.client-secret|.*credentials\.json$|.*connectionstring$|.*connection\.string$
* Group: sqlserver
*
* @param customSanitizePattern the value to set
@@ -923,6 +923,26 @@ public interface DebeziumSqlserverComponentBuilderFactory {
}
+ /**
+ * When enabled, uses the legacy table-per-thread parallel snapshot
+ * algorithm. When set to false (the default), tables are split into
+ * chunks and processed across all snapshot threads, allowing for
higher
+ * concurrency for snapshots.
+ *
+ * The option is a: <code>boolean</code> type.
+ *
+ * Default: false
+ * Group: sqlserver
+ *
+ * @param legacySnapshotMaxThreads the value to set
+ * @return the dsl builder
+ */
+ default DebeziumSqlserverComponentBuilder
legacySnapshotMaxThreads(boolean legacySnapshotMaxThreads) {
+ doSetProperty("legacySnapshotMaxThreads",
legacySnapshotMaxThreads);
+ return this;
+ }
+
+
/**
* Maximum size of each batch of source records. Defaults to 2048.
*
@@ -2098,6 +2118,7 @@ public interface DebeziumSqlserverComponentBuilderFactory
{
case "incrementalSnapshotChunkSize":
getOrCreateConfiguration((DebeziumSqlserverComponent)
component).setIncrementalSnapshotChunkSize((int) value); return true;
case "incrementalSnapshotOptionRecompile":
getOrCreateConfiguration((DebeziumSqlserverComponent)
component).setIncrementalSnapshotOptionRecompile((boolean) value); return true;
case "incrementalSnapshotWatermarkingStrategy":
getOrCreateConfiguration((DebeziumSqlserverComponent)
component).setIncrementalSnapshotWatermarkingStrategy((java.lang.String)
value); return true;
+ case "legacySnapshotMaxThreads":
getOrCreateConfiguration((DebeziumSqlserverComponent)
component).setLegacySnapshotMaxThreads((boolean) value); return true;
case "maxBatchSize":
getOrCreateConfiguration((DebeziumSqlserverComponent)
component).setMaxBatchSize((int) value); return true;
case "maxIterationTransactions":
getOrCreateConfiguration((DebeziumSqlserverComponent)
component).setMaxIterationTransactions((int) value); return true;
case "maxQueueSize":
getOrCreateConfiguration((DebeziumSqlserverComponent)
component).setMaxQueueSize((int) value); return true;
