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 <osc...@users.noreply.github.com> AuthorDate: Fri Apr 21 09:15:43 2023 +0000 Regen for commit 7a21dcf5b117936a7bd81c5a1f575faef72bb716 Signed-off-by: GitHub <nore...@github.com> --- .../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}. */