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
The following commit(s) were added to refs/heads/main by this push:
new 0734e92b015 Regen for commit 7a21dcf5b117936a7bd81c5a1f575faef72bb716
0734e92b015 is described below
commit 0734e92b0155c798573a5775387b19f6cafc648f
Author: oscerd <[email protected]>
AuthorDate: Fri Apr 21 09:15:43 2023 +0000
Regen for commit 7a21dcf5b117936a7bd81c5a1f575faef72bb716
Signed-off-by: GitHub <[email protected]>
---
.../dsl/DebeziumDb2ComponentBuilderFactory.java | 64 ++++--
.../DebeziumMongodbComponentBuilderFactory.java | 138 +++----------
.../dsl/DebeziumMysqlComponentBuilderFactory.java | 64 ++++--
.../dsl/DebeziumOracleComponentBuilderFactory.java | 69 +++++--
.../DebeziumPostgresComponentBuilderFactory.java | 43 ++--
.../DebeziumSqlserverComponentBuilderFactory.java | 82 ++++++--
.../dsl/DebeziumDb2EndpointBuilderFactory.java | 99 +++++----
.../dsl/DebeziumMongodbEndpointBuilderFactory.java | 223 +++------------------
.../dsl/DebeziumMySqlEndpointBuilderFactory.java | 99 +++++----
.../dsl/DebeziumOracleEndpointBuilderFactory.java | 109 ++++++----
.../DebeziumPostgresEndpointBuilderFactory.java | 58 +++---
.../DebeziumSqlserverEndpointBuilderFactory.java | 133 ++++++++----
.../dsl/IgniteCacheEndpointBuilderFactory.java | 7 +-
13 files changed, 605 insertions(+), 583 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 52add2705bc..fdb77fb03aa 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
@@ -715,22 +715,6 @@ public interface DebeziumDb2ComponentBuilderFactory {
doSetProperty("retriableRestartConnectorWaitMs",
retriableRestartConnectorWaitMs);
return this;
}
- /**
- * Whether field names will be sanitized to Avro naming conventions.
- *
- * The option is a: <code>boolean</code> type.
- *
- * Default: false
- * Group: db2
- *
- * @param sanitizeFieldNames the value to set
- * @return the dsl builder
- */
- default DebeziumDb2ComponentBuilder sanitizeFieldNames(
- boolean sanitizeFieldNames) {
- doSetProperty("sanitizeFieldNames", sanitizeFieldNames);
- return this;
- }
/**
* The name of the SchemaHistory class that should be used to store and
* recover database schema changes. The configuration properties for
the
@@ -785,6 +769,26 @@ public interface DebeziumDb2ComponentBuilderFactory {
doSetProperty("schemaHistoryInternalSkipUnparseableDdl",
schemaHistoryInternalSkipUnparseableDdl);
return this;
}
+ /**
+ * Controls what DDL will Debezium store in database schema history. By
+ * default (true) only DDL that manipulates a table from captured
+ * schema/database will be stored. If set to false, then Debezium will
+ * store all incoming DDL statements.
+ *
+ * The option is a: <code>boolean</code> type.
+ *
+ * Default: false
+ * Group: db2
+ *
+ * @param schemaHistoryInternalStoreOnlyCapturedDatabasesDdl the value
+ * to set
+ * @return the dsl builder
+ */
+ default DebeziumDb2ComponentBuilder
schemaHistoryInternalStoreOnlyCapturedDatabasesDdl(
+ boolean schemaHistoryInternalStoreOnlyCapturedDatabasesDdl) {
+
doSetProperty("schemaHistoryInternalStoreOnlyCapturedDatabasesDdl",
schemaHistoryInternalStoreOnlyCapturedDatabasesDdl);
+ return this;
+ }
/**
* Controls what DDL will Debezium store in database schema history. By
* default (false) Debezium will store all incoming DDL statements. If
@@ -809,7 +813,10 @@ public interface DebeziumDb2ComponentBuilderFactory {
* Specify how schema names should be adjusted for compatibility with
* the message converter used by the connector, including: 'avro'
* replaces the characters that cannot be used in the Avro type name
- * with underscore; 'none' does not apply any adjustment (default).
+ * with underscore; 'avro_unicode' replaces the underscore or
characters
+ * that cannot be used in the Avro type name with corresponding unicode
+ * like _uxxxx. Note: _ is an escape sequence like backslash in
+ * Java;'none' does not apply any adjustment (default).
*
* The option is a: <code>java.lang.String</code> type.
*
@@ -972,6 +979,26 @@ public interface DebeziumDb2ComponentBuilderFactory {
doSetProperty("snapshotSelectStatementOverrides",
snapshotSelectStatementOverrides);
return this;
}
+ /**
+ * Controls the order in which tables are processed in the initial
+ * snapshot. A descending value will order the tables by row count
+ * descending. A ascending value will order the tables by row count
+ * ascending. A value of disabled (the default) will disable ordering
by
+ * row count.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Default: disabled
+ * Group: db2
+ *
+ * @param snapshotTablesOrderByRowCount the value to set
+ * @return the dsl builder
+ */
+ default DebeziumDb2ComponentBuilder snapshotTablesOrderByRowCount(
+ java.lang.String snapshotTablesOrderByRowCount) {
+ doSetProperty("snapshotTablesOrderByRowCount",
snapshotTablesOrderByRowCount);
+ return this;
+ }
/**
* A comma-separated list of regular expressions that match the
* fully-qualified names of tables to be excluded from monitoring.
@@ -1162,10 +1189,10 @@ public interface DebeziumDb2ComponentBuilderFactory {
case "provideTransactionMetadata":
getOrCreateConfiguration((DebeziumDb2Component)
component).setProvideTransactionMetadata((boolean) value); return true;
case "queryFetchSize":
getOrCreateConfiguration((DebeziumDb2Component)
component).setQueryFetchSize((int) value); return true;
case "retriableRestartConnectorWaitMs":
getOrCreateConfiguration((DebeziumDb2Component)
component).setRetriableRestartConnectorWaitMs((long) value); return true;
- case "sanitizeFieldNames":
getOrCreateConfiguration((DebeziumDb2Component)
component).setSanitizeFieldNames((boolean) value); return true;
case "schemaHistoryInternal":
getOrCreateConfiguration((DebeziumDb2Component)
component).setSchemaHistoryInternal((java.lang.String) value); return true;
case "schemaHistoryInternalFileFilename":
getOrCreateConfiguration((DebeziumDb2Component)
component).setSchemaHistoryInternalFileFilename((java.lang.String) value);
return true;
case "schemaHistoryInternalSkipUnparseableDdl":
getOrCreateConfiguration((DebeziumDb2Component)
component).setSchemaHistoryInternalSkipUnparseableDdl((boolean) value); return
true;
+ case "schemaHistoryInternalStoreOnlyCapturedDatabasesDdl":
getOrCreateConfiguration((DebeziumDb2Component)
component).setSchemaHistoryInternalStoreOnlyCapturedDatabasesDdl((boolean)
value); return true;
case "schemaHistoryInternalStoreOnlyCapturedTablesDdl":
getOrCreateConfiguration((DebeziumDb2Component)
component).setSchemaHistoryInternalStoreOnlyCapturedTablesDdl((boolean) value);
return true;
case "schemaNameAdjustmentMode":
getOrCreateConfiguration((DebeziumDb2Component)
component).setSchemaNameAdjustmentMode((java.lang.String) value); return true;
case "signalDataCollection":
getOrCreateConfiguration((DebeziumDb2Component)
component).setSignalDataCollection((java.lang.String) value); return true;
@@ -1176,6 +1203,7 @@ public interface DebeziumDb2ComponentBuilderFactory {
case "snapshotLockTimeoutMs":
getOrCreateConfiguration((DebeziumDb2Component)
component).setSnapshotLockTimeoutMs((long) value); return true;
case "snapshotMode":
getOrCreateConfiguration((DebeziumDb2Component)
component).setSnapshotMode((java.lang.String) value); return true;
case "snapshotSelectStatementOverrides":
getOrCreateConfiguration((DebeziumDb2Component)
component).setSnapshotSelectStatementOverrides((java.lang.String) value);
return true;
+ case "snapshotTablesOrderByRowCount":
getOrCreateConfiguration((DebeziumDb2Component)
component).setSnapshotTablesOrderByRowCount((java.lang.String) value); return
true;
case "tableExcludeList":
getOrCreateConfiguration((DebeziumDb2Component)
component).setTableExcludeList((java.lang.String) value); return true;
case "tableIgnoreBuiltin":
getOrCreateConfiguration((DebeziumDb2Component)
component).setTableIgnoreBuiltin((boolean) value); return true;
case "tableIncludeList":
getOrCreateConfiguration((DebeziumDb2Component)
component).setTableIncludeList((java.lang.String) 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 49b9822c274..e5c7bdb764c 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
@@ -351,62 +351,6 @@ public interface DebeziumMongodbComponentBuilderFactory {
doSetProperty("collectionIncludeList", collectionIncludeList);
return this;
}
- /**
- * The initial delay when trying to reconnect to a primary after a
- * connection cannot be made or when no primary is available, given in
- * milliseconds. Defaults to 1 second (1,000 ms).
- *
- * The option is a: <code>long</code> type.
- *
- * Default: 1s
- * Group: mongodb
- *
- * @param connectBackoffInitialDelayMs the value to set
- * @return the dsl builder
- */
- default DebeziumMongodbComponentBuilder connectBackoffInitialDelayMs(
- long connectBackoffInitialDelayMs) {
- doSetProperty("connectBackoffInitialDelayMs",
connectBackoffInitialDelayMs);
- return this;
- }
- /**
- * The maximum delay when trying to reconnect to a primary after a
- * connection cannot be made or when no primary is available, given in
- * milliseconds. Defaults to 120 second (120,000 ms).
- *
- * The option is a: <code>long</code> type.
- *
- * Default: 2m
- * Group: mongodb
- *
- * @param connectBackoffMaxDelayMs the value to set
- * @return the dsl builder
- */
- default DebeziumMongodbComponentBuilder connectBackoffMaxDelayMs(
- long connectBackoffMaxDelayMs) {
- doSetProperty("connectBackoffMaxDelayMs",
connectBackoffMaxDelayMs);
- return this;
- }
- /**
- * Maximum number of failed connection attempts to a replica set
primary
- * before an exception occurs and task is aborted. Defaults to 16,
which
- * with the defaults for 'connect.backoff.initial.delay.ms' and
- * 'connect.backoff.max.delay.ms' results in just over 20 minutes of
- * attempts before failing.
- *
- * The option is a: <code>int</code> type.
- *
- * Default: 16
- * Group: mongodb
- *
- * @param connectMaxAttempts the value to set
- * @return the dsl builder
- */
- default DebeziumMongodbComponentBuilder connectMaxAttempts(
- int connectMaxAttempts) {
- doSetProperty("connectMaxAttempts", connectMaxAttempts);
- return this;
- }
/**
* Optional list of custom converters that would be used instead of
* default ones. The converters are defined using '.type' config option
@@ -628,6 +572,25 @@ public interface DebeziumMongodbComponentBuilderFactory {
doSetProperty("mongodbAuthsource", mongodbAuthsource);
return this;
}
+ /**
+ * The method used to connect to MongoDB cluster. Options include:
+ * 'replica_set' (the default) to individually connect to each replica
+ * set / shard 'sharded' to connect via single connection obtained from
+ * connection string.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Default: replica_set
+ * Group: mongodb
+ *
+ * @param mongodbConnectionMode the value to set
+ * @return the dsl builder
+ */
+ default DebeziumMongodbComponentBuilder mongodbConnectionMode(
+ java.lang.String mongodbConnectionMode) {
+ doSetProperty("mongodbConnectionMode", mongodbConnectionMode);
+ return this;
+ }
/**
* Database connection string.
*
@@ -677,41 +640,6 @@ public interface DebeziumMongodbComponentBuilderFactory {
doSetProperty("mongodbHeartbeatFrequencyMs",
mongodbHeartbeatFrequencyMs);
return this;
}
- /**
- * The hostname and port pairs (in the form 'host' or 'host:port') of
- * the MongoDB server(s) in the replica set.
- *
- * The option is a: <code>java.lang.String</code> type.
- *
- * Group: mongodb
- *
- * @param mongodbHosts the value to set
- * @return the dsl builder
- */
- default DebeziumMongodbComponentBuilder mongodbHosts(
- java.lang.String mongodbHosts) {
- doSetProperty("mongodbHosts", mongodbHosts);
- return this;
- }
- /**
- * 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 default is 'true'.
- *
- * The option is a: <code>boolean</code> type.
- *
- * Default: true
- * Group: mongodb
- *
- * @param mongodbMembersAutoDiscover the value to set
- * @return the dsl builder
- */
- default DebeziumMongodbComponentBuilder mongodbMembersAutoDiscover(
- boolean mongodbMembersAutoDiscover) {
- doSetProperty("mongodbMembersAutoDiscover",
mongodbMembersAutoDiscover);
- return this;
- }
/**
* Password to be used when connecting to MongoDB, if necessary.
*
@@ -892,22 +820,6 @@ public interface DebeziumMongodbComponentBuilderFactory {
doSetProperty("retriableRestartConnectorWaitMs",
retriableRestartConnectorWaitMs);
return this;
}
- /**
- * Whether field names will be sanitized to Avro naming conventions.
- *
- * The option is a: <code>boolean</code> type.
- *
- * Default: false
- * Group: mongodb
- *
- * @param sanitizeFieldNames the value to set
- * @return the dsl builder
- */
- default DebeziumMongodbComponentBuilder sanitizeFieldNames(
- boolean sanitizeFieldNames) {
- doSetProperty("sanitizeFieldNames", sanitizeFieldNames);
- return this;
- }
/**
* The path to the file that will be used to record the database schema
* history.
@@ -928,7 +840,10 @@ public interface DebeziumMongodbComponentBuilderFactory {
* Specify how schema names should be adjusted for compatibility with
* the message converter used by the connector, including: 'avro'
* replaces the characters that cannot be used in the Avro type name
- * with underscore; 'none' does not apply any adjustment (default).
+ * with underscore; 'avro_unicode' replaces the underscore or
characters
+ * that cannot be used in the Avro type name with corresponding unicode
+ * like _uxxxx. Note: _ is an escape sequence like backslash in
+ * Java;'none' does not apply any adjustment (default).
*
* The option is a: <code>java.lang.String</code> type.
*
@@ -1180,9 +1095,6 @@ public interface DebeziumMongodbComponentBuilderFactory {
case "captureMode":
getOrCreateConfiguration((DebeziumMongodbComponent)
component).setCaptureMode((java.lang.String) value); return true;
case "collectionExcludeList":
getOrCreateConfiguration((DebeziumMongodbComponent)
component).setCollectionExcludeList((java.lang.String) value); return true;
case "collectionIncludeList":
getOrCreateConfiguration((DebeziumMongodbComponent)
component).setCollectionIncludeList((java.lang.String) value); return true;
- case "connectBackoffInitialDelayMs":
getOrCreateConfiguration((DebeziumMongodbComponent)
component).setConnectBackoffInitialDelayMs((long) value); return true;
- 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;
@@ -1196,11 +1108,10 @@ public interface DebeziumMongodbComponentBuilderFactory
{
case "maxQueueSize":
getOrCreateConfiguration((DebeziumMongodbComponent)
component).setMaxQueueSize((int) value); return true;
case "maxQueueSizeInBytes":
getOrCreateConfiguration((DebeziumMongodbComponent)
component).setMaxQueueSizeInBytes((long) value); return true;
case "mongodbAuthsource":
getOrCreateConfiguration((DebeziumMongodbComponent)
component).setMongodbAuthsource((java.lang.String) value); return true;
+ case "mongodbConnectionMode":
getOrCreateConfiguration((DebeziumMongodbComponent)
component).setMongodbConnectionMode((java.lang.String) value); return true;
case "mongodbConnectionString":
getOrCreateConfiguration((DebeziumMongodbComponent)
component).setMongodbConnectionString((java.lang.String) value); return true;
case "mongodbConnectTimeoutMs":
getOrCreateConfiguration((DebeziumMongodbComponent)
component).setMongodbConnectTimeoutMs((int) value); return true;
case "mongodbHeartbeatFrequencyMs":
getOrCreateConfiguration((DebeziumMongodbComponent)
component).setMongodbHeartbeatFrequencyMs((int) value); return true;
- case "mongodbHosts":
getOrCreateConfiguration((DebeziumMongodbComponent)
component).setMongodbHosts((java.lang.String) value); return true;
- case "mongodbMembersAutoDiscover":
getOrCreateConfiguration((DebeziumMongodbComponent)
component).setMongodbMembersAutoDiscover((boolean) value); return true;
case "mongodbPassword":
getOrCreateConfiguration((DebeziumMongodbComponent)
component).setMongodbPassword((java.lang.String) value); return true;
case "mongodbPollIntervalMs":
getOrCreateConfiguration((DebeziumMongodbComponent)
component).setMongodbPollIntervalMs((long) value); return true;
case "mongodbServerSelectionTimeoutMs":
getOrCreateConfiguration((DebeziumMongodbComponent)
component).setMongodbServerSelectionTimeoutMs((int) value); return true;
@@ -1212,7 +1123,6 @@ public interface DebeziumMongodbComponentBuilderFactory {
case "provideTransactionMetadata":
getOrCreateConfiguration((DebeziumMongodbComponent)
component).setProvideTransactionMetadata((boolean) value); return true;
case "queryFetchSize":
getOrCreateConfiguration((DebeziumMongodbComponent)
component).setQueryFetchSize((int) value); return true;
case "retriableRestartConnectorWaitMs":
getOrCreateConfiguration((DebeziumMongodbComponent)
component).setRetriableRestartConnectorWaitMs((long) value); return true;
- case "sanitizeFieldNames":
getOrCreateConfiguration((DebeziumMongodbComponent)
component).setSanitizeFieldNames((boolean) value); return true;
case "schemaHistoryInternalFileFilename":
getOrCreateConfiguration((DebeziumMongodbComponent)
component).setSchemaHistoryInternalFileFilename((java.lang.String) value);
return true;
case "schemaNameAdjustmentMode":
getOrCreateConfiguration((DebeziumMongodbComponent)
component).setSchemaNameAdjustmentMode((java.lang.String) value); return true;
case "signalDataCollection":
getOrCreateConfiguration((DebeziumMongodbComponent)
component).setSignalDataCollection((java.lang.String) 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 2658fbe56a4..d04c8bf4090 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
@@ -1220,22 +1220,6 @@ public interface DebeziumMysqlComponentBuilderFactory {
doSetProperty("retriableRestartConnectorWaitMs",
retriableRestartConnectorWaitMs);
return this;
}
- /**
- * Whether field names will be sanitized to Avro naming conventions.
- *
- * The option is a: <code>boolean</code> type.
- *
- * Default: false
- * Group: mysql
- *
- * @param sanitizeFieldNames the value to set
- * @return the dsl builder
- */
- default DebeziumMysqlComponentBuilder sanitizeFieldNames(
- boolean sanitizeFieldNames) {
- doSetProperty("sanitizeFieldNames", sanitizeFieldNames);
- return this;
- }
/**
* The name of the SchemaHistory class that should be used to store and
* recover database schema changes. The configuration properties for
the
@@ -1290,6 +1274,26 @@ public interface DebeziumMysqlComponentBuilderFactory {
doSetProperty("schemaHistoryInternalSkipUnparseableDdl",
schemaHistoryInternalSkipUnparseableDdl);
return this;
}
+ /**
+ * Controls what DDL will Debezium store in database schema history. By
+ * default (true) only DDL that manipulates a table from captured
+ * schema/database will be stored. If set to false, then Debezium will
+ * store all incoming DDL statements.
+ *
+ * The option is a: <code>boolean</code> type.
+ *
+ * Default: true
+ * Group: mysql
+ *
+ * @param schemaHistoryInternalStoreOnlyCapturedDatabasesDdl the value
+ * to set
+ * @return the dsl builder
+ */
+ default DebeziumMysqlComponentBuilder
schemaHistoryInternalStoreOnlyCapturedDatabasesDdl(
+ boolean schemaHistoryInternalStoreOnlyCapturedDatabasesDdl) {
+
doSetProperty("schemaHistoryInternalStoreOnlyCapturedDatabasesDdl",
schemaHistoryInternalStoreOnlyCapturedDatabasesDdl);
+ return this;
+ }
/**
* Controls what DDL will Debezium store in database schema history. By
* default (false) Debezium will store all incoming DDL statements. If
@@ -1314,7 +1318,10 @@ public interface DebeziumMysqlComponentBuilderFactory {
* Specify how schema names should be adjusted for compatibility with
* the message converter used by the connector, including: 'avro'
* replaces the characters that cannot be used in the Avro type name
- * with underscore; 'none' does not apply any adjustment (default).
+ * with underscore; 'avro_unicode' replaces the underscore or
characters
+ * that cannot be used in the Avro type name with corresponding unicode
+ * like _uxxxx. Note: _ is an escape sequence like backslash in
+ * Java;'none' does not apply any adjustment (default).
*
* The option is a: <code>java.lang.String</code> type.
*
@@ -1559,6 +1566,26 @@ public interface DebeziumMysqlComponentBuilderFactory {
doSetProperty("snapshotSelectStatementOverrides",
snapshotSelectStatementOverrides);
return this;
}
+ /**
+ * Controls the order in which tables are processed in the initial
+ * snapshot. A descending value will order the tables by row count
+ * descending. A ascending value will order the tables by row count
+ * ascending. A value of disabled (the default) will disable ordering
by
+ * row count.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Default: disabled
+ * Group: mysql
+ *
+ * @param snapshotTablesOrderByRowCount the value to set
+ * @return the dsl builder
+ */
+ default DebeziumMysqlComponentBuilder snapshotTablesOrderByRowCount(
+ java.lang.String snapshotTablesOrderByRowCount) {
+ doSetProperty("snapshotTablesOrderByRowCount",
snapshotTablesOrderByRowCount);
+ return this;
+ }
/**
* A comma-separated list of regular expressions that match the
* fully-qualified names of tables to be excluded from monitoring.
@@ -1775,10 +1802,10 @@ public interface DebeziumMysqlComponentBuilderFactory {
case "provideTransactionMetadata":
getOrCreateConfiguration((DebeziumMySqlComponent)
component).setProvideTransactionMetadata((boolean) value); return true;
case "queryFetchSize":
getOrCreateConfiguration((DebeziumMySqlComponent)
component).setQueryFetchSize((int) value); return true;
case "retriableRestartConnectorWaitMs":
getOrCreateConfiguration((DebeziumMySqlComponent)
component).setRetriableRestartConnectorWaitMs((long) value); return true;
- case "sanitizeFieldNames":
getOrCreateConfiguration((DebeziumMySqlComponent)
component).setSanitizeFieldNames((boolean) value); return true;
case "schemaHistoryInternal":
getOrCreateConfiguration((DebeziumMySqlComponent)
component).setSchemaHistoryInternal((java.lang.String) value); return true;
case "schemaHistoryInternalFileFilename":
getOrCreateConfiguration((DebeziumMySqlComponent)
component).setSchemaHistoryInternalFileFilename((java.lang.String) value);
return true;
case "schemaHistoryInternalSkipUnparseableDdl":
getOrCreateConfiguration((DebeziumMySqlComponent)
component).setSchemaHistoryInternalSkipUnparseableDdl((boolean) value); return
true;
+ case "schemaHistoryInternalStoreOnlyCapturedDatabasesDdl":
getOrCreateConfiguration((DebeziumMySqlComponent)
component).setSchemaHistoryInternalStoreOnlyCapturedDatabasesDdl((boolean)
value); return true;
case "schemaHistoryInternalStoreOnlyCapturedTablesDdl":
getOrCreateConfiguration((DebeziumMySqlComponent)
component).setSchemaHistoryInternalStoreOnlyCapturedTablesDdl((boolean) value);
return true;
case "schemaNameAdjustmentMode":
getOrCreateConfiguration((DebeziumMySqlComponent)
component).setSchemaNameAdjustmentMode((java.lang.String) value); return true;
case "signalDataCollection":
getOrCreateConfiguration((DebeziumMySqlComponent)
component).setSignalDataCollection((java.lang.String) value); return true;
@@ -1792,6 +1819,7 @@ public interface DebeziumMysqlComponentBuilderFactory {
case "snapshotMode":
getOrCreateConfiguration((DebeziumMySqlComponent)
component).setSnapshotMode((java.lang.String) value); return true;
case "snapshotNewTables":
getOrCreateConfiguration((DebeziumMySqlComponent)
component).setSnapshotNewTables((java.lang.String) value); return true;
case "snapshotSelectStatementOverrides":
getOrCreateConfiguration((DebeziumMySqlComponent)
component).setSnapshotSelectStatementOverrides((java.lang.String) value);
return true;
+ case "snapshotTablesOrderByRowCount":
getOrCreateConfiguration((DebeziumMySqlComponent)
component).setSnapshotTablesOrderByRowCount((java.lang.String) value); return
true;
case "tableExcludeList":
getOrCreateConfiguration((DebeziumMySqlComponent)
component).setTableExcludeList((java.lang.String) value); return true;
case "tableIgnoreBuiltin":
getOrCreateConfiguration((DebeziumMySqlComponent)
component).setTableIgnoreBuiltin((boolean) value); return true;
case "tableIncludeList":
getOrCreateConfiguration((DebeziumMySqlComponent)
component).setTableIncludeList((java.lang.String) 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 75a7776d58d..9030924278e 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
@@ -1254,11 +1254,12 @@ public interface DebeziumOracleComponentBuilderFactory {
}
/**
* The maximum number of records that should be loaded into memory
while
- * streaming. A value of '0' uses the default JDBC fetch size.
+ * streaming. A value of '0' uses the default JDBC fetch size, defaults
+ * to '2000'.
*
* The option is a: <code>int</code> type.
*
- * Default: 0
+ * Default: 2000
* Group: oracle
*
* @param queryFetchSize the value to set
@@ -1300,22 +1301,6 @@ public interface DebeziumOracleComponentBuilderFactory {
doSetProperty("retriableRestartConnectorWaitMs",
retriableRestartConnectorWaitMs);
return this;
}
- /**
- * Whether field names will be sanitized to Avro naming conventions.
- *
- * The option is a: <code>boolean</code> type.
- *
- * Default: false
- * Group: oracle
- *
- * @param sanitizeFieldNames the value to set
- * @return the dsl builder
- */
- default DebeziumOracleComponentBuilder sanitizeFieldNames(
- boolean sanitizeFieldNames) {
- doSetProperty("sanitizeFieldNames", sanitizeFieldNames);
- return this;
- }
/**
* The name of the SchemaHistory class that should be used to store and
* recover database schema changes. The configuration properties for
the
@@ -1370,6 +1355,26 @@ public interface DebeziumOracleComponentBuilderFactory {
doSetProperty("schemaHistoryInternalSkipUnparseableDdl",
schemaHistoryInternalSkipUnparseableDdl);
return this;
}
+ /**
+ * Controls what DDL will Debezium store in database schema history. By
+ * default (true) only DDL that manipulates a table from captured
+ * schema/database will be stored. If set to false, then Debezium will
+ * store all incoming DDL statements.
+ *
+ * The option is a: <code>boolean</code> type.
+ *
+ * Default: false
+ * Group: oracle
+ *
+ * @param schemaHistoryInternalStoreOnlyCapturedDatabasesDdl the value
+ * to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleComponentBuilder
schemaHistoryInternalStoreOnlyCapturedDatabasesDdl(
+ boolean schemaHistoryInternalStoreOnlyCapturedDatabasesDdl) {
+
doSetProperty("schemaHistoryInternalStoreOnlyCapturedDatabasesDdl",
schemaHistoryInternalStoreOnlyCapturedDatabasesDdl);
+ return this;
+ }
/**
* Controls what DDL will Debezium store in database schema history. By
* default (false) Debezium will store all incoming DDL statements. If
@@ -1394,7 +1399,10 @@ public interface DebeziumOracleComponentBuilderFactory {
* Specify how schema names should be adjusted for compatibility with
* the message converter used by the connector, including: 'avro'
* replaces the characters that cannot be used in the Avro type name
- * with underscore; 'none' does not apply any adjustment (default).
+ * with underscore; 'avro_unicode' replaces the underscore or
characters
+ * that cannot be used in the Avro type name with corresponding unicode
+ * like _uxxxx. Note: _ is an escape sequence like backslash in
+ * Java;'none' does not apply any adjustment (default).
*
* The option is a: <code>java.lang.String</code> type.
*
@@ -1615,6 +1623,26 @@ public interface DebeziumOracleComponentBuilderFactory {
doSetProperty("snapshotSelectStatementOverrides",
snapshotSelectStatementOverrides);
return this;
}
+ /**
+ * Controls the order in which tables are processed in the initial
+ * snapshot. A descending value will order the tables by row count
+ * descending. A ascending value will order the tables by row count
+ * ascending. A value of disabled (the default) will disable ordering
by
+ * row count.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Default: disabled
+ * Group: oracle
+ *
+ * @param snapshotTablesOrderByRowCount the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleComponentBuilder snapshotTablesOrderByRowCount(
+ java.lang.String snapshotTablesOrderByRowCount) {
+ doSetProperty("snapshotTablesOrderByRowCount",
snapshotTablesOrderByRowCount);
+ return this;
+ }
/**
* A comma-separated list of regular expressions that match the
* fully-qualified names of tables to be excluded from monitoring.
@@ -1840,10 +1868,10 @@ public interface DebeziumOracleComponentBuilderFactory {
case "queryFetchSize":
getOrCreateConfiguration((DebeziumOracleComponent)
component).setQueryFetchSize((int) value); return true;
case "racNodes":
getOrCreateConfiguration((DebeziumOracleComponent)
component).setRacNodes((java.lang.String) value); return true;
case "retriableRestartConnectorWaitMs":
getOrCreateConfiguration((DebeziumOracleComponent)
component).setRetriableRestartConnectorWaitMs((long) value); return true;
- case "sanitizeFieldNames":
getOrCreateConfiguration((DebeziumOracleComponent)
component).setSanitizeFieldNames((boolean) value); return true;
case "schemaHistoryInternal":
getOrCreateConfiguration((DebeziumOracleComponent)
component).setSchemaHistoryInternal((java.lang.String) value); return true;
case "schemaHistoryInternalFileFilename":
getOrCreateConfiguration((DebeziumOracleComponent)
component).setSchemaHistoryInternalFileFilename((java.lang.String) value);
return true;
case "schemaHistoryInternalSkipUnparseableDdl":
getOrCreateConfiguration((DebeziumOracleComponent)
component).setSchemaHistoryInternalSkipUnparseableDdl((boolean) value); return
true;
+ case "schemaHistoryInternalStoreOnlyCapturedDatabasesDdl":
getOrCreateConfiguration((DebeziumOracleComponent)
component).setSchemaHistoryInternalStoreOnlyCapturedDatabasesDdl((boolean)
value); return true;
case "schemaHistoryInternalStoreOnlyCapturedTablesDdl":
getOrCreateConfiguration((DebeziumOracleComponent)
component).setSchemaHistoryInternalStoreOnlyCapturedTablesDdl((boolean) value);
return true;
case "schemaNameAdjustmentMode":
getOrCreateConfiguration((DebeziumOracleComponent)
component).setSchemaNameAdjustmentMode((java.lang.String) value); return true;
case "signalDataCollection":
getOrCreateConfiguration((DebeziumOracleComponent)
component).setSignalDataCollection((java.lang.String) value); return true;
@@ -1857,6 +1885,7 @@ public interface DebeziumOracleComponentBuilderFactory {
case "snapshotMaxThreads":
getOrCreateConfiguration((DebeziumOracleComponent)
component).setSnapshotMaxThreads((int) value); return true;
case "snapshotMode":
getOrCreateConfiguration((DebeziumOracleComponent)
component).setSnapshotMode((java.lang.String) value); return true;
case "snapshotSelectStatementOverrides":
getOrCreateConfiguration((DebeziumOracleComponent)
component).setSnapshotSelectStatementOverrides((java.lang.String) value);
return true;
+ case "snapshotTablesOrderByRowCount":
getOrCreateConfiguration((DebeziumOracleComponent)
component).setSnapshotTablesOrderByRowCount((java.lang.String) value); return
true;
case "tableExcludeList":
getOrCreateConfiguration((DebeziumOracleComponent)
component).setTableExcludeList((java.lang.String) value); return true;
case "tableIncludeList":
getOrCreateConfiguration((DebeziumOracleComponent)
component).setTableIncludeList((java.lang.String) value); return true;
case "timePrecisionMode":
getOrCreateConfiguration((DebeziumOracleComponent)
component).setTimePrecisionMode((java.lang.String) 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 bea714918c5..11051d7bbd0 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
@@ -1064,22 +1064,6 @@ public interface DebeziumPostgresComponentBuilderFactory
{
doSetProperty("retriableRestartConnectorWaitMs",
retriableRestartConnectorWaitMs);
return this;
}
- /**
- * Whether field names will be sanitized to Avro naming conventions.
- *
- * The option is a: <code>boolean</code> type.
- *
- * Default: false
- * Group: postgres
- *
- * @param sanitizeFieldNames the value to set
- * @return the dsl builder
- */
- default DebeziumPostgresComponentBuilder sanitizeFieldNames(
- boolean sanitizeFieldNames) {
- doSetProperty("sanitizeFieldNames", sanitizeFieldNames);
- return this;
- }
/**
* The schemas for which events must not be captured.
*
@@ -1130,7 +1114,10 @@ public interface DebeziumPostgresComponentBuilderFactory
{
* Specify how schema names should be adjusted for compatibility with
* the message converter used by the connector, including: 'avro'
* replaces the characters that cannot be used in the Avro type name
- * with underscore; 'none' does not apply any adjustment (default).
+ * with underscore; 'avro_unicode' replaces the underscore or
characters
+ * that cannot be used in the Avro type name with corresponding unicode
+ * like _uxxxx. Note: _ is an escape sequence like backslash in
+ * Java;'none' does not apply any adjustment (default).
*
* The option is a: <code>java.lang.String</code> type.
*
@@ -1450,6 +1437,26 @@ public interface DebeziumPostgresComponentBuilderFactory
{
doSetProperty("snapshotSelectStatementOverrides",
snapshotSelectStatementOverrides);
return this;
}
+ /**
+ * Controls the order in which tables are processed in the initial
+ * snapshot. A descending value will order the tables by row count
+ * descending. A ascending value will order the tables by row count
+ * ascending. A value of disabled (the default) will disable ordering
by
+ * row count.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Default: disabled
+ * Group: postgres
+ *
+ * @param snapshotTablesOrderByRowCount the value to set
+ * @return the dsl builder
+ */
+ default DebeziumPostgresComponentBuilder snapshotTablesOrderByRowCount(
+ java.lang.String snapshotTablesOrderByRowCount) {
+ doSetProperty("snapshotTablesOrderByRowCount",
snapshotTablesOrderByRowCount);
+ return this;
+ }
/**
* Frequency for sending replication connection status updates to the
* server, given in milliseconds. Defaults to 10 seconds (10,000 ms).
@@ -1718,7 +1725,6 @@ public interface DebeziumPostgresComponentBuilderFactory {
case "publicationName":
getOrCreateConfiguration((DebeziumPostgresComponent)
component).setPublicationName((java.lang.String) value); return true;
case "queryFetchSize":
getOrCreateConfiguration((DebeziumPostgresComponent)
component).setQueryFetchSize((int) value); return true;
case "retriableRestartConnectorWaitMs":
getOrCreateConfiguration((DebeziumPostgresComponent)
component).setRetriableRestartConnectorWaitMs((long) value); return true;
- case "sanitizeFieldNames":
getOrCreateConfiguration((DebeziumPostgresComponent)
component).setSanitizeFieldNames((boolean) value); return true;
case "schemaExcludeList":
getOrCreateConfiguration((DebeziumPostgresComponent)
component).setSchemaExcludeList((java.lang.String) value); return true;
case "schemaHistoryInternalFileFilename":
getOrCreateConfiguration((DebeziumPostgresComponent)
component).setSchemaHistoryInternalFileFilename((java.lang.String) value);
return true;
case "schemaIncludeList":
getOrCreateConfiguration((DebeziumPostgresComponent)
component).setSchemaIncludeList((java.lang.String) value); return true;
@@ -1739,6 +1745,7 @@ public interface DebeziumPostgresComponentBuilderFactory {
case "snapshotMaxThreads":
getOrCreateConfiguration((DebeziumPostgresComponent)
component).setSnapshotMaxThreads((int) value); return true;
case "snapshotMode":
getOrCreateConfiguration((DebeziumPostgresComponent)
component).setSnapshotMode((java.lang.String) value); return true;
case "snapshotSelectStatementOverrides":
getOrCreateConfiguration((DebeziumPostgresComponent)
component).setSnapshotSelectStatementOverrides((java.lang.String) value);
return true;
+ case "snapshotTablesOrderByRowCount":
getOrCreateConfiguration((DebeziumPostgresComponent)
component).setSnapshotTablesOrderByRowCount((java.lang.String) value); return
true;
case "statusUpdateIntervalMs":
getOrCreateConfiguration((DebeziumPostgresComponent)
component).setStatusUpdateIntervalMs((int) value); return true;
case "tableExcludeList":
getOrCreateConfiguration((DebeziumPostgresComponent)
component).setTableExcludeList((java.lang.String) value); return true;
case "tableIgnoreBuiltin":
getOrCreateConfiguration((DebeziumPostgresComponent)
component).setTableIgnoreBuiltin((boolean) 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 1600ec4453b..37d3d3f2269 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
@@ -518,6 +518,23 @@ public interface DebeziumSqlserverComponentBuilderFactory {
doSetProperty("decimalHandlingMode", decimalHandlingMode);
return this;
}
+ /**
+ * The maximum number of retries on connection errors before failing
(-1
+ * = no limit, 0 = disabled, 0 = num of retries).
+ *
+ * The option is a: <code>int</code> type.
+ *
+ * Default: -1
+ * Group: sqlserver
+ *
+ * @param errorsMaxRetries the value to set
+ * @return the dsl builder
+ */
+ default DebeziumSqlserverComponentBuilder errorsMaxRetries(
+ int errorsMaxRetries) {
+ doSetProperty("errorsMaxRetries", errorsMaxRetries);
+ return this;
+ }
/**
* Specify how failures during processing of events (i.e. when
* encountering a corrupted event) should be handled, including: 'fail'
@@ -847,22 +864,6 @@ public interface DebeziumSqlserverComponentBuilderFactory {
doSetProperty("retriableRestartConnectorWaitMs",
retriableRestartConnectorWaitMs);
return this;
}
- /**
- * Whether field names will be sanitized to Avro naming conventions.
- *
- * The option is a: <code>boolean</code> type.
- *
- * Default: false
- * Group: sqlserver
- *
- * @param sanitizeFieldNames the value to set
- * @return the dsl builder
- */
- default DebeziumSqlserverComponentBuilder sanitizeFieldNames(
- boolean sanitizeFieldNames) {
- doSetProperty("sanitizeFieldNames", sanitizeFieldNames);
- return this;
- }
/**
* The name of the SchemaHistory class that should be used to store and
* recover database schema changes. The configuration properties for
the
@@ -917,6 +918,26 @@ public interface DebeziumSqlserverComponentBuilderFactory {
doSetProperty("schemaHistoryInternalSkipUnparseableDdl",
schemaHistoryInternalSkipUnparseableDdl);
return this;
}
+ /**
+ * Controls what DDL will Debezium store in database schema history. By
+ * default (true) only DDL that manipulates a table from captured
+ * schema/database will be stored. If set to false, then Debezium will
+ * store all incoming DDL statements.
+ *
+ * The option is a: <code>boolean</code> type.
+ *
+ * Default: false
+ * Group: sqlserver
+ *
+ * @param schemaHistoryInternalStoreOnlyCapturedDatabasesDdl the value
+ * to set
+ * @return the dsl builder
+ */
+ default DebeziumSqlserverComponentBuilder
schemaHistoryInternalStoreOnlyCapturedDatabasesDdl(
+ boolean schemaHistoryInternalStoreOnlyCapturedDatabasesDdl) {
+
doSetProperty("schemaHistoryInternalStoreOnlyCapturedDatabasesDdl",
schemaHistoryInternalStoreOnlyCapturedDatabasesDdl);
+ return this;
+ }
/**
* Controls what DDL will Debezium store in database schema history. By
* default (false) Debezium will store all incoming DDL statements. If
@@ -941,7 +962,10 @@ public interface DebeziumSqlserverComponentBuilderFactory {
* Specify how schema names should be adjusted for compatibility with
* the message converter used by the connector, including: 'avro'
* replaces the characters that cannot be used in the Avro type name
- * with underscore; 'none' does not apply any adjustment (default).
+ * with underscore; 'avro_unicode' replaces the underscore or
characters
+ * that cannot be used in the Avro type name with corresponding unicode
+ * like _uxxxx. Note: _ is an escape sequence like backslash in
+ * Java;'none' does not apply any adjustment (default).
*
* The option is a: <code>java.lang.String</code> type.
*
@@ -1153,6 +1177,26 @@ public interface
DebeziumSqlserverComponentBuilderFactory {
doSetProperty("snapshotSelectStatementOverrides",
snapshotSelectStatementOverrides);
return this;
}
+ /**
+ * Controls the order in which tables are processed in the initial
+ * snapshot. A descending value will order the tables by row count
+ * descending. A ascending value will order the tables by row count
+ * ascending. A value of disabled (the default) will disable ordering
by
+ * row count.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Default: disabled
+ * Group: sqlserver
+ *
+ * @param snapshotTablesOrderByRowCount the value to set
+ * @return the dsl builder
+ */
+ default DebeziumSqlserverComponentBuilder
snapshotTablesOrderByRowCount(
+ java.lang.String snapshotTablesOrderByRowCount) {
+ doSetProperty("snapshotTablesOrderByRowCount",
snapshotTablesOrderByRowCount);
+ return this;
+ }
/**
* A comma-separated list of regular expressions that match the
* fully-qualified names of tables to be excluded from monitoring.
@@ -1332,6 +1376,7 @@ public interface DebeziumSqlserverComponentBuilderFactory
{
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;
+ case "errorsMaxRetries":
getOrCreateConfiguration((DebeziumSqlserverComponent)
component).setErrorsMaxRetries((int) value); return true;
case "eventProcessingFailureHandlingMode":
getOrCreateConfiguration((DebeziumSqlserverComponent)
component).setEventProcessingFailureHandlingMode((java.lang.String) value);
return true;
case "heartbeatActionQuery":
getOrCreateConfiguration((DebeziumSqlserverComponent)
component).setHeartbeatActionQuery((java.lang.String) value); return true;
case "heartbeatIntervalMs":
getOrCreateConfiguration((DebeziumSqlserverComponent)
component).setHeartbeatIntervalMs((int) value); return true;
@@ -1350,10 +1395,10 @@ public interface
DebeziumSqlserverComponentBuilderFactory {
case "provideTransactionMetadata":
getOrCreateConfiguration((DebeziumSqlserverComponent)
component).setProvideTransactionMetadata((boolean) value); return true;
case "queryFetchSize":
getOrCreateConfiguration((DebeziumSqlserverComponent)
component).setQueryFetchSize((int) value); return true;
case "retriableRestartConnectorWaitMs":
getOrCreateConfiguration((DebeziumSqlserverComponent)
component).setRetriableRestartConnectorWaitMs((long) value); return true;
- case "sanitizeFieldNames":
getOrCreateConfiguration((DebeziumSqlserverComponent)
component).setSanitizeFieldNames((boolean) value); return true;
case "schemaHistoryInternal":
getOrCreateConfiguration((DebeziumSqlserverComponent)
component).setSchemaHistoryInternal((java.lang.String) value); return true;
case "schemaHistoryInternalFileFilename":
getOrCreateConfiguration((DebeziumSqlserverComponent)
component).setSchemaHistoryInternalFileFilename((java.lang.String) value);
return true;
case "schemaHistoryInternalSkipUnparseableDdl":
getOrCreateConfiguration((DebeziumSqlserverComponent)
component).setSchemaHistoryInternalSkipUnparseableDdl((boolean) value); return
true;
+ case "schemaHistoryInternalStoreOnlyCapturedDatabasesDdl":
getOrCreateConfiguration((DebeziumSqlserverComponent)
component).setSchemaHistoryInternalStoreOnlyCapturedDatabasesDdl((boolean)
value); return true;
case "schemaHistoryInternalStoreOnlyCapturedTablesDdl":
getOrCreateConfiguration((DebeziumSqlserverComponent)
component).setSchemaHistoryInternalStoreOnlyCapturedTablesDdl((boolean) value);
return true;
case "schemaNameAdjustmentMode":
getOrCreateConfiguration((DebeziumSqlserverComponent)
component).setSchemaNameAdjustmentMode((java.lang.String) value); return true;
case "signalDataCollection":
getOrCreateConfiguration((DebeziumSqlserverComponent)
component).setSignalDataCollection((java.lang.String) value); return true;
@@ -1366,6 +1411,7 @@ public interface DebeziumSqlserverComponentBuilderFactory
{
case "snapshotMaxThreads":
getOrCreateConfiguration((DebeziumSqlserverComponent)
component).setSnapshotMaxThreads((int) value); return true;
case "snapshotMode":
getOrCreateConfiguration((DebeziumSqlserverComponent)
component).setSnapshotMode((java.lang.String) value); return true;
case "snapshotSelectStatementOverrides":
getOrCreateConfiguration((DebeziumSqlserverComponent)
component).setSnapshotSelectStatementOverrides((java.lang.String) value);
return true;
+ case "snapshotTablesOrderByRowCount":
getOrCreateConfiguration((DebeziumSqlserverComponent)
component).setSnapshotTablesOrderByRowCount((java.lang.String) value); return
true;
case "tableExcludeList":
getOrCreateConfiguration((DebeziumSqlserverComponent)
component).setTableExcludeList((java.lang.String) value); return true;
case "tableIgnoreBuiltin":
getOrCreateConfiguration((DebeziumSqlserverComponent)
component).setTableIgnoreBuiltin((boolean) value); return true;
case "tableIncludeList":
getOrCreateConfiguration((DebeziumSqlserverComponent)
component).setTableIncludeList((java.lang.String) value); return true;
diff --git
a/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/DebeziumDb2EndpointBuilderFactory.java
b/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/DebeziumDb2EndpointBuilderFactory.java
index 50bad611985..b33ab9ea604 100644
---
a/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/DebeziumDb2EndpointBuilderFactory.java
+++
b/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/DebeziumDb2EndpointBuilderFactory.java
@@ -931,39 +931,6 @@ public interface DebeziumDb2EndpointBuilderFactory {
doSetProperty("retriableRestartConnectorWaitMs",
retriableRestartConnectorWaitMs);
return this;
}
- /**
- * Whether field names will be sanitized to Avro naming conventions.
- *
- * The option is a: <code>boolean</code> type.
- *
- * Default: false
- * Group: db2
- *
- * @param sanitizeFieldNames the value to set
- * @return the dsl builder
- */
- default DebeziumDb2EndpointBuilder sanitizeFieldNames(
- boolean sanitizeFieldNames) {
- doSetProperty("sanitizeFieldNames", sanitizeFieldNames);
- return this;
- }
- /**
- * Whether field names will be sanitized to Avro naming conventions.
- *
- * The option will be converted to a <code>boolean</code>
- * type.
- *
- * Default: false
- * Group: db2
- *
- * @param sanitizeFieldNames the value to set
- * @return the dsl builder
- */
- default DebeziumDb2EndpointBuilder sanitizeFieldNames(
- String sanitizeFieldNames) {
- doSetProperty("sanitizeFieldNames", sanitizeFieldNames);
- return this;
- }
/**
* The name of the SchemaHistory class that should be used to store and
* recover database schema changes. The configuration properties for
the
@@ -1039,6 +1006,47 @@ public interface DebeziumDb2EndpointBuilderFactory {
doSetProperty("schemaHistoryInternalSkipUnparseableDdl",
schemaHistoryInternalSkipUnparseableDdl);
return this;
}
+ /**
+ * Controls what DDL will Debezium store in database schema history. By
+ * default (true) only DDL that manipulates a table from captured
+ * schema/database will be stored. If set to false, then Debezium will
+ * store all incoming DDL statements.
+ *
+ * The option is a: <code>boolean</code> type.
+ *
+ * Default: false
+ * Group: db2
+ *
+ * @param schemaHistoryInternalStoreOnlyCapturedDatabasesDdl the value
+ * to set
+ * @return the dsl builder
+ */
+ default DebeziumDb2EndpointBuilder
schemaHistoryInternalStoreOnlyCapturedDatabasesDdl(
+ boolean schemaHistoryInternalStoreOnlyCapturedDatabasesDdl) {
+
doSetProperty("schemaHistoryInternalStoreOnlyCapturedDatabasesDdl",
schemaHistoryInternalStoreOnlyCapturedDatabasesDdl);
+ return this;
+ }
+ /**
+ * Controls what DDL will Debezium store in database schema history. By
+ * default (true) only DDL that manipulates a table from captured
+ * schema/database will be stored. If set to false, then Debezium will
+ * store all incoming DDL statements.
+ *
+ * The option will be converted to a <code>boolean</code>
+ * type.
+ *
+ * Default: false
+ * Group: db2
+ *
+ * @param schemaHistoryInternalStoreOnlyCapturedDatabasesDdl the value
+ * to set
+ * @return the dsl builder
+ */
+ default DebeziumDb2EndpointBuilder
schemaHistoryInternalStoreOnlyCapturedDatabasesDdl(
+ String schemaHistoryInternalStoreOnlyCapturedDatabasesDdl) {
+
doSetProperty("schemaHistoryInternalStoreOnlyCapturedDatabasesDdl",
schemaHistoryInternalStoreOnlyCapturedDatabasesDdl);
+ return this;
+ }
/**
* Controls what DDL will Debezium store in database schema history. By
* default (false) Debezium will store all incoming DDL statements. If
@@ -1084,7 +1092,10 @@ public interface DebeziumDb2EndpointBuilderFactory {
* Specify how schema names should be adjusted for compatibility with
* the message converter used by the connector, including: 'avro'
* replaces the characters that cannot be used in the Avro type name
- * with underscore; 'none' does not apply any adjustment (default).
+ * with underscore; 'avro_unicode' replaces the underscore or
characters
+ * that cannot be used in the Avro type name with corresponding unicode
+ * like _uxxxx. Note: _ is an escape sequence like backslash in
+ * Java;'none' does not apply any adjustment (default).
*
* The option is a: <code>java.lang.String</code> type.
*
@@ -1297,6 +1308,26 @@ public interface DebeziumDb2EndpointBuilderFactory {
doSetProperty("snapshotSelectStatementOverrides",
snapshotSelectStatementOverrides);
return this;
}
+ /**
+ * Controls the order in which tables are processed in the initial
+ * snapshot. A descending value will order the tables by row count
+ * descending. A ascending value will order the tables by row count
+ * ascending. A value of disabled (the default) will disable ordering
by
+ * row count.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Default: disabled
+ * Group: db2
+ *
+ * @param snapshotTablesOrderByRowCount the value to set
+ * @return the dsl builder
+ */
+ default DebeziumDb2EndpointBuilder snapshotTablesOrderByRowCount(
+ String snapshotTablesOrderByRowCount) {
+ doSetProperty("snapshotTablesOrderByRowCount",
snapshotTablesOrderByRowCount);
+ return this;
+ }
/**
* A comma-separated list of regular expressions that match the
* fully-qualified names of tables to be excluded from monitoring.
diff --git
a/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/DebeziumMongodbEndpointBuilderFactory.java
b/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/DebeziumMongodbEndpointBuilderFactory.java
index 2d96c3b6e88..898ee93ccac 100644
---
a/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/DebeziumMongodbEndpointBuilderFactory.java
+++
b/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/DebeziumMongodbEndpointBuilderFactory.java
@@ -380,118 +380,6 @@ public interface DebeziumMongodbEndpointBuilderFactory {
doSetProperty("collectionIncludeList", collectionIncludeList);
return this;
}
- /**
- * The initial delay when trying to reconnect to a primary after a
- * connection cannot be made or when no primary is available, given in
- * milliseconds. Defaults to 1 second (1,000 ms).
- *
- * The option is a: <code>long</code> type.
- *
- * Default: 1s
- * Group: mongodb
- *
- * @param connectBackoffInitialDelayMs the value to set
- * @return the dsl builder
- */
- default DebeziumMongodbEndpointBuilder connectBackoffInitialDelayMs(
- long connectBackoffInitialDelayMs) {
- doSetProperty("connectBackoffInitialDelayMs",
connectBackoffInitialDelayMs);
- return this;
- }
- /**
- * The initial delay when trying to reconnect to a primary after a
- * connection cannot be made or when no primary is available, given in
- * milliseconds. Defaults to 1 second (1,000 ms).
- *
- * The option will be converted to a <code>long</code>
type.
- *
- * Default: 1s
- * Group: mongodb
- *
- * @param connectBackoffInitialDelayMs the value to set
- * @return the dsl builder
- */
- default DebeziumMongodbEndpointBuilder connectBackoffInitialDelayMs(
- String connectBackoffInitialDelayMs) {
- doSetProperty("connectBackoffInitialDelayMs",
connectBackoffInitialDelayMs);
- return this;
- }
- /**
- * The maximum delay when trying to reconnect to a primary after a
- * connection cannot be made or when no primary is available, given in
- * milliseconds. Defaults to 120 second (120,000 ms).
- *
- * The option is a: <code>long</code> type.
- *
- * Default: 2m
- * Group: mongodb
- *
- * @param connectBackoffMaxDelayMs the value to set
- * @return the dsl builder
- */
- default DebeziumMongodbEndpointBuilder connectBackoffMaxDelayMs(
- long connectBackoffMaxDelayMs) {
- doSetProperty("connectBackoffMaxDelayMs",
connectBackoffMaxDelayMs);
- return this;
- }
- /**
- * The maximum delay when trying to reconnect to a primary after a
- * connection cannot be made or when no primary is available, given in
- * milliseconds. Defaults to 120 second (120,000 ms).
- *
- * The option will be converted to a <code>long</code>
type.
- *
- * Default: 2m
- * Group: mongodb
- *
- * @param connectBackoffMaxDelayMs the value to set
- * @return the dsl builder
- */
- default DebeziumMongodbEndpointBuilder connectBackoffMaxDelayMs(
- String connectBackoffMaxDelayMs) {
- doSetProperty("connectBackoffMaxDelayMs",
connectBackoffMaxDelayMs);
- return this;
- }
- /**
- * Maximum number of failed connection attempts to a replica set
primary
- * before an exception occurs and task is aborted. Defaults to 16,
which
- * with the defaults for 'connect.backoff.initial.delay.ms' and
- * 'connect.backoff.max.delay.ms' results in just over 20 minutes of
- * attempts before failing.
- *
- * The option is a: <code>int</code> type.
- *
- * Default: 16
- * Group: mongodb
- *
- * @param connectMaxAttempts the value to set
- * @return the dsl builder
- */
- default DebeziumMongodbEndpointBuilder connectMaxAttempts(
- int connectMaxAttempts) {
- doSetProperty("connectMaxAttempts", connectMaxAttempts);
- return this;
- }
- /**
- * Maximum number of failed connection attempts to a replica set
primary
- * before an exception occurs and task is aborted. Defaults to 16,
which
- * with the defaults for 'connect.backoff.initial.delay.ms' and
- * 'connect.backoff.max.delay.ms' results in just over 20 minutes of
- * attempts before failing.
- *
- * The option will be converted to a <code>int</code> type.
- *
- * Default: 16
- * Group: mongodb
- *
- * @param connectMaxAttempts the value to set
- * @return the dsl builder
- */
- default DebeziumMongodbEndpointBuilder connectMaxAttempts(
- String connectMaxAttempts) {
- doSetProperty("connectMaxAttempts", connectMaxAttempts);
- return this;
- }
/**
* Optional list of custom converters that would be used instead of
* default ones. The converters are defined using '.type' config option
@@ -795,6 +683,25 @@ public interface DebeziumMongodbEndpointBuilderFactory {
doSetProperty("mongodbAuthsource", mongodbAuthsource);
return this;
}
+ /**
+ * The method used to connect to MongoDB cluster. Options include:
+ * 'replica_set' (the default) to individually connect to each replica
+ * set / shard 'sharded' to connect via single connection obtained from
+ * connection string.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Default: replica_set
+ * Group: mongodb
+ *
+ * @param mongodbConnectionMode the value to set
+ * @return the dsl builder
+ */
+ default DebeziumMongodbEndpointBuilder mongodbConnectionMode(
+ String mongodbConnectionMode) {
+ doSetProperty("mongodbConnectionMode", mongodbConnectionMode);
+ return this;
+ }
/**
* Database connection string.
*
@@ -878,60 +785,6 @@ public interface DebeziumMongodbEndpointBuilderFactory {
doSetProperty("mongodbHeartbeatFrequencyMs",
mongodbHeartbeatFrequencyMs);
return this;
}
- /**
- * The hostname and port pairs (in the form 'host' or 'host:port') of
- * the MongoDB server(s) in the replica set.
- *
- * The option is a: <code>java.lang.String</code> type.
- *
- * Group: mongodb
- *
- * @param mongodbHosts the value to set
- * @return the dsl builder
- */
- default DebeziumMongodbEndpointBuilder mongodbHosts(String
mongodbHosts) {
- doSetProperty("mongodbHosts", mongodbHosts);
- return this;
- }
- /**
- * 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 default is 'true'.
- *
- * The option is a: <code>boolean</code> type.
- *
- * Default: true
- * Group: mongodb
- *
- * @param mongodbMembersAutoDiscover the value to set
- * @return the dsl builder
- */
- default DebeziumMongodbEndpointBuilder mongodbMembersAutoDiscover(
- boolean mongodbMembersAutoDiscover) {
- doSetProperty("mongodbMembersAutoDiscover",
mongodbMembersAutoDiscover);
- return this;
- }
- /**
- * 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 default is 'true'.
- *
- * The option will be converted to a <code>boolean</code>
- * type.
- *
- * Default: true
- * Group: mongodb
- *
- * @param mongodbMembersAutoDiscover the value to set
- * @return the dsl builder
- */
- default DebeziumMongodbEndpointBuilder mongodbMembersAutoDiscover(
- String mongodbMembersAutoDiscover) {
- doSetProperty("mongodbMembersAutoDiscover",
mongodbMembersAutoDiscover);
- return this;
- }
/**
* Password to be used when connecting to MongoDB, if necessary.
*
@@ -1264,39 +1117,6 @@ public interface DebeziumMongodbEndpointBuilderFactory {
doSetProperty("retriableRestartConnectorWaitMs",
retriableRestartConnectorWaitMs);
return this;
}
- /**
- * Whether field names will be sanitized to Avro naming conventions.
- *
- * The option is a: <code>boolean</code> type.
- *
- * Default: false
- * Group: mongodb
- *
- * @param sanitizeFieldNames the value to set
- * @return the dsl builder
- */
- default DebeziumMongodbEndpointBuilder sanitizeFieldNames(
- boolean sanitizeFieldNames) {
- doSetProperty("sanitizeFieldNames", sanitizeFieldNames);
- return this;
- }
- /**
- * Whether field names will be sanitized to Avro naming conventions.
- *
- * The option will be converted to a <code>boolean</code>
- * type.
- *
- * Default: false
- * Group: mongodb
- *
- * @param sanitizeFieldNames the value to set
- * @return the dsl builder
- */
- default DebeziumMongodbEndpointBuilder sanitizeFieldNames(
- String sanitizeFieldNames) {
- doSetProperty("sanitizeFieldNames", sanitizeFieldNames);
- return this;
- }
/**
* The path to the file that will be used to record the database schema
* history.
@@ -1317,7 +1137,10 @@ public interface DebeziumMongodbEndpointBuilderFactory {
* Specify how schema names should be adjusted for compatibility with
* the message converter used by the connector, including: 'avro'
* replaces the characters that cannot be used in the Avro type name
- * with underscore; 'none' does not apply any adjustment (default).
+ * with underscore; 'avro_unicode' replaces the underscore or
characters
+ * that cannot be used in the Avro type name with corresponding unicode
+ * like _uxxxx. Note: _ is an escape sequence like backslash in
+ * Java;'none' does not apply any adjustment (default).
*
* The option is a: <code>java.lang.String</code> type.
*
diff --git
a/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/DebeziumMySqlEndpointBuilderFactory.java
b/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/DebeziumMySqlEndpointBuilderFactory.java
index 25a0bbb614b..920361469f2 100644
---
a/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/DebeziumMySqlEndpointBuilderFactory.java
+++
b/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/DebeziumMySqlEndpointBuilderFactory.java
@@ -1674,39 +1674,6 @@ public interface DebeziumMySqlEndpointBuilderFactory {
doSetProperty("retriableRestartConnectorWaitMs",
retriableRestartConnectorWaitMs);
return this;
}
- /**
- * Whether field names will be sanitized to Avro naming conventions.
- *
- * The option is a: <code>boolean</code> type.
- *
- * Default: false
- * Group: mysql
- *
- * @param sanitizeFieldNames the value to set
- * @return the dsl builder
- */
- default DebeziumMySqlEndpointBuilder sanitizeFieldNames(
- boolean sanitizeFieldNames) {
- doSetProperty("sanitizeFieldNames", sanitizeFieldNames);
- return this;
- }
- /**
- * Whether field names will be sanitized to Avro naming conventions.
- *
- * The option will be converted to a <code>boolean</code>
- * type.
- *
- * Default: false
- * Group: mysql
- *
- * @param sanitizeFieldNames the value to set
- * @return the dsl builder
- */
- default DebeziumMySqlEndpointBuilder sanitizeFieldNames(
- String sanitizeFieldNames) {
- doSetProperty("sanitizeFieldNames", sanitizeFieldNames);
- return this;
- }
/**
* The name of the SchemaHistory class that should be used to store and
* recover database schema changes. The configuration properties for
the
@@ -1782,6 +1749,47 @@ public interface DebeziumMySqlEndpointBuilderFactory {
doSetProperty("schemaHistoryInternalSkipUnparseableDdl",
schemaHistoryInternalSkipUnparseableDdl);
return this;
}
+ /**
+ * Controls what DDL will Debezium store in database schema history. By
+ * default (true) only DDL that manipulates a table from captured
+ * schema/database will be stored. If set to false, then Debezium will
+ * store all incoming DDL statements.
+ *
+ * The option is a: <code>boolean</code> type.
+ *
+ * Default: true
+ * Group: mysql
+ *
+ * @param schemaHistoryInternalStoreOnlyCapturedDatabasesDdl the value
+ * to set
+ * @return the dsl builder
+ */
+ default DebeziumMySqlEndpointBuilder
schemaHistoryInternalStoreOnlyCapturedDatabasesDdl(
+ boolean schemaHistoryInternalStoreOnlyCapturedDatabasesDdl) {
+
doSetProperty("schemaHistoryInternalStoreOnlyCapturedDatabasesDdl",
schemaHistoryInternalStoreOnlyCapturedDatabasesDdl);
+ return this;
+ }
+ /**
+ * Controls what DDL will Debezium store in database schema history. By
+ * default (true) only DDL that manipulates a table from captured
+ * schema/database will be stored. If set to false, then Debezium will
+ * store all incoming DDL statements.
+ *
+ * The option will be converted to a <code>boolean</code>
+ * type.
+ *
+ * Default: true
+ * Group: mysql
+ *
+ * @param schemaHistoryInternalStoreOnlyCapturedDatabasesDdl the value
+ * to set
+ * @return the dsl builder
+ */
+ default DebeziumMySqlEndpointBuilder
schemaHistoryInternalStoreOnlyCapturedDatabasesDdl(
+ String schemaHistoryInternalStoreOnlyCapturedDatabasesDdl) {
+
doSetProperty("schemaHistoryInternalStoreOnlyCapturedDatabasesDdl",
schemaHistoryInternalStoreOnlyCapturedDatabasesDdl);
+ return this;
+ }
/**
* Controls what DDL will Debezium store in database schema history. By
* default (false) Debezium will store all incoming DDL statements. If
@@ -1827,7 +1835,10 @@ public interface DebeziumMySqlEndpointBuilderFactory {
* Specify how schema names should be adjusted for compatibility with
* the message converter used by the connector, including: 'avro'
* replaces the characters that cannot be used in the Avro type name
- * with underscore; 'none' does not apply any adjustment (default).
+ * with underscore; 'avro_unicode' replaces the underscore or
characters
+ * that cannot be used in the Avro type name with corresponding unicode
+ * like _uxxxx. Note: _ is an escape sequence like backslash in
+ * Java;'none' does not apply any adjustment (default).
*
* The option is a: <code>java.lang.String</code> type.
*
@@ -2139,6 +2150,26 @@ public interface DebeziumMySqlEndpointBuilderFactory {
doSetProperty("snapshotSelectStatementOverrides",
snapshotSelectStatementOverrides);
return this;
}
+ /**
+ * Controls the order in which tables are processed in the initial
+ * snapshot. A descending value will order the tables by row count
+ * descending. A ascending value will order the tables by row count
+ * ascending. A value of disabled (the default) will disable ordering
by
+ * row count.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Default: disabled
+ * Group: mysql
+ *
+ * @param snapshotTablesOrderByRowCount the value to set
+ * @return the dsl builder
+ */
+ default DebeziumMySqlEndpointBuilder snapshotTablesOrderByRowCount(
+ String snapshotTablesOrderByRowCount) {
+ doSetProperty("snapshotTablesOrderByRowCount",
snapshotTablesOrderByRowCount);
+ return this;
+ }
/**
* A comma-separated list of regular expressions that match the
* fully-qualified names of tables to be excluded from monitoring.
diff --git
a/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/DebeziumOracleEndpointBuilderFactory.java
b/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/DebeziumOracleEndpointBuilderFactory.java
index 84b305ea300..9dd52e03e6a 100644
---
a/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/DebeziumOracleEndpointBuilderFactory.java
+++
b/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/DebeziumOracleEndpointBuilderFactory.java
@@ -1754,11 +1754,12 @@ public interface DebeziumOracleEndpointBuilderFactory {
}
/**
* The maximum number of records that should be loaded into memory
while
- * streaming. A value of '0' uses the default JDBC fetch size.
+ * streaming. A value of '0' uses the default JDBC fetch size, defaults
+ * to '2000'.
*
* The option is a: <code>int</code> type.
*
- * Default: 0
+ * Default: 2000
* Group: oracle
*
* @param queryFetchSize the value to set
@@ -1770,11 +1771,12 @@ public interface DebeziumOracleEndpointBuilderFactory {
}
/**
* The maximum number of records that should be loaded into memory
while
- * streaming. A value of '0' uses the default JDBC fetch size.
+ * streaming. A value of '0' uses the default JDBC fetch size, defaults
+ * to '2000'.
*
* The option will be converted to a <code>int</code> type.
*
- * Default: 0
+ * Default: 2000
* Group: oracle
*
* @param queryFetchSize the value to set
@@ -1833,39 +1835,6 @@ public interface DebeziumOracleEndpointBuilderFactory {
doSetProperty("retriableRestartConnectorWaitMs",
retriableRestartConnectorWaitMs);
return this;
}
- /**
- * Whether field names will be sanitized to Avro naming conventions.
- *
- * The option is a: <code>boolean</code> type.
- *
- * Default: false
- * Group: oracle
- *
- * @param sanitizeFieldNames the value to set
- * @return the dsl builder
- */
- default DebeziumOracleEndpointBuilder sanitizeFieldNames(
- boolean sanitizeFieldNames) {
- doSetProperty("sanitizeFieldNames", sanitizeFieldNames);
- return this;
- }
- /**
- * Whether field names will be sanitized to Avro naming conventions.
- *
- * The option will be converted to a <code>boolean</code>
- * type.
- *
- * Default: false
- * Group: oracle
- *
- * @param sanitizeFieldNames the value to set
- * @return the dsl builder
- */
- default DebeziumOracleEndpointBuilder sanitizeFieldNames(
- String sanitizeFieldNames) {
- doSetProperty("sanitizeFieldNames", sanitizeFieldNames);
- return this;
- }
/**
* The name of the SchemaHistory class that should be used to store and
* recover database schema changes. The configuration properties for
the
@@ -1941,6 +1910,47 @@ public interface DebeziumOracleEndpointBuilderFactory {
doSetProperty("schemaHistoryInternalSkipUnparseableDdl",
schemaHistoryInternalSkipUnparseableDdl);
return this;
}
+ /**
+ * Controls what DDL will Debezium store in database schema history. By
+ * default (true) only DDL that manipulates a table from captured
+ * schema/database will be stored. If set to false, then Debezium will
+ * store all incoming DDL statements.
+ *
+ * The option is a: <code>boolean</code> type.
+ *
+ * Default: false
+ * Group: oracle
+ *
+ * @param schemaHistoryInternalStoreOnlyCapturedDatabasesDdl the value
+ * to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleEndpointBuilder
schemaHistoryInternalStoreOnlyCapturedDatabasesDdl(
+ boolean schemaHistoryInternalStoreOnlyCapturedDatabasesDdl) {
+
doSetProperty("schemaHistoryInternalStoreOnlyCapturedDatabasesDdl",
schemaHistoryInternalStoreOnlyCapturedDatabasesDdl);
+ return this;
+ }
+ /**
+ * Controls what DDL will Debezium store in database schema history. By
+ * default (true) only DDL that manipulates a table from captured
+ * schema/database will be stored. If set to false, then Debezium will
+ * store all incoming DDL statements.
+ *
+ * The option will be converted to a <code>boolean</code>
+ * type.
+ *
+ * Default: false
+ * Group: oracle
+ *
+ * @param schemaHistoryInternalStoreOnlyCapturedDatabasesDdl the value
+ * to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleEndpointBuilder
schemaHistoryInternalStoreOnlyCapturedDatabasesDdl(
+ String schemaHistoryInternalStoreOnlyCapturedDatabasesDdl) {
+
doSetProperty("schemaHistoryInternalStoreOnlyCapturedDatabasesDdl",
schemaHistoryInternalStoreOnlyCapturedDatabasesDdl);
+ return this;
+ }
/**
* Controls what DDL will Debezium store in database schema history. By
* default (false) Debezium will store all incoming DDL statements. If
@@ -1986,7 +1996,10 @@ public interface DebeziumOracleEndpointBuilderFactory {
* Specify how schema names should be adjusted for compatibility with
* the message converter used by the connector, including: 'avro'
* replaces the characters that cannot be used in the Avro type name
- * with underscore; 'none' does not apply any adjustment (default).
+ * with underscore; 'avro_unicode' replaces the underscore or
characters
+ * that cannot be used in the Avro type name with corresponding unicode
+ * like _uxxxx. Note: _ is an escape sequence like backslash in
+ * Java;'none' does not apply any adjustment (default).
*
* The option is a: <code>java.lang.String</code> type.
*
@@ -2274,6 +2287,26 @@ public interface DebeziumOracleEndpointBuilderFactory {
doSetProperty("snapshotSelectStatementOverrides",
snapshotSelectStatementOverrides);
return this;
}
+ /**
+ * Controls the order in which tables are processed in the initial
+ * snapshot. A descending value will order the tables by row count
+ * descending. A ascending value will order the tables by row count
+ * ascending. A value of disabled (the default) will disable ordering
by
+ * row count.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Default: disabled
+ * Group: oracle
+ *
+ * @param snapshotTablesOrderByRowCount the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleEndpointBuilder snapshotTablesOrderByRowCount(
+ String snapshotTablesOrderByRowCount) {
+ doSetProperty("snapshotTablesOrderByRowCount",
snapshotTablesOrderByRowCount);
+ return this;
+ }
/**
* A comma-separated list of regular expressions that match the
* fully-qualified names of tables to be excluded from monitoring.
diff --git
a/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/DebeziumPostgresEndpointBuilderFactory.java
b/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/DebeziumPostgresEndpointBuilderFactory.java
index 9ab021a5e37..2c94810c0c3 100644
---
a/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/DebeziumPostgresEndpointBuilderFactory.java
+++
b/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/DebeziumPostgresEndpointBuilderFactory.java
@@ -1338,39 +1338,6 @@ public interface DebeziumPostgresEndpointBuilderFactory {
doSetProperty("retriableRestartConnectorWaitMs",
retriableRestartConnectorWaitMs);
return this;
}
- /**
- * Whether field names will be sanitized to Avro naming conventions.
- *
- * The option is a: <code>boolean</code> type.
- *
- * Default: false
- * Group: postgres
- *
- * @param sanitizeFieldNames the value to set
- * @return the dsl builder
- */
- default DebeziumPostgresEndpointBuilder sanitizeFieldNames(
- boolean sanitizeFieldNames) {
- doSetProperty("sanitizeFieldNames", sanitizeFieldNames);
- return this;
- }
- /**
- * Whether field names will be sanitized to Avro naming conventions.
- *
- * The option will be converted to a <code>boolean</code>
- * type.
- *
- * Default: false
- * Group: postgres
- *
- * @param sanitizeFieldNames the value to set
- * @return the dsl builder
- */
- default DebeziumPostgresEndpointBuilder sanitizeFieldNames(
- String sanitizeFieldNames) {
- doSetProperty("sanitizeFieldNames", sanitizeFieldNames);
- return this;
- }
/**
* The schemas for which events must not be captured.
*
@@ -1421,7 +1388,10 @@ public interface DebeziumPostgresEndpointBuilderFactory {
* Specify how schema names should be adjusted for compatibility with
* the message converter used by the connector, including: 'avro'
* replaces the characters that cannot be used in the Avro type name
- * with underscore; 'none' does not apply any adjustment (default).
+ * with underscore; 'avro_unicode' replaces the underscore or
characters
+ * that cannot be used in the Avro type name with corresponding unicode
+ * like _uxxxx. Note: _ is an escape sequence like backslash in
+ * Java;'none' does not apply any adjustment (default).
*
* The option is a: <code>java.lang.String</code> type.
*
@@ -1861,6 +1831,26 @@ public interface DebeziumPostgresEndpointBuilderFactory {
doSetProperty("snapshotSelectStatementOverrides",
snapshotSelectStatementOverrides);
return this;
}
+ /**
+ * Controls the order in which tables are processed in the initial
+ * snapshot. A descending value will order the tables by row count
+ * descending. A ascending value will order the tables by row count
+ * ascending. A value of disabled (the default) will disable ordering
by
+ * row count.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Default: disabled
+ * Group: postgres
+ *
+ * @param snapshotTablesOrderByRowCount the value to set
+ * @return the dsl builder
+ */
+ default DebeziumPostgresEndpointBuilder snapshotTablesOrderByRowCount(
+ String snapshotTablesOrderByRowCount) {
+ doSetProperty("snapshotTablesOrderByRowCount",
snapshotTablesOrderByRowCount);
+ return this;
+ }
/**
* Frequency for sending replication connection status updates to the
* server, given in milliseconds. Defaults to 10 seconds (10,000 ms).
diff --git
a/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/DebeziumSqlserverEndpointBuilderFactory.java
b/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/DebeziumSqlserverEndpointBuilderFactory.java
index a6691772dcb..becb80be782 100644
---
a/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/DebeziumSqlserverEndpointBuilderFactory.java
+++
b/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/DebeziumSqlserverEndpointBuilderFactory.java
@@ -564,6 +564,40 @@ public interface DebeziumSqlserverEndpointBuilderFactory {
doSetProperty("decimalHandlingMode", decimalHandlingMode);
return this;
}
+ /**
+ * The maximum number of retries on connection errors before failing
(-1
+ * = no limit, 0 = disabled, 0 = num of retries).
+ *
+ * The option is a: <code>int</code> type.
+ *
+ * Default: -1
+ * Group: sqlserver
+ *
+ * @param errorsMaxRetries the value to set
+ * @return the dsl builder
+ */
+ default DebeziumSqlserverEndpointBuilder errorsMaxRetries(
+ int errorsMaxRetries) {
+ doSetProperty("errorsMaxRetries", errorsMaxRetries);
+ return this;
+ }
+ /**
+ * The maximum number of retries on connection errors before failing
(-1
+ * = no limit, 0 = disabled, 0 = num of retries).
+ *
+ * The option will be converted to a <code>int</code> type.
+ *
+ * Default: -1
+ * Group: sqlserver
+ *
+ * @param errorsMaxRetries the value to set
+ * @return the dsl builder
+ */
+ default DebeziumSqlserverEndpointBuilder errorsMaxRetries(
+ String errorsMaxRetries) {
+ doSetProperty("errorsMaxRetries", errorsMaxRetries);
+ return this;
+ }
/**
* Specify how failures during processing of events (i.e. when
* encountering a corrupted event) should be handled, including: 'fail'
@@ -1153,39 +1187,6 @@ public interface DebeziumSqlserverEndpointBuilderFactory
{
doSetProperty("retriableRestartConnectorWaitMs",
retriableRestartConnectorWaitMs);
return this;
}
- /**
- * Whether field names will be sanitized to Avro naming conventions.
- *
- * The option is a: <code>boolean</code> type.
- *
- * Default: false
- * Group: sqlserver
- *
- * @param sanitizeFieldNames the value to set
- * @return the dsl builder
- */
- default DebeziumSqlserverEndpointBuilder sanitizeFieldNames(
- boolean sanitizeFieldNames) {
- doSetProperty("sanitizeFieldNames", sanitizeFieldNames);
- return this;
- }
- /**
- * Whether field names will be sanitized to Avro naming conventions.
- *
- * The option will be converted to a <code>boolean</code>
- * type.
- *
- * Default: false
- * Group: sqlserver
- *
- * @param sanitizeFieldNames the value to set
- * @return the dsl builder
- */
- default DebeziumSqlserverEndpointBuilder sanitizeFieldNames(
- String sanitizeFieldNames) {
- doSetProperty("sanitizeFieldNames", sanitizeFieldNames);
- return this;
- }
/**
* The name of the SchemaHistory class that should be used to store and
* recover database schema changes. The configuration properties for
the
@@ -1261,6 +1262,47 @@ public interface DebeziumSqlserverEndpointBuilderFactory
{
doSetProperty("schemaHistoryInternalSkipUnparseableDdl",
schemaHistoryInternalSkipUnparseableDdl);
return this;
}
+ /**
+ * Controls what DDL will Debezium store in database schema history. By
+ * default (true) only DDL that manipulates a table from captured
+ * schema/database will be stored. If set to false, then Debezium will
+ * store all incoming DDL statements.
+ *
+ * The option is a: <code>boolean</code> type.
+ *
+ * Default: false
+ * Group: sqlserver
+ *
+ * @param schemaHistoryInternalStoreOnlyCapturedDatabasesDdl the value
+ * to set
+ * @return the dsl builder
+ */
+ default DebeziumSqlserverEndpointBuilder
schemaHistoryInternalStoreOnlyCapturedDatabasesDdl(
+ boolean schemaHistoryInternalStoreOnlyCapturedDatabasesDdl) {
+
doSetProperty("schemaHistoryInternalStoreOnlyCapturedDatabasesDdl",
schemaHistoryInternalStoreOnlyCapturedDatabasesDdl);
+ return this;
+ }
+ /**
+ * Controls what DDL will Debezium store in database schema history. By
+ * default (true) only DDL that manipulates a table from captured
+ * schema/database will be stored. If set to false, then Debezium will
+ * store all incoming DDL statements.
+ *
+ * The option will be converted to a <code>boolean</code>
+ * type.
+ *
+ * Default: false
+ * Group: sqlserver
+ *
+ * @param schemaHistoryInternalStoreOnlyCapturedDatabasesDdl the value
+ * to set
+ * @return the dsl builder
+ */
+ default DebeziumSqlserverEndpointBuilder
schemaHistoryInternalStoreOnlyCapturedDatabasesDdl(
+ String schemaHistoryInternalStoreOnlyCapturedDatabasesDdl) {
+
doSetProperty("schemaHistoryInternalStoreOnlyCapturedDatabasesDdl",
schemaHistoryInternalStoreOnlyCapturedDatabasesDdl);
+ return this;
+ }
/**
* Controls what DDL will Debezium store in database schema history. By
* default (false) Debezium will store all incoming DDL statements. If
@@ -1306,7 +1348,10 @@ public interface DebeziumSqlserverEndpointBuilderFactory
{
* Specify how schema names should be adjusted for compatibility with
* the message converter used by the connector, including: 'avro'
* replaces the characters that cannot be used in the Avro type name
- * with underscore; 'none' does not apply any adjustment (default).
+ * with underscore; 'avro_unicode' replaces the underscore or
characters
+ * that cannot be used in the Avro type name with corresponding unicode
+ * like _uxxxx. Note: _ is an escape sequence like backslash in
+ * Java;'none' does not apply any adjustment (default).
*
* The option is a: <code>java.lang.String</code> type.
*
@@ -1586,6 +1631,26 @@ public interface DebeziumSqlserverEndpointBuilderFactory
{
doSetProperty("snapshotSelectStatementOverrides",
snapshotSelectStatementOverrides);
return this;
}
+ /**
+ * Controls the order in which tables are processed in the initial
+ * snapshot. A descending value will order the tables by row count
+ * descending. A ascending value will order the tables by row count
+ * ascending. A value of disabled (the default) will disable ordering
by
+ * row count.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Default: disabled
+ * Group: sqlserver
+ *
+ * @param snapshotTablesOrderByRowCount the value to set
+ * @return the dsl builder
+ */
+ default DebeziumSqlserverEndpointBuilder snapshotTablesOrderByRowCount(
+ String snapshotTablesOrderByRowCount) {
+ doSetProperty("snapshotTablesOrderByRowCount",
snapshotTablesOrderByRowCount);
+ return this;
+ }
/**
* A comma-separated list of regular expressions that match the
* fully-qualified names of tables to be excluded from monitoring.
diff --git
a/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/IgniteCacheEndpointBuilderFactory.java
b/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/IgniteCacheEndpointBuilderFactory.java
index 965549452c1..715be5e4979 100644
---
a/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/IgniteCacheEndpointBuilderFactory.java
+++
b/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/IgniteCacheEndpointBuilderFactory.java
@@ -973,12 +973,13 @@ public interface IgniteCacheEndpointBuilderFactory {
}
/**
- * This header carries the old cache value when passed in the incoming
- * cache event.
+ * (producer) The old cache value to be replaced when invoking the
+ * REPLACE operation. (consumer) This header carries the old cache
value
+ * when passed in the incoming cache event.
*
* The option is a: {@code Object} type.
*
- * Group: consumer
+ * Group: common
*
* @return the name of the header {@code IgniteCacheOldValue}.
*/
