You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by ac...@apache.org on 2022/04/04 16:59:09 UTC
[camel] branch main updated (649b5c0240b -> 58d3a971a76)
This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/camel.git
from 649b5c0240b Regen for commit 00aba9a79bb6271baaf66679454ab12e28c8e463
new 1aae556f1d0 CAMEL:17092:Debezium 1.7.0 - Oracle Connector - Add to tooling
new 58d3a971a76 CAMEL:17092:Debezium 1.7.0 - Oracle Connector - Add to tooling
The 2 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../org/apache/camel/catalog/components.properties | 1 +
.../camel/catalog/components}/debezium-oracle.json | 0
.../org/apache/camel/main/components.properties | 1 +
.../component/ComponentsBuilderFactory.java | 13 +
... => DebeziumOracleComponentBuilderFactory.java} | 1482 +++++++--------
.../src/generated/resources/metadata.json | 22 +
.../builder/endpoint/EndpointBuilderFactory.java | 1 +
.../camel/builder/endpoint/EndpointBuilders.java | 1 +
.../builder/endpoint/StaticEndpointBuilders.java | 45 +
...a => DebeziumOracleEndpointBuilderFactory.java} | 1884 ++++++++++----------
.../apache/camel/maven/packaging/MojoHelper.java | 3 +-
11 files changed, 1799 insertions(+), 1654 deletions(-)
copy {components/camel-debezium/camel-debezium-oracle/src/generated/resources/org/apache/camel/component/debezium => catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components}/debezium-oracle.json (100%)
copy dsl/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/{DebeziumMysqlComponentBuilderFactory.java => DebeziumOracleComponentBuilderFactory.java} (58%)
copy dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/{DebeziumMySqlEndpointBuilderFactory.java => DebeziumOracleEndpointBuilderFactory.java} (65%)
[camel] 02/02: CAMEL:17092:Debezium 1.7.0 - Oracle Connector - Add to tooling
Posted by ac...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel.git
commit 58d3a971a768eaac2dee7fa63075cd6ed50ae026
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Mon Apr 4 18:58:33 2022 +0200
CAMEL:17092:Debezium 1.7.0 - Oracle Connector - Add to tooling
---
.../org/apache/camel/catalog/components.properties | 1 +
.../camel/catalog/components/debezium-oracle.json | 242 ++
.../org/apache/camel/main/components.properties | 1 +
.../component/ComponentsBuilderFactory.java | 13 +
.../dsl/DebeziumOracleComponentBuilderFactory.java | 1986 ++++++++++++++
.../src/generated/resources/metadata.json | 22 +
.../builder/endpoint/EndpointBuilderFactory.java | 1 +
.../camel/builder/endpoint/EndpointBuilders.java | 1 +
.../builder/endpoint/StaticEndpointBuilders.java | 45 +
.../dsl/DebeziumOracleEndpointBuilderFactory.java | 2738 ++++++++++++++++++++
.../apache/camel/maven/packaging/MojoHelper.java | 3 +-
11 files changed, 5052 insertions(+), 1 deletion(-)
diff --git a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components.properties b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components.properties
index 7453436ccf3..ffa7ed62753 100644
--- a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components.properties
+++ b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components.properties
@@ -74,6 +74,7 @@ dataset
dataset-test
debezium-mongodb
debezium-mysql
+debezium-oracle
debezium-postgres
debezium-sqlserver
digitalocean
diff --git a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/debezium-oracle.json b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/debezium-oracle.json
new file mode 100644
index 00000000000..55c38f3a9c6
--- /dev/null
+++ b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/debezium-oracle.json
@@ -0,0 +1,242 @@
+{
+ "component": {
+ "kind": "component",
+ "name": "debezium-oracle",
+ "title": "Debezium Oracle Connector",
+ "description": "Capture changes from a Oracle database.",
+ "deprecated": false,
+ "firstVersion": "3.17.0",
+ "label": "database,sql",
+ "javaType": "org.apache.camel.component.debezium.DebeziumOracleComponent",
+ "supportLevel": "Preview",
+ "groupId": "org.apache.camel",
+ "artifactId": "camel-debezium-oracle",
+ "version": "3.17.0-SNAPSHOT",
+ "scheme": "debezium-oracle",
+ "extendsScheme": "",
+ "syntax": "debezium-oracle:name",
+ "async": false,
+ "api": false,
+ "consumerOnly": true,
+ "producerOnly": false,
+ "lenientProperties": false
+ },
+ "componentProperties": {
+ "additionalProperties": { "kind": "property", "displayName": "Additional Properties", "group": "common", "label": "common", "required": false, "type": "object", "javaType": "java.util.Map<java.lang.String, java.lang.Object>", "prefix": "additionalProperties.", "multiValue": true, "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "config [...]
+ "bridgeErrorHandler": { "kind": "property", "displayName": "Bridge Error Handler", "group": "consumer", "label": "consumer", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": false, "description": "Allows for bridging the consumer to the Camel routing Error Handler, which mean any exceptions occurred while the consumer is trying to pickup incoming messages, or the likes, will now be processed as a me [...]
+ "configuration": { "kind": "property", "displayName": "Configuration", "group": "consumer", "label": "", "required": false, "type": "object", "javaType": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "deprecated": false, "autowired": false, "secret": false, "description": "Allow pre-configured Configurations to be set." },
+ "internalKeyConverter": { "kind": "property", "displayName": "Internal Key Converter", "group": "consumer", "label": "consumer", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "org.apache.kafka.connect.json.JsonConverter", "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "descripti [...]
+ "internalValueConverter": { "kind": "property", "displayName": "Internal Value Converter", "group": "consumer", "label": "consumer", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "org.apache.kafka.connect.json.JsonConverter", "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "descr [...]
+ "offsetCommitPolicy": { "kind": "property", "displayName": "Offset Commit Policy", "group": "consumer", "label": "consumer", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "io.debezium.embedded.spi.OffsetCommitPolicy.PeriodicCommitOffsetPolicy", "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "con [...]
+ "offsetCommitTimeoutMs": { "kind": "property", "displayName": "Offset Commit Timeout Ms", "group": "consumer", "label": "consumer", "required": false, "type": "duration", "javaType": "long", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "5000", "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Maximum number of milliseconds to wait f [...]
+ "offsetFlushIntervalMs": { "kind": "property", "displayName": "Offset Flush Interval Ms", "group": "consumer", "label": "consumer", "required": false, "type": "duration", "javaType": "long", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "60000", "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Interval at which to try committing off [...]
+ "offsetStorage": { "kind": "property", "displayName": "Offset Storage", "group": "consumer", "label": "consumer", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "org.apache.kafka.connect.storage.FileOffsetBackingStore", "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description" [...]
+ "offsetStorageFileName": { "kind": "property", "displayName": "Offset Storage File Name", "group": "consumer", "label": "consumer", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Path to file where offsets are to be stored. Required [...]
+ "offsetStoragePartitions": { "kind": "property", "displayName": "Offset Storage Partitions", "group": "consumer", "label": "consumer", "required": false, "type": "integer", "javaType": "int", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The number of partitions used when creating the offset storage [...]
+ "offsetStorageReplicationFactor": { "kind": "property", "displayName": "Offset Storage Replication Factor", "group": "consumer", "label": "consumer", "required": false, "type": "integer", "javaType": "int", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Replication factor used when creating the offset [...]
+ "offsetStorageTopic": { "kind": "property", "displayName": "Offset Storage Topic", "group": "consumer", "label": "consumer", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The name of the Kafka topic where offsets are to be stored. R [...]
+ "autowiredEnabled": { "kind": "property", "displayName": "Autowired Enabled", "group": "advanced", "label": "advanced", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": true, "description": "Whether autowiring is enabled. This is used for automatic autowiring options (the option must be marked as autowired) by looking up in the registry to find if there is a single instance of matching type, which t [...]
+ "binaryHandlingMode": { "kind": "property", "displayName": "Binary Handling Mode", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "bytes", "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Specify how binary (blob, binar [...]
+ "columnBlacklist": { "kind": "property", "displayName": "Column Blacklist", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Regular expressions matching columns to exclude from change eve [...]
+ "columnExcludeList": { "kind": "property", "displayName": "Column Exclude List", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Regular expressions matching columns to exclude from chang [...]
+ "columnIncludeList": { "kind": "property", "displayName": "Column Include List", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Regular expressions matching columns to include in change [...]
+ "columnPropagateSourceType": { "kind": "property", "displayName": "Column Propagate Source Type", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "A comma-separated list of regular express [...]
+ "columnWhitelist": { "kind": "property", "displayName": "Column Whitelist", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Regular expressions matching columns to include in change event [...]
+ "converters": { "kind": "property", "displayName": "Converters", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Optional list of custom converters that would be used instead of default o [...]
+ "databaseConnectionAdapter": { "kind": "property", "displayName": "Database Connection Adapter", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "LogMiner", "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The adapter to [...]
+ "databaseDbname": { "kind": "property", "displayName": "Database Dbname", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The name of the database from which the connector should capture [...]
+ "databaseHistory": { "kind": "property", "displayName": "Database History", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "class io.debezium.relational.history.KafkaDatabaseHistory", "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "d [...]
+ "databaseHistoryFileFilename": { "kind": "property", "displayName": "Database History File Filename", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The path to the file that will be use [...]
+ "databaseHistoryKafkaBootstrapServers": { "kind": "property", "displayName": "Database History Kafka Bootstrap Servers", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "A list of host\/po [...]
+ "databaseHistoryKafkaRecoveryAttempts": { "kind": "property", "displayName": "Database History Kafka Recovery Attempts", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "integer", "javaType": "int", "deprecated": false, "autowired": false, "secret": false, "defaultValue": 100, "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The numbe [...]
+ "databaseHistoryKafkaRecoveryPollIntervalMs": { "kind": "property", "displayName": "Database History Kafka Recovery Poll Interval Ms", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "duration", "javaType": "int", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "100ms", "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "descr [...]
+ "databaseHistoryKafkaTopic": { "kind": "property", "displayName": "Database History Kafka Topic", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The name of the topic for the database sc [...]
+ "databaseHistorySkipUnparseableDdl": { "kind": "property", "displayName": "Database History Skip Unparseable Ddl", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": false, "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Controls [...]
+ "databaseHistoryStoreOnlyCapturedTablesDdl": { "kind": "property", "displayName": "Database History Store Only Captured Tables Ddl", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": false, "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "descri [...]
+ "databaseHistoryStoreOnlyMonitoredTablesDdl": { "kind": "property", "displayName": "Database History Store Only Monitored Tables Ddl", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": false, "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "desc [...]
+ "databaseHostname": { "kind": "property", "displayName": "Database Hostname", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Resolvable hostname or IP address of the database server." },
+ "databaseOutServerName": { "kind": "property", "displayName": "Database Out Server Name", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Name of the XStream Out server to connect to." },
+ "databasePassword": { "kind": "property", "displayName": "Database Password", "group": "oracle", "label": "consumer,oracle", "required": true, "type": "string", "javaType": "java.lang.String", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Password of the database user to be use [...]
+ "databasePdbName": { "kind": "property", "displayName": "Database Pdb Name", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Name of the pluggable database when working with a multi-tenan [...]
+ "databasePort": { "kind": "property", "displayName": "Database Port", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "integer", "javaType": "int", "deprecated": false, "autowired": false, "secret": false, "defaultValue": 1528, "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Port of the database server." },
+ "databaseServerName": { "kind": "property", "displayName": "Database Server Name", "group": "oracle", "label": "consumer,oracle", "required": true, "type": "string", "javaType": "java.lang.String", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Unique name that identifies the da [...]
+ "databaseUrl": { "kind": "property", "displayName": "Database Url", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Complete JDBC URL as an alternative to specifying hostname, port and da [...]
+ "databaseUser": { "kind": "property", "displayName": "Database User", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Name of the database user to be used when connecting to the database." },
+ "datatypePropagateSourceType": { "kind": "property", "displayName": "Datatype Propagate Source Type", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "A comma-separated list of regular exp [...]
+ "decimalHandlingMode": { "kind": "property", "displayName": "Decimal Handling Mode", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "precise", "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Specify how DECIMAL and NUM [...]
+ "eventProcessingFailureHandlingMode": { "kind": "property", "displayName": "Event Processing Failure Handling Mode", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "fail", "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": [...]
+ "heartbeatActionQuery": { "kind": "property", "displayName": "Heartbeat Action Query", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The query executed with every heartbeat." },
+ "heartbeatIntervalMs": { "kind": "property", "displayName": "Heartbeat Interval Ms", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "duration", "javaType": "int", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "0ms", "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Length of an interval in milli-seconds in [...]
+ "heartbeatTopicsPrefix": { "kind": "property", "displayName": "Heartbeat Topics Prefix", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "__debezium-heartbeat", "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The prefix [...]
+ "includeSchemaChanges": { "kind": "property", "displayName": "Include Schema Changes", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": true, "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Whether the connector should publish c [...]
+ "includeSchemaComments": { "kind": "property", "displayName": "Include Schema Comments", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": false, "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Whether the connector parse table a [...]
+ "intervalHandlingMode": { "kind": "property", "displayName": "Interval Handling Mode", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "numeric", "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Specify how INTERVAL colu [...]
+ "lobEnabled": { "kind": "property", "displayName": "Lob Enabled", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": false, "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "When set to false, the default, LOB fields will not be cap [...]
+ "logMiningArchiveDestinationName": { "kind": "property", "displayName": "Log Mining Archive Destination Name", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Sets the specific archive lo [...]
+ "logMiningArchiveLogHours": { "kind": "property", "displayName": "Log Mining Archive Log Hours", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "integer", "javaType": "long", "deprecated": false, "autowired": false, "secret": false, "defaultValue": 0, "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The number of hours in the past fr [...]
+ "logMiningArchiveLogOnlyMode": { "kind": "property", "displayName": "Log Mining Archive Log Only Mode", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": false, "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "When set to false, t [...]
+ "logMiningArchiveLogOnlyScnPollIntervalMs": { "kind": "property", "displayName": "Log Mining Archive Log Only Scn Poll Interval Ms", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "duration", "javaType": "long", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "10s", "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "descript [...]
+ "logMiningBatchSizeDefault": { "kind": "property", "displayName": "Log Mining Batch Size Default", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "integer", "javaType": "long", "deprecated": false, "autowired": false, "secret": false, "defaultValue": 20000, "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The starting SCN interval si [...]
+ "logMiningBatchSizeMax": { "kind": "property", "displayName": "Log Mining Batch Size Max", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "integer", "javaType": "long", "deprecated": false, "autowired": false, "secret": false, "defaultValue": 100000, "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The maximum SCN interval size that [...]
+ "logMiningBatchSizeMin": { "kind": "property", "displayName": "Log Mining Batch Size Min", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "integer", "javaType": "long", "deprecated": false, "autowired": false, "secret": false, "defaultValue": 1000, "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The minimum SCN interval size that th [...]
+ "logMiningBufferDropOnStop": { "kind": "property", "displayName": "Log Mining Buffer Drop On Stop", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": false, "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "When set to true the und [...]
+ "logMiningBufferInfinispanCacheEvents": { "kind": "property", "displayName": "Log Mining Buffer Infinispan Cache Events", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Specifies the XML [...]
+ "logMiningBufferInfinispanCacheProcessedTransactions": { "kind": "property", "displayName": "Log Mining Buffer Infinispan Cache Processed Transactions", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "d [...]
+ "logMiningBufferInfinispanCacheSchemaChanges": { "kind": "property", "displayName": "Log Mining Buffer Infinispan Cache Schema Changes", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Sp [...]
+ "logMiningBufferInfinispanCacheTransactions": { "kind": "property", "displayName": "Log Mining Buffer Infinispan Cache Transactions", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Speci [...]
+ "logMiningBufferType": { "kind": "property", "displayName": "Log Mining Buffer Type", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "memory", "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The buffer type controls ho [...]
+ "logMiningScnGapDetectionGapSizeMin": { "kind": "property", "displayName": "Log Mining Scn Gap Detection Gap Size Min", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "integer", "javaType": "long", "deprecated": false, "autowired": false, "secret": false, "defaultValue": 1000000, "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Used [...]
+ "logMiningScnGapDetectionTimeIntervalMaxMs": { "kind": "property", "displayName": "Log Mining Scn Gap Detection Time Interval Max Ms", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "duration", "javaType": "long", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "20s", "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "descri [...]
+ "logMiningSleepTimeDefaultMs": { "kind": "property", "displayName": "Log Mining Sleep Time Default Ms", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "duration", "javaType": "long", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "1s", "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The amount of time that [...]
+ "logMiningSleepTimeIncrementMs": { "kind": "property", "displayName": "Log Mining Sleep Time Increment Ms", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "duration", "javaType": "long", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "200ms", "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The maximum amou [...]
+ "logMiningSleepTimeMaxMs": { "kind": "property", "displayName": "Log Mining Sleep Time Max Ms", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "duration", "javaType": "long", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "3s", "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The maximum amount of time that [...]
+ "logMiningSleepTimeMinMs": { "kind": "property", "displayName": "Log Mining Sleep Time Min Ms", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "duration", "javaType": "long", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "0ms", "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The minimum amount of time tha [...]
+ "logMiningStrategy": { "kind": "property", "displayName": "Log Mining Strategy", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "redo_log_catalog", "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "There are strategies: [...]
+ "logMiningTransactionRetentionHours": { "kind": "property", "displayName": "Log Mining Transaction Retention Hours", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "integer", "javaType": "long", "deprecated": false, "autowired": false, "secret": false, "defaultValue": 0, "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Hours to keep [...]
+ "logMiningUsernameExcludeList": { "kind": "property", "displayName": "Log Mining Username Exclude List", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Comma separated list of usernames [...]
+ "maxBatchSize": { "kind": "property", "displayName": "Max Batch Size", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "integer", "javaType": "int", "deprecated": false, "autowired": false, "secret": false, "defaultValue": 2048, "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Maximum size of each batch of source records. Defaults to [...]
+ "maxQueueSize": { "kind": "property", "displayName": "Max Queue Size", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "integer", "javaType": "int", "deprecated": false, "autowired": false, "secret": false, "defaultValue": 8192, "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Maximum size of the queue for change events read from the [...]
+ "maxQueueSizeInBytes": { "kind": "property", "displayName": "Max Queue Size In Bytes", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "integer", "javaType": "long", "deprecated": false, "autowired": false, "secret": false, "defaultValue": 0, "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Maximum size of the queue in bytes for chang [...]
+ "messageKeyColumns": { "kind": "property", "displayName": "Message Key Columns", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "A semicolon-separated list of expressions that match fully [...]
+ "pollIntervalMs": { "kind": "property", "displayName": "Poll Interval Ms", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "duration", "javaType": "long", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "500ms", "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Time to wait for new change events to appear afte [...]
+ "provideTransactionMetadata": { "kind": "property", "displayName": "Provide Transaction Metadata", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": false, "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Enables transaction metad [...]
+ "queryFetchSize": { "kind": "property", "displayName": "Query Fetch Size", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "integer", "javaType": "int", "deprecated": false, "autowired": false, "secret": false, "defaultValue": 0, "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The maximum number of records that should be loaded into [...]
+ "racNodes": { "kind": "property", "displayName": "Rac Nodes", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "A comma-separated list of RAC node hostnames or ip addresses" },
+ "retriableRestartConnectorWaitMs": { "kind": "property", "displayName": "Retriable Restart Connector Wait Ms", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "duration", "javaType": "long", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "10s", "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Time to wait be [...]
+ "sanitizeFieldNames": { "kind": "property", "displayName": "Sanitize Field Names", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": false, "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Whether field names will be sanitized to [...]
+ "signalDataCollection": { "kind": "property", "displayName": "Signal Data Collection", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The name of the data collection that is used to send [...]
+ "skippedOperations": { "kind": "property", "displayName": "Skipped Operations", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The comma-separated list of operations to skip during strea [...]
+ "snapshotDelayMs": { "kind": "property", "displayName": "Snapshot Delay Ms", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "duration", "javaType": "long", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "0ms", "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "A delay period before a snapshot will begin, give [...]
+ "snapshotEnhancePredicateScn": { "kind": "property", "displayName": "Snapshot Enhance Predicate Scn", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "A token to replace on snapshot predic [...]
+ "snapshotFetchSize": { "kind": "property", "displayName": "Snapshot Fetch Size", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "integer", "javaType": "int", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The maximum number of records that should be loaded into memory while [...]
+ "snapshotIncludeCollectionList": { "kind": "property", "displayName": "Snapshot Include Collection List", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "this setting must be set to speci [...]
+ "snapshotLockingMode": { "kind": "property", "displayName": "Snapshot Locking Mode", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "shared", "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Controls how the connector h [...]
+ "snapshotLockTimeoutMs": { "kind": "property", "displayName": "Snapshot Lock Timeout Ms", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "duration", "javaType": "long", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "10s", "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The maximum number of millis to wait [...]
+ "snapshotMaxThreads": { "kind": "property", "displayName": "Snapshot Max Threads", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "integer", "javaType": "int", "deprecated": false, "autowired": false, "secret": false, "defaultValue": 1, "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The maximum number of threads used to perform the [...]
+ "snapshotMode": { "kind": "property", "displayName": "Snapshot Mode", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "initial", "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The criteria for running a snapshot upon s [...]
+ "snapshotSelectStatementOverrides": { "kind": "property", "displayName": "Snapshot Select Statement Overrides", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "This property contains a co [...]
+ "sourceStructVersion": { "kind": "property", "displayName": "Source Struct Version", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "v2", "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "A version of the format of the p [...]
+ "tableBlacklist": { "kind": "property", "displayName": "Table Blacklist", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "A comma-separated list of regular expressions that match the full [...]
+ "tableExcludeList": { "kind": "property", "displayName": "Table Exclude List", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "A comma-separated list of regular expressions that match the [...]
+ "tableIncludeList": { "kind": "property", "displayName": "Table Include List", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The tables for which changes are to be captured" },
+ "tableWhitelist": { "kind": "property", "displayName": "Table Whitelist", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The tables for which changes are to be captured (deprecated, use [...]
+ "timePrecisionMode": { "kind": "property", "displayName": "Time Precision Mode", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "adaptive", "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Time, date, and timestamps can [...]
+ "tombstonesOnDelete": { "kind": "property", "displayName": "Tombstones On Delete", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": false, "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Whether delete operations should be repre [...]
+ "transactionTopic": { "kind": "property", "displayName": "Transaction Topic", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "${database.server.name}.transaction", "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The na [...]
+ "unavailableValuePlaceholder": { "kind": "property", "displayName": "Unavailable Value Placeholder", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "__debezium_unavailable_value", "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "descr [...]
+ },
+ "headers": {
+ "CamelDebeziumSourceMetadata": { "kind": "header", "displayName": "", "group": "consumer", "label": "", "required": false, "javaType": "Map<String, Object>", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "description": "The metadata about the source event, for example table name, database name, log position, etc, please refer to the Debezium documentation for more info." },
+ "CamelDebeziumIdentifier": { "kind": "header", "displayName": "", "group": "consumer", "label": "", "required": false, "javaType": "String", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "description": "The identifier of the connector, normally is this format {server-name}.{database-name}.{table-name}." },
+ "CamelDebeziumKey": { "kind": "header", "displayName": "", "group": "consumer", "label": "", "required": false, "javaType": "Struct", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "description": "The key of the event, normally is the table Primary Key." },
+ "CamelDebeziumOperation": { "kind": "header", "displayName": "", "group": "consumer", "label": "", "required": false, "javaType": "String", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "description": "If presents, the type of event operation. Values for the connector are c for create (or insert), u for update, d for delete or r for read (in the case of a initial sync) or in case of a snapshot event." },
+ "CamelDebeziumTimestamp": { "kind": "header", "displayName": "", "group": "consumer", "label": "", "required": false, "javaType": "Long", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "description": "If presents, the time (using the system clock in the JVM) at which the connector processed the event." },
+ "CamelDebeziumBefore": { "kind": "header", "displayName": "", "group": "consumer", "label": "", "required": false, "javaType": "Struct", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "description": "If presents, contains the state of the row before the event occurred." },
+ "CamelDebeziumDdlSQL": { "kind": "header", "displayName": "", "group": "consumer", "label": "", "required": false, "javaType": "String", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "description": "If presents, the ddl sql text of the event." }
+ },
+ "properties": {
+ "name": { "kind": "path", "displayName": "Name", "group": "consumer", "label": "consumer", "required": true, "type": "string", "javaType": "java.lang.String", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Unique name for the connector. Attempting to register again with the same [...]
+ "additionalProperties": { "kind": "parameter", "displayName": "Additional Properties", "group": "common", "label": "common", "required": false, "type": "object", "javaType": "java.util.Map<java.lang.String, java.lang.Object>", "prefix": "additionalProperties.", "multiValue": true, "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "confi [...]
+ "bridgeErrorHandler": { "kind": "parameter", "displayName": "Bridge Error Handler", "group": "consumer", "label": "consumer", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": false, "description": "Allows for bridging the consumer to the Camel routing Error Handler, which mean any exceptions occurred while the consumer is trying to pickup incoming messages, or the likes, will now be processed as a m [...]
+ "internalKeyConverter": { "kind": "parameter", "displayName": "Internal Key Converter", "group": "consumer", "label": "consumer", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "org.apache.kafka.connect.json.JsonConverter", "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "descript [...]
+ "internalValueConverter": { "kind": "parameter", "displayName": "Internal Value Converter", "group": "consumer", "label": "consumer", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "org.apache.kafka.connect.json.JsonConverter", "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "desc [...]
+ "offsetCommitPolicy": { "kind": "parameter", "displayName": "Offset Commit Policy", "group": "consumer", "label": "consumer", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "io.debezium.embedded.spi.OffsetCommitPolicy.PeriodicCommitOffsetPolicy", "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "co [...]
+ "offsetCommitTimeoutMs": { "kind": "parameter", "displayName": "Offset Commit Timeout Ms", "group": "consumer", "label": "consumer", "required": false, "type": "duration", "javaType": "long", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "5000", "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Maximum number of milliseconds to wait [...]
+ "offsetFlushIntervalMs": { "kind": "parameter", "displayName": "Offset Flush Interval Ms", "group": "consumer", "label": "consumer", "required": false, "type": "duration", "javaType": "long", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "60000", "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Interval at which to try committing of [...]
+ "offsetStorage": { "kind": "parameter", "displayName": "Offset Storage", "group": "consumer", "label": "consumer", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "org.apache.kafka.connect.storage.FileOffsetBackingStore", "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description [...]
+ "offsetStorageFileName": { "kind": "parameter", "displayName": "Offset Storage File Name", "group": "consumer", "label": "consumer", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Path to file where offsets are to be stored. Required [...]
+ "offsetStoragePartitions": { "kind": "parameter", "displayName": "Offset Storage Partitions", "group": "consumer", "label": "consumer", "required": false, "type": "integer", "javaType": "int", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The number of partitions used when creating the offset storage [...]
+ "offsetStorageReplicationFactor": { "kind": "parameter", "displayName": "Offset Storage Replication Factor", "group": "consumer", "label": "consumer", "required": false, "type": "integer", "javaType": "int", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Replication factor used when creating the offse [...]
+ "offsetStorageTopic": { "kind": "parameter", "displayName": "Offset Storage Topic", "group": "consumer", "label": "consumer", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The name of the Kafka topic where offsets are to be stored. [...]
+ "exceptionHandler": { "kind": "parameter", "displayName": "Exception Handler", "group": "consumer (advanced)", "label": "consumer,advanced", "required": false, "type": "object", "javaType": "org.apache.camel.spi.ExceptionHandler", "optionalPrefix": "consumer.", "deprecated": false, "autowired": false, "secret": false, "description": "To let the consumer use a custom ExceptionHandler. Notice if the option bridgeErrorHandler is enabled then this option is not in use. By default the con [...]
+ "exchangePattern": { "kind": "parameter", "displayName": "Exchange Pattern", "group": "consumer (advanced)", "label": "consumer,advanced", "required": false, "type": "object", "javaType": "org.apache.camel.ExchangePattern", "enum": [ "InOnly", "InOut", "InOptionalOut" ], "deprecated": false, "autowired": false, "secret": false, "description": "Sets the exchange pattern when the consumer creates an exchange." },
+ "binaryHandlingMode": { "kind": "parameter", "displayName": "Binary Handling Mode", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "bytes", "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Specify how binary (blob, bina [...]
+ "columnBlacklist": { "kind": "parameter", "displayName": "Column Blacklist", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Regular expressions matching columns to exclude from change ev [...]
+ "columnExcludeList": { "kind": "parameter", "displayName": "Column Exclude List", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Regular expressions matching columns to exclude from chan [...]
+ "columnIncludeList": { "kind": "parameter", "displayName": "Column Include List", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Regular expressions matching columns to include in change [...]
+ "columnPropagateSourceType": { "kind": "parameter", "displayName": "Column Propagate Source Type", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "A comma-separated list of regular expres [...]
+ "columnWhitelist": { "kind": "parameter", "displayName": "Column Whitelist", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Regular expressions matching columns to include in change even [...]
+ "converters": { "kind": "parameter", "displayName": "Converters", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Optional list of custom converters that would be used instead of default [...]
+ "databaseConnectionAdapter": { "kind": "parameter", "displayName": "Database Connection Adapter", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "LogMiner", "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The adapter t [...]
+ "databaseDbname": { "kind": "parameter", "displayName": "Database Dbname", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The name of the database from which the connector should capture [...]
+ "databaseHistory": { "kind": "parameter", "displayName": "Database History", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "class io.debezium.relational.history.KafkaDatabaseHistory", "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", " [...]
+ "databaseHistoryFileFilename": { "kind": "parameter", "displayName": "Database History File Filename", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The path to the file that will be us [...]
+ "databaseHistoryKafkaBootstrapServers": { "kind": "parameter", "displayName": "Database History Kafka Bootstrap Servers", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "A list of host\/p [...]
+ "databaseHistoryKafkaRecoveryAttempts": { "kind": "parameter", "displayName": "Database History Kafka Recovery Attempts", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "integer", "javaType": "int", "deprecated": false, "autowired": false, "secret": false, "defaultValue": 100, "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The numb [...]
+ "databaseHistoryKafkaRecoveryPollIntervalMs": { "kind": "parameter", "displayName": "Database History Kafka Recovery Poll Interval Ms", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "duration", "javaType": "int", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "100ms", "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "desc [...]
+ "databaseHistoryKafkaTopic": { "kind": "parameter", "displayName": "Database History Kafka Topic", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The name of the topic for the database s [...]
+ "databaseHistorySkipUnparseableDdl": { "kind": "parameter", "displayName": "Database History Skip Unparseable Ddl", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": false, "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Controls [...]
+ "databaseHistoryStoreOnlyCapturedTablesDdl": { "kind": "parameter", "displayName": "Database History Store Only Captured Tables Ddl", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": false, "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "descr [...]
+ "databaseHistoryStoreOnlyMonitoredTablesDdl": { "kind": "parameter", "displayName": "Database History Store Only Monitored Tables Ddl", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": false, "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "des [...]
+ "databaseHostname": { "kind": "parameter", "displayName": "Database Hostname", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Resolvable hostname or IP address of the database server." },
+ "databaseOutServerName": { "kind": "parameter", "displayName": "Database Out Server Name", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Name of the XStream Out server to connect to." },
+ "databasePassword": { "kind": "parameter", "displayName": "Database Password", "group": "oracle", "label": "consumer,oracle", "required": true, "type": "string", "javaType": "java.lang.String", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Password of the database user to be us [...]
+ "databasePdbName": { "kind": "parameter", "displayName": "Database Pdb Name", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Name of the pluggable database when working with a multi-tena [...]
+ "databasePort": { "kind": "parameter", "displayName": "Database Port", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "integer", "javaType": "int", "deprecated": false, "autowired": false, "secret": false, "defaultValue": 1528, "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Port of the database server." },
+ "databaseServerName": { "kind": "parameter", "displayName": "Database Server Name", "group": "oracle", "label": "consumer,oracle", "required": true, "type": "string", "javaType": "java.lang.String", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Unique name that identifies the d [...]
+ "databaseUrl": { "kind": "parameter", "displayName": "Database Url", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Complete JDBC URL as an alternative to specifying hostname, port and d [...]
+ "databaseUser": { "kind": "parameter", "displayName": "Database User", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Name of the database user to be used when connecting to the database." },
+ "datatypePropagateSourceType": { "kind": "parameter", "displayName": "Datatype Propagate Source Type", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "A comma-separated list of regular ex [...]
+ "decimalHandlingMode": { "kind": "parameter", "displayName": "Decimal Handling Mode", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "precise", "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Specify how DECIMAL and NU [...]
+ "eventProcessingFailureHandlingMode": { "kind": "parameter", "displayName": "Event Processing Failure Handling Mode", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "fail", "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description" [...]
+ "heartbeatActionQuery": { "kind": "parameter", "displayName": "Heartbeat Action Query", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The query executed with every heartbeat." },
+ "heartbeatIntervalMs": { "kind": "parameter", "displayName": "Heartbeat Interval Ms", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "duration", "javaType": "int", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "0ms", "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Length of an interval in milli-seconds in [...]
+ "heartbeatTopicsPrefix": { "kind": "parameter", "displayName": "Heartbeat Topics Prefix", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "__debezium-heartbeat", "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The prefi [...]
+ "includeSchemaChanges": { "kind": "parameter", "displayName": "Include Schema Changes", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": true, "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Whether the connector should publish [...]
+ "includeSchemaComments": { "kind": "parameter", "displayName": "Include Schema Comments", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": false, "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Whether the connector parse table [...]
+ "intervalHandlingMode": { "kind": "parameter", "displayName": "Interval Handling Mode", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "numeric", "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Specify how INTERVAL col [...]
+ "lobEnabled": { "kind": "parameter", "displayName": "Lob Enabled", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": false, "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "When set to false, the default, LOB fields will not be ca [...]
+ "logMiningArchiveDestinationName": { "kind": "parameter", "displayName": "Log Mining Archive Destination Name", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Sets the specific archive l [...]
+ "logMiningArchiveLogHours": { "kind": "parameter", "displayName": "Log Mining Archive Log Hours", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "integer", "javaType": "long", "deprecated": false, "autowired": false, "secret": false, "defaultValue": 0, "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The number of hours in the past f [...]
+ "logMiningArchiveLogOnlyMode": { "kind": "parameter", "displayName": "Log Mining Archive Log Only Mode", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": false, "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "When set to false, [...]
+ "logMiningArchiveLogOnlyScnPollIntervalMs": { "kind": "parameter", "displayName": "Log Mining Archive Log Only Scn Poll Interval Ms", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "duration", "javaType": "long", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "10s", "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "descrip [...]
+ "logMiningBatchSizeDefault": { "kind": "parameter", "displayName": "Log Mining Batch Size Default", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "integer", "javaType": "long", "deprecated": false, "autowired": false, "secret": false, "defaultValue": 20000, "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The starting SCN interval s [...]
+ "logMiningBatchSizeMax": { "kind": "parameter", "displayName": "Log Mining Batch Size Max", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "integer", "javaType": "long", "deprecated": false, "autowired": false, "secret": false, "defaultValue": 100000, "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The maximum SCN interval size that [...]
+ "logMiningBatchSizeMin": { "kind": "parameter", "displayName": "Log Mining Batch Size Min", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "integer", "javaType": "long", "deprecated": false, "autowired": false, "secret": false, "defaultValue": 1000, "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The minimum SCN interval size that t [...]
+ "logMiningBufferDropOnStop": { "kind": "parameter", "displayName": "Log Mining Buffer Drop On Stop", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": false, "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "When set to true the un [...]
+ "logMiningBufferInfinispanCacheEvents": { "kind": "parameter", "displayName": "Log Mining Buffer Infinispan Cache Events", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Specifies the XM [...]
+ "logMiningBufferInfinispanCacheProcessedTransactions": { "kind": "parameter", "displayName": "Log Mining Buffer Infinispan Cache Processed Transactions", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", " [...]
+ "logMiningBufferInfinispanCacheSchemaChanges": { "kind": "parameter", "displayName": "Log Mining Buffer Infinispan Cache Schema Changes", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "S [...]
+ "logMiningBufferInfinispanCacheTransactions": { "kind": "parameter", "displayName": "Log Mining Buffer Infinispan Cache Transactions", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Spec [...]
+ "logMiningBufferType": { "kind": "parameter", "displayName": "Log Mining Buffer Type", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "memory", "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The buffer type controls h [...]
+ "logMiningScnGapDetectionGapSizeMin": { "kind": "parameter", "displayName": "Log Mining Scn Gap Detection Gap Size Min", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "integer", "javaType": "long", "deprecated": false, "autowired": false, "secret": false, "defaultValue": 1000000, "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Used [...]
+ "logMiningScnGapDetectionTimeIntervalMaxMs": { "kind": "parameter", "displayName": "Log Mining Scn Gap Detection Time Interval Max Ms", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "duration", "javaType": "long", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "20s", "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "descr [...]
+ "logMiningSleepTimeDefaultMs": { "kind": "parameter", "displayName": "Log Mining Sleep Time Default Ms", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "duration", "javaType": "long", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "1s", "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The amount of time tha [...]
+ "logMiningSleepTimeIncrementMs": { "kind": "parameter", "displayName": "Log Mining Sleep Time Increment Ms", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "duration", "javaType": "long", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "200ms", "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The maximum amo [...]
+ "logMiningSleepTimeMaxMs": { "kind": "parameter", "displayName": "Log Mining Sleep Time Max Ms", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "duration", "javaType": "long", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "3s", "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The maximum amount of time tha [...]
+ "logMiningSleepTimeMinMs": { "kind": "parameter", "displayName": "Log Mining Sleep Time Min Ms", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "duration", "javaType": "long", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "0ms", "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The minimum amount of time th [...]
+ "logMiningStrategy": { "kind": "parameter", "displayName": "Log Mining Strategy", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "redo_log_catalog", "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "There are strategies: [...]
+ "logMiningTransactionRetentionHours": { "kind": "parameter", "displayName": "Log Mining Transaction Retention Hours", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "integer", "javaType": "long", "deprecated": false, "autowired": false, "secret": false, "defaultValue": 0, "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Hours to keep [...]
+ "logMiningUsernameExcludeList": { "kind": "parameter", "displayName": "Log Mining Username Exclude List", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Comma separated list of usernames [...]
+ "maxBatchSize": { "kind": "parameter", "displayName": "Max Batch Size", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "integer", "javaType": "int", "deprecated": false, "autowired": false, "secret": false, "defaultValue": 2048, "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Maximum size of each batch of source records. Defaults to [...]
+ "maxQueueSize": { "kind": "parameter", "displayName": "Max Queue Size", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "integer", "javaType": "int", "deprecated": false, "autowired": false, "secret": false, "defaultValue": 8192, "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Maximum size of the queue for change events read from the [...]
+ "maxQueueSizeInBytes": { "kind": "parameter", "displayName": "Max Queue Size In Bytes", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "integer", "javaType": "long", "deprecated": false, "autowired": false, "secret": false, "defaultValue": 0, "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Maximum size of the queue in bytes for chan [...]
+ "messageKeyColumns": { "kind": "parameter", "displayName": "Message Key Columns", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "A semicolon-separated list of expressions that match full [...]
+ "pollIntervalMs": { "kind": "parameter", "displayName": "Poll Interval Ms", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "duration", "javaType": "long", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "500ms", "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Time to wait for new change events to appear aft [...]
+ "provideTransactionMetadata": { "kind": "parameter", "displayName": "Provide Transaction Metadata", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": false, "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Enables transaction meta [...]
+ "queryFetchSize": { "kind": "parameter", "displayName": "Query Fetch Size", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "integer", "javaType": "int", "deprecated": false, "autowired": false, "secret": false, "defaultValue": 0, "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The maximum number of records that should be loaded into [...]
+ "racNodes": { "kind": "parameter", "displayName": "Rac Nodes", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "A comma-separated list of RAC node hostnames or ip addresses" },
+ "retriableRestartConnectorWaitMs": { "kind": "parameter", "displayName": "Retriable Restart Connector Wait Ms", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "duration", "javaType": "long", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "10s", "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Time to wait b [...]
+ "sanitizeFieldNames": { "kind": "parameter", "displayName": "Sanitize Field Names", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": false, "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Whether field names will be sanitized to [...]
+ "signalDataCollection": { "kind": "parameter", "displayName": "Signal Data Collection", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The name of the data collection that is used to sen [...]
+ "skippedOperations": { "kind": "parameter", "displayName": "Skipped Operations", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The comma-separated list of operations to skip during stre [...]
+ "snapshotDelayMs": { "kind": "parameter", "displayName": "Snapshot Delay Ms", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "duration", "javaType": "long", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "0ms", "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "A delay period before a snapshot will begin, giv [...]
+ "snapshotEnhancePredicateScn": { "kind": "parameter", "displayName": "Snapshot Enhance Predicate Scn", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "A token to replace on snapshot predi [...]
+ "snapshotFetchSize": { "kind": "parameter", "displayName": "Snapshot Fetch Size", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "integer", "javaType": "int", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The maximum number of records that should be loaded into memory while [...]
+ "snapshotIncludeCollectionList": { "kind": "parameter", "displayName": "Snapshot Include Collection List", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "this setting must be set to spec [...]
+ "snapshotLockingMode": { "kind": "parameter", "displayName": "Snapshot Locking Mode", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "shared", "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Controls how the connector [...]
+ "snapshotLockTimeoutMs": { "kind": "parameter", "displayName": "Snapshot Lock Timeout Ms", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "duration", "javaType": "long", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "10s", "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The maximum number of millis to wai [...]
+ "snapshotMaxThreads": { "kind": "parameter", "displayName": "Snapshot Max Threads", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "integer", "javaType": "int", "deprecated": false, "autowired": false, "secret": false, "defaultValue": 1, "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The maximum number of threads used to perform th [...]
+ "snapshotMode": { "kind": "parameter", "displayName": "Snapshot Mode", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "initial", "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The criteria for running a snapshot upon [...]
+ "snapshotSelectStatementOverrides": { "kind": "parameter", "displayName": "Snapshot Select Statement Overrides", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "This property contains a c [...]
+ "sourceStructVersion": { "kind": "parameter", "displayName": "Source Struct Version", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "v2", "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "A version of the format of the [...]
+ "tableBlacklist": { "kind": "parameter", "displayName": "Table Blacklist", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "A comma-separated list of regular expressions that match the ful [...]
+ "tableExcludeList": { "kind": "parameter", "displayName": "Table Exclude List", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "A comma-separated list of regular expressions that match th [...]
+ "tableIncludeList": { "kind": "parameter", "displayName": "Table Include List", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The tables for which changes are to be captured" },
+ "tableWhitelist": { "kind": "parameter", "displayName": "Table Whitelist", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The tables for which changes are to be captured (deprecated, use [...]
+ "timePrecisionMode": { "kind": "parameter", "displayName": "Time Precision Mode", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "adaptive", "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Time, date, and timestamps ca [...]
+ "tombstonesOnDelete": { "kind": "parameter", "displayName": "Tombstones On Delete", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": false, "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "Whether delete operations should be repr [...]
+ "transactionTopic": { "kind": "parameter", "displayName": "Transaction Topic", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "${database.server.name}.transaction", "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "description": "The n [...]
+ "unavailableValuePlaceholder": { "kind": "parameter", "displayName": "Unavailable Value Placeholder", "group": "oracle", "label": "consumer,oracle", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "__debezium_unavailable_value", "configurationClass": "org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration", "configurationField": "configuration", "desc [...]
+ }
+}
diff --git a/core/camel-main/src/generated/resources/org/apache/camel/main/components.properties b/core/camel-main/src/generated/resources/org/apache/camel/main/components.properties
index 7453436ccf3..ffa7ed62753 100644
--- a/core/camel-main/src/generated/resources/org/apache/camel/main/components.properties
+++ b/core/camel-main/src/generated/resources/org/apache/camel/main/components.properties
@@ -74,6 +74,7 @@ dataset
dataset-test
debezium-mongodb
debezium-mysql
+debezium-oracle
debezium-postgres
debezium-sqlserver
digitalocean
diff --git a/dsl/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/ComponentsBuilderFactory.java b/dsl/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/ComponentsBuilderFactory.java
index 90716029171..f6cdc63683a 100644
--- a/dsl/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/ComponentsBuilderFactory.java
+++ b/dsl/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/ComponentsBuilderFactory.java
@@ -1057,6 +1057,19 @@ public interface ComponentsBuilderFactory {
static org.apache.camel.builder.component.dsl.DebeziumMysqlComponentBuilderFactory.DebeziumMysqlComponentBuilder debeziumMysql() {
return org.apache.camel.builder.component.dsl.DebeziumMysqlComponentBuilderFactory.debeziumMysql();
}
+ /**
+ * Debezium Oracle Connector (camel-debezium-oracle)
+ * Capture changes from a Oracle database.
+ *
+ * Category: database,sql
+ * Since: 3.17
+ * Maven coordinates: org.apache.camel:camel-debezium-oracle
+ *
+ * @return the dsl builder
+ */
+ static org.apache.camel.builder.component.dsl.DebeziumOracleComponentBuilderFactory.DebeziumOracleComponentBuilder debeziumOracle() {
+ return org.apache.camel.builder.component.dsl.DebeziumOracleComponentBuilderFactory.debeziumOracle();
+ }
/**
* Debezium PostgresSQL Connector (camel-debezium-postgres)
* Capture changes from a PostgresSQL database.
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
new file mode 100644
index 00000000000..62d7d00abdc
--- /dev/null
+++ b/dsl/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/DebeziumOracleComponentBuilderFactory.java
@@ -0,0 +1,1986 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.camel.builder.component.dsl;
+
+import javax.annotation.Generated;
+import org.apache.camel.Component;
+import org.apache.camel.builder.component.AbstractComponentBuilder;
+import org.apache.camel.builder.component.ComponentBuilder;
+import org.apache.camel.component.debezium.DebeziumOracleComponent;
+
+/**
+ * Capture changes from a Oracle database.
+ *
+ * Generated by camel-package-maven-plugin - do not edit this file!
+ */
+@Generated("org.apache.camel.maven.packaging.ComponentDslMojo")
+public interface DebeziumOracleComponentBuilderFactory {
+
+ /**
+ * Debezium Oracle Connector (camel-debezium-oracle)
+ * Capture changes from a Oracle database.
+ *
+ * Category: database,sql
+ * Since: 3.17
+ * Maven coordinates: org.apache.camel:camel-debezium-oracle
+ *
+ * @return the dsl builder
+ */
+ static DebeziumOracleComponentBuilder debeziumOracle() {
+ return new DebeziumOracleComponentBuilderImpl();
+ }
+
+ /**
+ * Builder for the Debezium Oracle Connector component.
+ */
+ interface DebeziumOracleComponentBuilder
+ extends
+ ComponentBuilder<DebeziumOracleComponent> {
+ /**
+ * Additional properties for debezium components in case they can't be
+ * set directly on the camel configurations (e.g: setting Kafka Connect
+ * properties needed by Debezium engine, for example setting
+ * KafkaOffsetBackingStore), the properties have to be prefixed with
+ * additionalProperties.. E.g:
+ * additionalProperties.transactional.id=12345&amp;additionalProperties.schema.registry.url=http://localhost:8811/avro.
+ *
+ * The option is a: <code>java.util.Map&lt;java.lang.String,
+ * java.lang.Object&gt;</code> type.
+ *
+ * Group: common
+ *
+ * @param additionalProperties the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleComponentBuilder additionalProperties(
+ java.util.Map<java.lang.String, java.lang.Object> additionalProperties) {
+ doSetProperty("additionalProperties", additionalProperties);
+ return this;
+ }
+ /**
+ * Allows for bridging the consumer to the Camel routing Error Handler,
+ * which mean any exceptions occurred while the consumer is trying to
+ * pickup incoming messages, or the likes, will now be processed as a
+ * message and handled by the routing Error Handler. By default the
+ * consumer will use the org.apache.camel.spi.ExceptionHandler to deal
+ * with exceptions, that will be logged at WARN or ERROR level and
+ * ignored.
+ *
+ * The option is a: <code>boolean</code> type.
+ *
+ * Default: false
+ * Group: consumer
+ *
+ * @param bridgeErrorHandler the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleComponentBuilder bridgeErrorHandler(
+ boolean bridgeErrorHandler) {
+ doSetProperty("bridgeErrorHandler", bridgeErrorHandler);
+ return this;
+ }
+ /**
+ * Allow pre-configured Configurations to be set.
+ *
+ * The option is a:
+ * <code>org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration</code> type.
+ *
+ * Group: consumer
+ *
+ * @param configuration the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleComponentBuilder configuration(
+ org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration configuration) {
+ doSetProperty("configuration", configuration);
+ return this;
+ }
+ /**
+ * The Converter class that should be used to serialize and deserialize
+ * key data for offsets. The default is JSON converter.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Default: org.apache.kafka.connect.json.JsonConverter
+ * Group: consumer
+ *
+ * @param internalKeyConverter the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleComponentBuilder internalKeyConverter(
+ java.lang.String internalKeyConverter) {
+ doSetProperty("internalKeyConverter", internalKeyConverter);
+ return this;
+ }
+ /**
+ * The Converter class that should be used to serialize and deserialize
+ * value data for offsets. The default is JSON converter.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Default: org.apache.kafka.connect.json.JsonConverter
+ * Group: consumer
+ *
+ * @param internalValueConverter the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleComponentBuilder internalValueConverter(
+ java.lang.String internalValueConverter) {
+ doSetProperty("internalValueConverter", internalValueConverter);
+ return this;
+ }
+ /**
+ * The name of the Java class of the commit policy. It defines when
+ * offsets commit has to be triggered based on the number of events
+ * processed and the time elapsed since the last commit. This class must
+ * implement the interface 'OffsetCommitPolicy'. The default is a
+ * periodic commit policy based upon time intervals.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Default:
+ * io.debezium.embedded.spi.OffsetCommitPolicy.PeriodicCommitOffsetPolicy
+ * Group: consumer
+ *
+ * @param offsetCommitPolicy the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleComponentBuilder offsetCommitPolicy(
+ java.lang.String offsetCommitPolicy) {
+ doSetProperty("offsetCommitPolicy", offsetCommitPolicy);
+ return this;
+ }
+ /**
+ * Maximum number of milliseconds to wait for records to flush and
+ * partition offset data to be committed to offset storage before
+ * cancelling the process and restoring the offset data to be committed
+ * in a future attempt. The default is 5 seconds.
+ *
+ * The option is a: <code>long</code> type.
+ *
+ * Default: 5000
+ * Group: consumer
+ *
+ * @param offsetCommitTimeoutMs the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleComponentBuilder offsetCommitTimeoutMs(
+ long offsetCommitTimeoutMs) {
+ doSetProperty("offsetCommitTimeoutMs", offsetCommitTimeoutMs);
+ return this;
+ }
+ /**
+ * Interval at which to try committing offsets. The default is 1 minute.
+ *
+ * The option is a: <code>long</code> type.
+ *
+ * Default: 60000
+ * Group: consumer
+ *
+ * @param offsetFlushIntervalMs the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleComponentBuilder offsetFlushIntervalMs(
+ long offsetFlushIntervalMs) {
+ doSetProperty("offsetFlushIntervalMs", offsetFlushIntervalMs);
+ return this;
+ }
+ /**
+ * The name of the Java class that is responsible for persistence of
+ * connector offsets.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Default: org.apache.kafka.connect.storage.FileOffsetBackingStore
+ * Group: consumer
+ *
+ * @param offsetStorage the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleComponentBuilder offsetStorage(
+ java.lang.String offsetStorage) {
+ doSetProperty("offsetStorage", offsetStorage);
+ return this;
+ }
+ /**
+ * Path to file where offsets are to be stored. Required when
+ * offset.storage is set to the FileOffsetBackingStore.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: consumer
+ *
+ * @param offsetStorageFileName the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleComponentBuilder offsetStorageFileName(
+ java.lang.String offsetStorageFileName) {
+ doSetProperty("offsetStorageFileName", offsetStorageFileName);
+ return this;
+ }
+ /**
+ * The number of partitions used when creating the offset storage topic.
+ * Required when offset.storage is set to the 'KafkaOffsetBackingStore'.
+ *
+ * The option is a: <code>int</code> type.
+ *
+ * Group: consumer
+ *
+ * @param offsetStoragePartitions the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleComponentBuilder offsetStoragePartitions(
+ int offsetStoragePartitions) {
+ doSetProperty("offsetStoragePartitions", offsetStoragePartitions);
+ return this;
+ }
+ /**
+ * Replication factor used when creating the offset storage topic.
+ * Required when offset.storage is set to the KafkaOffsetBackingStore.
+ *
+ * The option is a: <code>int</code> type.
+ *
+ * Group: consumer
+ *
+ * @param offsetStorageReplicationFactor the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleComponentBuilder offsetStorageReplicationFactor(
+ int offsetStorageReplicationFactor) {
+ doSetProperty("offsetStorageReplicationFactor", offsetStorageReplicationFactor);
+ return this;
+ }
+ /**
+ * The name of the Kafka topic where offsets are to be stored. Required
+ * when offset.storage is set to the KafkaOffsetBackingStore.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: consumer
+ *
+ * @param offsetStorageTopic the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleComponentBuilder offsetStorageTopic(
+ java.lang.String offsetStorageTopic) {
+ doSetProperty("offsetStorageTopic", offsetStorageTopic);
+ return this;
+ }
+ /**
+ * Whether autowiring is enabled. This is used for automatic autowiring
+ * options (the option must be marked as autowired) by looking up in the
+ * registry to find if there is a single instance of matching type,
+ * which then gets configured on the component. This can be used for
+ * automatic configuring JDBC data sources, JMS connection factories,
+ * AWS Clients, etc.
+ *
+ * The option is a: <code>boolean</code> type.
+ *
+ * Default: true
+ * Group: advanced
+ *
+ * @param autowiredEnabled the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleComponentBuilder autowiredEnabled(
+ boolean autowiredEnabled) {
+ doSetProperty("autowiredEnabled", autowiredEnabled);
+ return this;
+ }
+ /**
+ * Specify how binary (blob, binary, etc.) columns should be represented
+ * in change events, including:'bytes' represents binary data as byte
+ * array (default)'base64' represents binary data as base64-encoded
+ * string'hex' represents binary data as hex-encoded (base16) string.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Default: bytes
+ * Group: oracle
+ *
+ * @param binaryHandlingMode the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleComponentBuilder binaryHandlingMode(
+ java.lang.String binaryHandlingMode) {
+ doSetProperty("binaryHandlingMode", binaryHandlingMode);
+ return this;
+ }
+ /**
+ * Regular expressions matching columns to exclude from change events
+ * (deprecated, use column.exclude.list instead).
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: oracle
+ *
+ * @param columnBlacklist the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleComponentBuilder columnBlacklist(
+ java.lang.String columnBlacklist) {
+ doSetProperty("columnBlacklist", columnBlacklist);
+ return this;
+ }
+ /**
+ * Regular expressions matching columns to exclude from change events.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: oracle
+ *
+ * @param columnExcludeList the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleComponentBuilder columnExcludeList(
+ java.lang.String columnExcludeList) {
+ doSetProperty("columnExcludeList", columnExcludeList);
+ return this;
+ }
+ /**
+ * Regular expressions matching columns to include in change events.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: oracle
+ *
+ * @param columnIncludeList the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleComponentBuilder columnIncludeList(
+ java.lang.String columnIncludeList) {
+ doSetProperty("columnIncludeList", columnIncludeList);
+ return this;
+ }
+ /**
+ * A comma-separated list of regular expressions matching
+ * fully-qualified names of columns that adds the columns original type
+ * and original length as parameters to the corresponding field schemas
+ * in the emitted change records.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: oracle
+ *
+ * @param columnPropagateSourceType the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleComponentBuilder columnPropagateSourceType(
+ java.lang.String columnPropagateSourceType) {
+ doSetProperty("columnPropagateSourceType", columnPropagateSourceType);
+ return this;
+ }
+ /**
+ * Regular expressions matching columns to include in change events
+ * (deprecated, use column.include.list instead).
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: oracle
+ *
+ * @param columnWhitelist the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleComponentBuilder columnWhitelist(
+ java.lang.String columnWhitelist) {
+ doSetProperty("columnWhitelist", columnWhitelist);
+ return this;
+ }
+ /**
+ * Optional list of custom converters that would be used instead of
+ * default ones. The converters are defined using '.type' config option
+ * and configured using options '.'.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: oracle
+ *
+ * @param converters the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleComponentBuilder converters(
+ java.lang.String converters) {
+ doSetProperty("converters", converters);
+ return this;
+ }
+ /**
+ * The adapter to use when capturing changes from the database. Options
+ * include: 'logminer': (the default) to capture changes using native
+ * Oracle LogMiner; 'xstream' to capture changes using Oracle XStreams.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Default: LogMiner
+ * Group: oracle
+ *
+ * @param databaseConnectionAdapter the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleComponentBuilder databaseConnectionAdapter(
+ java.lang.String databaseConnectionAdapter) {
+ doSetProperty("databaseConnectionAdapter", databaseConnectionAdapter);
+ return this;
+ }
+ /**
+ * The name of the database from which the connector should capture
+ * changes.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: oracle
+ *
+ * @param databaseDbname the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleComponentBuilder databaseDbname(
+ java.lang.String databaseDbname) {
+ doSetProperty("databaseDbname", databaseDbname);
+ return this;
+ }
+ /**
+ * The name of the DatabaseHistory class that should be used to store
+ * and recover database schema changes. The configuration properties for
+ * the history are prefixed with the 'database.history.' string.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Default: class io.debezium.relational.history.KafkaDatabaseHistory
+ * Group: oracle
+ *
+ * @param databaseHistory the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleComponentBuilder databaseHistory(
+ java.lang.String databaseHistory) {
+ doSetProperty("databaseHistory", databaseHistory);
+ return this;
+ }
+ /**
+ * The path to the file that will be used to record the database
+ * history.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: oracle
+ *
+ * @param databaseHistoryFileFilename the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleComponentBuilder databaseHistoryFileFilename(
+ java.lang.String databaseHistoryFileFilename) {
+ doSetProperty("databaseHistoryFileFilename", databaseHistoryFileFilename);
+ return this;
+ }
+ /**
+ * A list of host/port pairs that the connector will use for
+ * establishing the initial connection to the Kafka cluster for
+ * retrieving database schema history previously stored by the
+ * connector. This should point to the same Kafka cluster used by the
+ * Kafka Connect process.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: oracle
+ *
+ * @param databaseHistoryKafkaBootstrapServers the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleComponentBuilder databaseHistoryKafkaBootstrapServers(
+ java.lang.String databaseHistoryKafkaBootstrapServers) {
+ doSetProperty("databaseHistoryKafkaBootstrapServers", databaseHistoryKafkaBootstrapServers);
+ return this;
+ }
+ /**
+ * The number of attempts in a row that no data are returned from Kafka
+ * before recover completes. The maximum amount of time to wait after
+ * receiving no data is (recovery.attempts) x
+ * (recovery.poll.interval.ms).
+ *
+ * The option is a: <code>int</code> type.
+ *
+ * Default: 100
+ * Group: oracle
+ *
+ * @param databaseHistoryKafkaRecoveryAttempts the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleComponentBuilder databaseHistoryKafkaRecoveryAttempts(
+ int databaseHistoryKafkaRecoveryAttempts) {
+ doSetProperty("databaseHistoryKafkaRecoveryAttempts", databaseHistoryKafkaRecoveryAttempts);
+ return this;
+ }
+ /**
+ * The number of milliseconds to wait while polling for persisted data
+ * during recovery.
+ *
+ * The option is a: <code>int</code> type.
+ *
+ * Default: 100ms
+ * Group: oracle
+ *
+ * @param databaseHistoryKafkaRecoveryPollIntervalMs the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleComponentBuilder databaseHistoryKafkaRecoveryPollIntervalMs(
+ int databaseHistoryKafkaRecoveryPollIntervalMs) {
+ doSetProperty("databaseHistoryKafkaRecoveryPollIntervalMs", databaseHistoryKafkaRecoveryPollIntervalMs);
+ return this;
+ }
+ /**
+ * The name of the topic for the database schema history.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: oracle
+ *
+ * @param databaseHistoryKafkaTopic the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleComponentBuilder databaseHistoryKafkaTopic(
+ java.lang.String databaseHistoryKafkaTopic) {
+ doSetProperty("databaseHistoryKafkaTopic", databaseHistoryKafkaTopic);
+ return this;
+ }
+ /**
+ * Controls the action Debezium will take when it meets a DDL statement
+ * in binlog, that it cannot parse.By default the connector will stop
+ * operating but by changing the setting it can ignore the statements
+ * which it cannot parse. If skipping is enabled then Debezium can miss
+ * metadata changes.
+ *
+ * The option is a: <code>boolean</code> type.
+ *
+ * Default: false
+ * Group: oracle
+ *
+ * @param databaseHistorySkipUnparseableDdl the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleComponentBuilder databaseHistorySkipUnparseableDdl(
+ boolean databaseHistorySkipUnparseableDdl) {
+ doSetProperty("databaseHistorySkipUnparseableDdl", databaseHistorySkipUnparseableDdl);
+ return this;
+ }
+ /**
+ * Controls what DDL will Debezium store in database history. By default
+ * (false) Debezium will store all incoming DDL statements. If set to
+ * true, then only DDL that manipulates a captured table will be stored.
+ *
+ * The option is a: <code>boolean</code> type.
+ *
+ * Default: false
+ * Group: oracle
+ *
+ * @param databaseHistoryStoreOnlyCapturedTablesDdl the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleComponentBuilder databaseHistoryStoreOnlyCapturedTablesDdl(
+ boolean databaseHistoryStoreOnlyCapturedTablesDdl) {
+ doSetProperty("databaseHistoryStoreOnlyCapturedTablesDdl", databaseHistoryStoreOnlyCapturedTablesDdl);
+ return this;
+ }
+ /**
+ * Controls what DDL will Debezium store in database history. By default
+ * (false) Debezium will store all incoming DDL statements. If set to
+ * true, then only DDL that manipulates a monitored table will be stored
+ * (deprecated, use database.history.store.only.captured.tables.ddl
+ * instead).
+ *
+ * The option is a: <code>boolean</code> type.
+ *
+ * Default: false
+ * Group: oracle
+ *
+ * @param databaseHistoryStoreOnlyMonitoredTablesDdl the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleComponentBuilder databaseHistoryStoreOnlyMonitoredTablesDdl(
+ boolean databaseHistoryStoreOnlyMonitoredTablesDdl) {
+ doSetProperty("databaseHistoryStoreOnlyMonitoredTablesDdl", databaseHistoryStoreOnlyMonitoredTablesDdl);
+ return this;
+ }
+ /**
+ * Resolvable hostname or IP address of the database server.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: oracle
+ *
+ * @param databaseHostname the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleComponentBuilder databaseHostname(
+ java.lang.String databaseHostname) {
+ doSetProperty("databaseHostname", databaseHostname);
+ return this;
+ }
+ /**
+ * Name of the XStream Out server to connect to.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: oracle
+ *
+ * @param databaseOutServerName the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleComponentBuilder databaseOutServerName(
+ java.lang.String databaseOutServerName) {
+ doSetProperty("databaseOutServerName", databaseOutServerName);
+ return this;
+ }
+ /**
+ * Password of the database user to be used when connecting to the
+ * database.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: oracle
+ *
+ * @param databasePassword the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleComponentBuilder databasePassword(
+ java.lang.String databasePassword) {
+ doSetProperty("databasePassword", databasePassword);
+ return this;
+ }
+ /**
+ * Name of the pluggable database when working with a multi-tenant
+ * set-up. The CDB name must be given via database.dbname in this case.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: oracle
+ *
+ * @param databasePdbName the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleComponentBuilder databasePdbName(
+ java.lang.String databasePdbName) {
+ doSetProperty("databasePdbName", databasePdbName);
+ return this;
+ }
+ /**
+ * Port of the database server.
+ *
+ * The option is a: <code>int</code> type.
+ *
+ * Default: 1528
+ * Group: oracle
+ *
+ * @param databasePort the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleComponentBuilder databasePort(int databasePort) {
+ doSetProperty("databasePort", databasePort);
+ return this;
+ }
+ /**
+ * Unique name that identifies the database server and all recorded
+ * offsets, and that is used as a prefix for all schemas and topics.
+ * Each distinct installation should have a separate namespace and be
+ * monitored by at most one Debezium connector.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: oracle
+ *
+ * @param databaseServerName the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleComponentBuilder databaseServerName(
+ java.lang.String databaseServerName) {
+ doSetProperty("databaseServerName", databaseServerName);
+ return this;
+ }
+ /**
+ * Complete JDBC URL as an alternative to specifying hostname, port and
+ * database provided as a way to support alternative connection
+ * scenarios.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: oracle
+ *
+ * @param databaseUrl the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleComponentBuilder databaseUrl(
+ java.lang.String databaseUrl) {
+ doSetProperty("databaseUrl", databaseUrl);
+ return this;
+ }
+ /**
+ * Name of the database user to be used when connecting to the database.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: oracle
+ *
+ * @param databaseUser the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleComponentBuilder databaseUser(
+ java.lang.String databaseUser) {
+ doSetProperty("databaseUser", databaseUser);
+ return this;
+ }
+ /**
+ * A comma-separated list of regular expressions matching the
+ * database-specific data type names that adds the data type's original
+ * type and original length as parameters to the corresponding field
+ * schemas in the emitted change records.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: oracle
+ *
+ * @param datatypePropagateSourceType the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleComponentBuilder datatypePropagateSourceType(
+ java.lang.String datatypePropagateSourceType) {
+ doSetProperty("datatypePropagateSourceType", datatypePropagateSourceType);
+ return this;
+ }
+ /**
+ * Specify how DECIMAL and NUMERIC columns should be represented in
+ * change events, including:'precise' (the default) uses
+ * java.math.BigDecimal to represent values, which are encoded in the
+ * change events using a binary representation and Kafka Connect's
+ * 'org.apache.kafka.connect.data.Decimal' type; 'string' uses string to
+ * represent values; 'double' represents values using Java's 'double',
+ * which may not offer the precision but will be far easier to use in
+ * consumers.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Default: precise
+ * Group: oracle
+ *
+ * @param decimalHandlingMode the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleComponentBuilder decimalHandlingMode(
+ java.lang.String decimalHandlingMode) {
+ doSetProperty("decimalHandlingMode", decimalHandlingMode);
+ return this;
+ }
+ /**
+ * Specify how failures during processing of events (i.e. when
+ * encountering a corrupted event) should be handled, including:'fail'
+ * (the default) an exception indicating the problematic event and its
+ * position is raised, causing the connector to be stopped; 'warn' the
+ * problematic event and its position will be logged and the event will
+ * be skipped;'ignore' the problematic event will be skipped.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Default: fail
+ * Group: oracle
+ *
+ * @param eventProcessingFailureHandlingMode the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleComponentBuilder eventProcessingFailureHandlingMode(
+ java.lang.String eventProcessingFailureHandlingMode) {
+ doSetProperty("eventProcessingFailureHandlingMode", eventProcessingFailureHandlingMode);
+ return this;
+ }
+ /**
+ * The query executed with every heartbeat.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: oracle
+ *
+ * @param heartbeatActionQuery the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleComponentBuilder heartbeatActionQuery(
+ java.lang.String heartbeatActionQuery) {
+ doSetProperty("heartbeatActionQuery", heartbeatActionQuery);
+ return this;
+ }
+ /**
+ * Length of an interval in milli-seconds in in which the connector
+ * periodically sends heartbeat messages to a heartbeat topic. Use 0 to
+ * disable heartbeat messages. Disabled by default.
+ *
+ * The option is a: <code>int</code> type.
+ *
+ * Default: 0ms
+ * Group: oracle
+ *
+ * @param heartbeatIntervalMs the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleComponentBuilder heartbeatIntervalMs(
+ int heartbeatIntervalMs) {
+ doSetProperty("heartbeatIntervalMs", heartbeatIntervalMs);
+ return this;
+ }
+ /**
+ * The prefix that is used to name heartbeat topics.Defaults to
+ * __debezium-heartbeat.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Default: __debezium-heartbeat
+ * Group: oracle
+ *
+ * @param heartbeatTopicsPrefix the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleComponentBuilder heartbeatTopicsPrefix(
+ java.lang.String heartbeatTopicsPrefix) {
+ doSetProperty("heartbeatTopicsPrefix", heartbeatTopicsPrefix);
+ return this;
+ }
+ /**
+ * Whether the connector should publish changes in the database schema
+ * to a Kafka topic with the same name as the database server ID. Each
+ * schema change will be recorded using a key that contains the database
+ * name and whose value include logical description of the new schema
+ * and optionally the DDL statement(s).The default is 'true'. This is
+ * independent of how the connector internally records database history.
+ *
+ * The option is a: <code>boolean</code> type.
+ *
+ * Default: true
+ * Group: oracle
+ *
+ * @param includeSchemaChanges the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleComponentBuilder includeSchemaChanges(
+ boolean includeSchemaChanges) {
+ doSetProperty("includeSchemaChanges", includeSchemaChanges);
+ return this;
+ }
+ /**
+ * Whether the connector parse table and column's comment to metadata
+ * object.Note: Enable this option will bring the implications on memory
+ * usage. The number and size of ColumnImpl objects is what largely
+ * impacts how much memory is consumed by the Debezium connectors, and
+ * adding a String to each of them can potentially be quite heavy. The
+ * default is 'false'.
+ *
+ * The option is a: <code>boolean</code> type.
+ *
+ * Default: false
+ * Group: oracle
+ *
+ * @param includeSchemaComments the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleComponentBuilder includeSchemaComments(
+ boolean includeSchemaComments) {
+ doSetProperty("includeSchemaComments", includeSchemaComments);
+ return this;
+ }
+ /**
+ * Specify how INTERVAL columns should be represented in change events,
+ * including:'string' represents values as an exact ISO formatted
+ * string'numeric' (default) represents values using the inexact
+ * conversion into microseconds.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Default: numeric
+ * Group: oracle
+ *
+ * @param intervalHandlingMode the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleComponentBuilder intervalHandlingMode(
+ java.lang.String intervalHandlingMode) {
+ doSetProperty("intervalHandlingMode", intervalHandlingMode);
+ return this;
+ }
+ /**
+ * When set to false, the default, LOB fields will not be captured nor
+ * emitted. When set to true, the connector will capture LOB fields and
+ * emit changes for those fields like any other column type.
+ *
+ * The option is a: <code>boolean</code> type.
+ *
+ * Default: false
+ * Group: oracle
+ *
+ * @param lobEnabled the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleComponentBuilder lobEnabled(boolean lobEnabled) {
+ doSetProperty("lobEnabled", lobEnabled);
+ return this;
+ }
+ /**
+ * Sets the specific archive log destination as the source for reading
+ * archive logs.When not set, the connector will automatically select
+ * the first LOCAL and VALID destination.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: oracle
+ *
+ * @param logMiningArchiveDestinationName the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleComponentBuilder logMiningArchiveDestinationName(
+ java.lang.String logMiningArchiveDestinationName) {
+ doSetProperty("logMiningArchiveDestinationName", logMiningArchiveDestinationName);
+ return this;
+ }
+ /**
+ * The number of hours in the past from SYSDATE to mine archive logs.
+ * Using 0 mines all available archive logs.
+ *
+ * The option is a: <code>long</code> type.
+ *
+ * Default: 0
+ * Group: oracle
+ *
+ * @param logMiningArchiveLogHours the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleComponentBuilder logMiningArchiveLogHours(
+ long logMiningArchiveLogHours) {
+ doSetProperty("logMiningArchiveLogHours", logMiningArchiveLogHours);
+ return this;
+ }
+ /**
+ * When set to false, the default, the connector will mine both archive
+ * log and redo logs to emit change events. When set to true, the
+ * connector will only mine archive logs. There are circumstances where
+ * its advantageous to only mine archive logs and accept latency in
+ * event emission due to frequent revolving redo logs.
+ *
+ * The option is a: <code>boolean</code> type.
+ *
+ * Default: false
+ * Group: oracle
+ *
+ * @param logMiningArchiveLogOnlyMode the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleComponentBuilder logMiningArchiveLogOnlyMode(
+ boolean logMiningArchiveLogOnlyMode) {
+ doSetProperty("logMiningArchiveLogOnlyMode", logMiningArchiveLogOnlyMode);
+ return this;
+ }
+ /**
+ * The interval in milliseconds to wait between polls checking to see if
+ * the SCN is in the archive logs.
+ *
+ * The option is a: <code>long</code> type.
+ *
+ * Default: 10s
+ * Group: oracle
+ *
+ * @param logMiningArchiveLogOnlyScnPollIntervalMs the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleComponentBuilder logMiningArchiveLogOnlyScnPollIntervalMs(
+ long logMiningArchiveLogOnlyScnPollIntervalMs) {
+ doSetProperty("logMiningArchiveLogOnlyScnPollIntervalMs", logMiningArchiveLogOnlyScnPollIntervalMs);
+ return this;
+ }
+ /**
+ * The starting SCN interval size that the connector will use for
+ * reading data from redo/archive logs.
+ *
+ * The option is a: <code>long</code> type.
+ *
+ * Default: 20000
+ * Group: oracle
+ *
+ * @param logMiningBatchSizeDefault the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleComponentBuilder logMiningBatchSizeDefault(
+ long logMiningBatchSizeDefault) {
+ doSetProperty("logMiningBatchSizeDefault", logMiningBatchSizeDefault);
+ return this;
+ }
+ /**
+ * The maximum SCN interval size that this connector will use when
+ * reading from redo/archive logs.
+ *
+ * The option is a: <code>long</code> type.
+ *
+ * Default: 100000
+ * Group: oracle
+ *
+ * @param logMiningBatchSizeMax the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleComponentBuilder logMiningBatchSizeMax(
+ long logMiningBatchSizeMax) {
+ doSetProperty("logMiningBatchSizeMax", logMiningBatchSizeMax);
+ return this;
+ }
+ /**
+ * The minimum SCN interval size that this connector will try to read
+ * from redo/archive logs. Active batch size will be also
+ * increased/decreased by this amount for tuning connector throughput
+ * when needed.
+ *
+ * The option is a: <code>long</code> type.
+ *
+ * Default: 1000
+ * Group: oracle
+ *
+ * @param logMiningBatchSizeMin the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleComponentBuilder logMiningBatchSizeMin(
+ long logMiningBatchSizeMin) {
+ doSetProperty("logMiningBatchSizeMin", logMiningBatchSizeMin);
+ return this;
+ }
+ /**
+ * When set to true the underlying buffer cache is not retained when the
+ * connector is stopped. When set to false (the default), the buffer
+ * cache is retained across restarts.
+ *
+ * The option is a: <code>boolean</code> type.
+ *
+ * Default: false
+ * Group: oracle
+ *
+ * @param logMiningBufferDropOnStop the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleComponentBuilder logMiningBufferDropOnStop(
+ boolean logMiningBufferDropOnStop) {
+ doSetProperty("logMiningBufferDropOnStop", logMiningBufferDropOnStop);
+ return this;
+ }
+ /**
+ * Specifies the XML configuration for the Infinispan 'events' cache.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: oracle
+ *
+ * @param logMiningBufferInfinispanCacheEvents the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleComponentBuilder logMiningBufferInfinispanCacheEvents(
+ java.lang.String logMiningBufferInfinispanCacheEvents) {
+ doSetProperty("logMiningBufferInfinispanCacheEvents", logMiningBufferInfinispanCacheEvents);
+ return this;
+ }
+ /**
+ * Specifies the XML configuration for the Infinispan
+ * 'processed-transactions' cache.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: oracle
+ *
+ * @param logMiningBufferInfinispanCacheProcessedTransactions the value
+ * to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleComponentBuilder logMiningBufferInfinispanCacheProcessedTransactions(
+ java.lang.String logMiningBufferInfinispanCacheProcessedTransactions) {
+ doSetProperty("logMiningBufferInfinispanCacheProcessedTransactions", logMiningBufferInfinispanCacheProcessedTransactions);
+ return this;
+ }
+ /**
+ * Specifies the XML configuration for the Infinispan 'schema-changes'
+ * cache.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: oracle
+ *
+ * @param logMiningBufferInfinispanCacheSchemaChanges the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleComponentBuilder logMiningBufferInfinispanCacheSchemaChanges(
+ java.lang.String logMiningBufferInfinispanCacheSchemaChanges) {
+ doSetProperty("logMiningBufferInfinispanCacheSchemaChanges", logMiningBufferInfinispanCacheSchemaChanges);
+ return this;
+ }
+ /**
+ * Specifies the XML configuration for the Infinispan 'transactions'
+ * cache.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: oracle
+ *
+ * @param logMiningBufferInfinispanCacheTransactions the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleComponentBuilder logMiningBufferInfinispanCacheTransactions(
+ java.lang.String logMiningBufferInfinispanCacheTransactions) {
+ doSetProperty("logMiningBufferInfinispanCacheTransactions", logMiningBufferInfinispanCacheTransactions);
+ return this;
+ }
+ /**
+ * The buffer type controls how the connector manages buffering
+ * transaction data. memory - Uses the JVM process' heap to buffer all
+ * transaction data. infinispan_embedded - This option uses an embedded
+ * Infinispan cache to buffer transaction data and persist it to disk.
+ * infinispan_remote - This option uses a remote Infinispan cluster to
+ * buffer transaction data and persist it to disk.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Default: memory
+ * Group: oracle
+ *
+ * @param logMiningBufferType the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleComponentBuilder logMiningBufferType(
+ java.lang.String logMiningBufferType) {
+ doSetProperty("logMiningBufferType", logMiningBufferType);
+ return this;
+ }
+ /**
+ * Used for SCN gap detection, if the difference between current SCN and
+ * previous end SCN is bigger than this value, and the time difference
+ * of current SCN and previous end SCN is smaller than
+ * log.mining.scn.gap.detection.time.interval.max.ms, consider it a SCN
+ * gap.
+ *
+ * The option is a: <code>long</code> type.
+ *
+ * Default: 1000000
+ * Group: oracle
+ *
+ * @param logMiningScnGapDetectionGapSizeMin the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleComponentBuilder logMiningScnGapDetectionGapSizeMin(
+ long logMiningScnGapDetectionGapSizeMin) {
+ doSetProperty("logMiningScnGapDetectionGapSizeMin", logMiningScnGapDetectionGapSizeMin);
+ return this;
+ }
+ /**
+ * Used for SCN gap detection, if the difference between current SCN and
+ * previous end SCN is bigger than
+ * log.mining.scn.gap.detection.gap.size.min, and the time difference of
+ * current SCN and previous end SCN is smaller than this value, consider
+ * it a SCN gap.
+ *
+ * The option is a: <code>long</code> type.
+ *
+ * Default: 20s
+ * Group: oracle
+ *
+ * @param logMiningScnGapDetectionTimeIntervalMaxMs the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleComponentBuilder logMiningScnGapDetectionTimeIntervalMaxMs(
+ long logMiningScnGapDetectionTimeIntervalMaxMs) {
+ doSetProperty("logMiningScnGapDetectionTimeIntervalMaxMs", logMiningScnGapDetectionTimeIntervalMaxMs);
+ return this;
+ }
+ /**
+ * The amount of time that the connector will sleep after reading data
+ * from redo/archive logs and before starting reading data again. Value
+ * is in milliseconds.
+ *
+ * The option is a: <code>long</code> type.
+ *
+ * Default: 1s
+ * Group: oracle
+ *
+ * @param logMiningSleepTimeDefaultMs the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleComponentBuilder logMiningSleepTimeDefaultMs(
+ long logMiningSleepTimeDefaultMs) {
+ doSetProperty("logMiningSleepTimeDefaultMs", logMiningSleepTimeDefaultMs);
+ return this;
+ }
+ /**
+ * The maximum amount of time that the connector will use to tune the
+ * optimal sleep time when reading data from LogMiner. Value is in
+ * milliseconds.
+ *
+ * The option is a: <code>long</code> type.
+ *
+ * Default: 200ms
+ * Group: oracle
+ *
+ * @param logMiningSleepTimeIncrementMs the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleComponentBuilder logMiningSleepTimeIncrementMs(
+ long logMiningSleepTimeIncrementMs) {
+ doSetProperty("logMiningSleepTimeIncrementMs", logMiningSleepTimeIncrementMs);
+ return this;
+ }
+ /**
+ * The maximum amount of time that the connector will sleep after
+ * reading data from redo/archive logs and before starting reading data
+ * again. Value is in milliseconds.
+ *
+ * The option is a: <code>long</code> type.
+ *
+ * Default: 3s
+ * Group: oracle
+ *
+ * @param logMiningSleepTimeMaxMs the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleComponentBuilder logMiningSleepTimeMaxMs(
+ long logMiningSleepTimeMaxMs) {
+ doSetProperty("logMiningSleepTimeMaxMs", logMiningSleepTimeMaxMs);
+ return this;
+ }
+ /**
+ * The minimum amount of time that the connector will sleep after
+ * reading data from redo/archive logs and before starting reading data
+ * again. Value is in milliseconds.
+ *
+ * The option is a: <code>long</code> type.
+ *
+ * Default: 0ms
+ * Group: oracle
+ *
+ * @param logMiningSleepTimeMinMs the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleComponentBuilder logMiningSleepTimeMinMs(
+ long logMiningSleepTimeMinMs) {
+ doSetProperty("logMiningSleepTimeMinMs", logMiningSleepTimeMinMs);
+ return this;
+ }
+ /**
+ * There are strategies: Online catalog with faster mining but no
+ * captured DDL. Another - with data dictionary loaded into REDO LOG
+ * files.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Default: redo_log_catalog
+ * Group: oracle
+ *
+ * @param logMiningStrategy the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleComponentBuilder logMiningStrategy(
+ java.lang.String logMiningStrategy) {
+ doSetProperty("logMiningStrategy", logMiningStrategy);
+ return this;
+ }
+ /**
+ * Hours to keep long running transactions in transaction buffer between
+ * log mining sessions. By default, all transactions are retained.
+ *
+ * The option is a: <code>long</code> type.
+ *
+ * Default: 0
+ * Group: oracle
+ *
+ * @param logMiningTransactionRetentionHours the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleComponentBuilder logMiningTransactionRetentionHours(
+ long logMiningTransactionRetentionHours) {
+ doSetProperty("logMiningTransactionRetentionHours", logMiningTransactionRetentionHours);
+ return this;
+ }
+ /**
+ * Comma separated list of usernames to exclude from LogMiner query.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: oracle
+ *
+ * @param logMiningUsernameExcludeList the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleComponentBuilder logMiningUsernameExcludeList(
+ java.lang.String logMiningUsernameExcludeList) {
+ doSetProperty("logMiningUsernameExcludeList", logMiningUsernameExcludeList);
+ return this;
+ }
+ /**
+ * Maximum size of each batch of source records. Defaults to 2048.
+ *
+ * The option is a: <code>int</code> type.
+ *
+ * Default: 2048
+ * Group: oracle
+ *
+ * @param maxBatchSize the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleComponentBuilder maxBatchSize(int maxBatchSize) {
+ doSetProperty("maxBatchSize", maxBatchSize);
+ return this;
+ }
+ /**
+ * Maximum size of the queue for change events read from the database
+ * log but not yet recorded or forwarded. Defaults to 8192, and should
+ * always be larger than the maximum batch size.
+ *
+ * The option is a: <code>int</code> type.
+ *
+ * Default: 8192
+ * Group: oracle
+ *
+ * @param maxQueueSize the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleComponentBuilder maxQueueSize(int maxQueueSize) {
+ doSetProperty("maxQueueSize", maxQueueSize);
+ return this;
+ }
+ /**
+ * Maximum size of the queue in bytes for change events read from the
+ * database log but not yet recorded or forwarded. Defaults to 0. Mean
+ * the feature is not enabled.
+ *
+ * The option is a: <code>long</code> type.
+ *
+ * Default: 0
+ * Group: oracle
+ *
+ * @param maxQueueSizeInBytes the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleComponentBuilder maxQueueSizeInBytes(
+ long maxQueueSizeInBytes) {
+ doSetProperty("maxQueueSizeInBytes", maxQueueSizeInBytes);
+ return this;
+ }
+ /**
+ * A semicolon-separated list of expressions that match fully-qualified
+ * tables and column(s) to be used as message key. Each expression must
+ * match the pattern ':',where the table names could be defined as
+ * (DB_NAME.TABLE_NAME) or (SCHEMA_NAME.TABLE_NAME), depending on the
+ * specific connector,and the key columns are a comma-separated list of
+ * columns representing the custom key. For any table without an
+ * explicit key configuration the table's primary key column(s) will be
+ * used as message key.Example:
+ * dbserver1.inventory.orderlines:orderId,orderLineId;dbserver1.inventory.orders:id.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: oracle
+ *
+ * @param messageKeyColumns the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleComponentBuilder messageKeyColumns(
+ java.lang.String messageKeyColumns) {
+ doSetProperty("messageKeyColumns", messageKeyColumns);
+ return this;
+ }
+ /**
+ * Time to wait for new change events to appear after receiving no
+ * events, given in milliseconds. Defaults to 500 ms.
+ *
+ * The option is a: <code>long</code> type.
+ *
+ * Default: 500ms
+ * Group: oracle
+ *
+ * @param pollIntervalMs the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleComponentBuilder pollIntervalMs(
+ long pollIntervalMs) {
+ doSetProperty("pollIntervalMs", pollIntervalMs);
+ return this;
+ }
+ /**
+ * Enables transaction metadata extraction together with event counting.
+ *
+ * The option is a: <code>boolean</code> type.
+ *
+ * Default: false
+ * Group: oracle
+ *
+ * @param provideTransactionMetadata the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleComponentBuilder provideTransactionMetadata(
+ boolean provideTransactionMetadata) {
+ doSetProperty("provideTransactionMetadata", provideTransactionMetadata);
+ return this;
+ }
+ /**
+ * The maximum number of records that should be loaded into memory while
+ * streaming. A value of 0 uses the default JDBC fetch size.
+ *
+ * The option is a: <code>int</code> type.
+ *
+ * Default: 0
+ * Group: oracle
+ *
+ * @param queryFetchSize the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleComponentBuilder queryFetchSize(int queryFetchSize) {
+ doSetProperty("queryFetchSize", queryFetchSize);
+ return this;
+ }
+ /**
+ * A comma-separated list of RAC node hostnames or ip addresses.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: oracle
+ *
+ * @param racNodes the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleComponentBuilder racNodes(
+ java.lang.String racNodes) {
+ doSetProperty("racNodes", racNodes);
+ return this;
+ }
+ /**
+ * Time to wait before restarting connector after retriable exception
+ * occurs. Defaults to 10000ms.
+ *
+ * The option is a: <code>long</code> type.
+ *
+ * Default: 10s
+ * Group: oracle
+ *
+ * @param retriableRestartConnectorWaitMs the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleComponentBuilder retriableRestartConnectorWaitMs(
+ long retriableRestartConnectorWaitMs) {
+ 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 data collection that is used to send signals/commands
+ * to Debezium. Signaling is disabled when not set.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: oracle
+ *
+ * @param signalDataCollection the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleComponentBuilder signalDataCollection(
+ java.lang.String signalDataCollection) {
+ doSetProperty("signalDataCollection", signalDataCollection);
+ return this;
+ }
+ /**
+ * The comma-separated list of operations to skip during streaming,
+ * defined as: 'c' for inserts/create; 'u' for updates; 'd' for deletes.
+ * By default, no operations will be skipped.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: oracle
+ *
+ * @param skippedOperations the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleComponentBuilder skippedOperations(
+ java.lang.String skippedOperations) {
+ doSetProperty("skippedOperations", skippedOperations);
+ return this;
+ }
+ /**
+ * A delay period before a snapshot will begin, given in milliseconds.
+ * Defaults to 0 ms.
+ *
+ * The option is a: <code>long</code> type.
+ *
+ * Default: 0ms
+ * Group: oracle
+ *
+ * @param snapshotDelayMs the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleComponentBuilder snapshotDelayMs(
+ long snapshotDelayMs) {
+ doSetProperty("snapshotDelayMs", snapshotDelayMs);
+ return this;
+ }
+ /**
+ * A token to replace on snapshot predicate template.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: oracle
+ *
+ * @param snapshotEnhancePredicateScn the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleComponentBuilder snapshotEnhancePredicateScn(
+ java.lang.String snapshotEnhancePredicateScn) {
+ doSetProperty("snapshotEnhancePredicateScn", snapshotEnhancePredicateScn);
+ return this;
+ }
+ /**
+ * The maximum number of records that should be loaded into memory while
+ * performing a snapshot.
+ *
+ * The option is a: <code>int</code> type.
+ *
+ * Group: oracle
+ *
+ * @param snapshotFetchSize the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleComponentBuilder snapshotFetchSize(
+ int snapshotFetchSize) {
+ doSetProperty("snapshotFetchSize", snapshotFetchSize);
+ return this;
+ }
+ /**
+ * this setting must be set to specify a list of tables/collections
+ * whose snapshot must be taken on creating or restarting the connector.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: oracle
+ *
+ * @param snapshotIncludeCollectionList the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleComponentBuilder snapshotIncludeCollectionList(
+ java.lang.String snapshotIncludeCollectionList) {
+ doSetProperty("snapshotIncludeCollectionList", snapshotIncludeCollectionList);
+ return this;
+ }
+ /**
+ * Controls how the connector holds locks on tables while performing the
+ * schema snapshot. The default is 'shared', which means the connector
+ * will hold a table lock that prevents exclusive table access for just
+ * the initial portion of the snapshot while the database schemas and
+ * other metadata are being read. The remaining work in a snapshot
+ * involves selecting all rows from each table, and this is done using a
+ * flashback query that requires no locks. However, in some cases it may
+ * be desirable to avoid locks entirely which can be done by specifying
+ * 'none'. This mode is only safe to use if no schema changes are
+ * happening while the snapshot is taken.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Default: shared
+ * Group: oracle
+ *
+ * @param snapshotLockingMode the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleComponentBuilder snapshotLockingMode(
+ java.lang.String snapshotLockingMode) {
+ doSetProperty("snapshotLockingMode", snapshotLockingMode);
+ return this;
+ }
+ /**
+ * The maximum number of millis to wait for table locks at the beginning
+ * of a snapshot. If locks cannot be acquired in this time frame, the
+ * snapshot will be aborted. Defaults to 10 seconds.
+ *
+ * The option is a: <code>long</code> type.
+ *
+ * Default: 10s
+ * Group: oracle
+ *
+ * @param snapshotLockTimeoutMs the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleComponentBuilder snapshotLockTimeoutMs(
+ long snapshotLockTimeoutMs) {
+ doSetProperty("snapshotLockTimeoutMs", snapshotLockTimeoutMs);
+ return this;
+ }
+ /**
+ * The maximum number of threads used to perform the snapshot. Defaults
+ * to 1.
+ *
+ * The option is a: <code>int</code> type.
+ *
+ * Default: 1
+ * Group: oracle
+ *
+ * @param snapshotMaxThreads the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleComponentBuilder snapshotMaxThreads(
+ int snapshotMaxThreads) {
+ doSetProperty("snapshotMaxThreads", snapshotMaxThreads);
+ return this;
+ }
+ /**
+ * The criteria for running a snapshot upon startup of the connector.
+ * Options include: 'initial' (the default) to specify the connector
+ * should run a snapshot only when no offsets are available for the
+ * logical server name; 'schema_only' to specify the connector should
+ * run a snapshot of the schema when no offsets are available for the
+ * logical server name.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Default: initial
+ * Group: oracle
+ *
+ * @param snapshotMode the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleComponentBuilder snapshotMode(
+ java.lang.String snapshotMode) {
+ doSetProperty("snapshotMode", snapshotMode);
+ return this;
+ }
+ /**
+ * This property contains a comma-separated list of fully-qualified
+ * tables (DB_NAME.TABLE_NAME) or (SCHEMA_NAME.TABLE_NAME), depending on
+ * thespecific connectors. Select statements for the individual tables
+ * are specified in further configuration properties, one for each
+ * table, identified by the id
+ * 'snapshot.select.statement.overrides.DB_NAME.TABLE_NAME' or
+ * 'snapshot.select.statement.overrides.SCHEMA_NAME.TABLE_NAME',
+ * respectively. The value of those properties is the select statement
+ * to use when retrieving data from the specific table during
+ * snapshotting. A possible use case for large append-only tables is
+ * setting a specific point where to start (resume) snapshotting, in
+ * case a previous snapshotting was interrupted.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: oracle
+ *
+ * @param snapshotSelectStatementOverrides the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleComponentBuilder snapshotSelectStatementOverrides(
+ java.lang.String snapshotSelectStatementOverrides) {
+ doSetProperty("snapshotSelectStatementOverrides", snapshotSelectStatementOverrides);
+ return this;
+ }
+ /**
+ * A version of the format of the publicly visible source part in the
+ * message.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Default: v2
+ * Group: oracle
+ *
+ * @param sourceStructVersion the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleComponentBuilder sourceStructVersion(
+ java.lang.String sourceStructVersion) {
+ doSetProperty("sourceStructVersion", sourceStructVersion);
+ return this;
+ }
+ /**
+ * A comma-separated list of regular expressions that match the
+ * fully-qualified names of tables to be excluded from monitoring
+ * (deprecated, use table.exclude.list instead).
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: oracle
+ *
+ * @param tableBlacklist the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleComponentBuilder tableBlacklist(
+ java.lang.String tableBlacklist) {
+ doSetProperty("tableBlacklist", tableBlacklist);
+ return this;
+ }
+ /**
+ * A comma-separated list of regular expressions that match the
+ * fully-qualified names of tables to be excluded from monitoring.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: oracle
+ *
+ * @param tableExcludeList the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleComponentBuilder tableExcludeList(
+ java.lang.String tableExcludeList) {
+ doSetProperty("tableExcludeList", tableExcludeList);
+ return this;
+ }
+ /**
+ * The tables for which changes are to be captured.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: oracle
+ *
+ * @param tableIncludeList the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleComponentBuilder tableIncludeList(
+ java.lang.String tableIncludeList) {
+ doSetProperty("tableIncludeList", tableIncludeList);
+ return this;
+ }
+ /**
+ * The tables for which changes are to be captured (deprecated, use
+ * table.include.list instead).
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: oracle
+ *
+ * @param tableWhitelist the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleComponentBuilder tableWhitelist(
+ java.lang.String tableWhitelist) {
+ doSetProperty("tableWhitelist", tableWhitelist);
+ return this;
+ }
+ /**
+ * Time, date, and timestamps can be represented with different kinds of
+ * precisions, including:'adaptive' (the default) bases the precision of
+ * time, date, and timestamp values on the database column's precision;
+ * 'adaptive_time_microseconds' like 'adaptive' mode, but TIME fields
+ * always use microseconds precision;'connect' always represents time,
+ * date, and timestamp values using Kafka Connect's built-in
+ * representations for Time, Date, and Timestamp, which uses millisecond
+ * precision regardless of the database columns' precision .
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Default: adaptive
+ * Group: oracle
+ *
+ * @param timePrecisionMode the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleComponentBuilder timePrecisionMode(
+ java.lang.String timePrecisionMode) {
+ doSetProperty("timePrecisionMode", timePrecisionMode);
+ return this;
+ }
+ /**
+ * Whether delete operations should be represented by a delete event and
+ * a subsquenttombstone event (true) or only by a delete event (false).
+ * Emitting the tombstone event (the default behavior) allows Kafka to
+ * completely delete all events pertaining to the given key once the
+ * source record got deleted.
+ *
+ * The option is a: <code>boolean</code> type.
+ *
+ * Default: false
+ * Group: oracle
+ *
+ * @param tombstonesOnDelete the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleComponentBuilder tombstonesOnDelete(
+ boolean tombstonesOnDelete) {
+ doSetProperty("tombstonesOnDelete", tombstonesOnDelete);
+ return this;
+ }
+ /**
+ * The name of the transaction metadata topic. The placeholder
+ * ${database.server.name} can be used for referring to the connector's
+ * logical name; defaults to ${database.server.name}.transaction.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Default: ${database.server.name}.transaction
+ * Group: oracle
+ *
+ * @param transactionTopic the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleComponentBuilder transactionTopic(
+ java.lang.String transactionTopic) {
+ doSetProperty("transactionTopic", transactionTopic);
+ return this;
+ }
+ /**
+ * Specify the constant that will be provided by Debezium to indicate
+ * that the original value is unavailable and not provided by the
+ * database.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Default: __debezium_unavailable_value
+ * Group: oracle
+ *
+ * @param unavailableValuePlaceholder the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleComponentBuilder unavailableValuePlaceholder(
+ java.lang.String unavailableValuePlaceholder) {
+ doSetProperty("unavailableValuePlaceholder", unavailableValuePlaceholder);
+ return this;
+ }
+ }
+
+ class DebeziumOracleComponentBuilderImpl
+ extends
+ AbstractComponentBuilder<DebeziumOracleComponent>
+ implements
+ DebeziumOracleComponentBuilder {
+ @Override
+ protected DebeziumOracleComponent buildConcreteComponent() {
+ return new DebeziumOracleComponent();
+ }
+ private org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration getOrCreateConfiguration(
+ org.apache.camel.component.debezium.DebeziumOracleComponent component) {
+ if (component.getConfiguration() == null) {
+ component.setConfiguration(new org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration());
+ }
+ return component.getConfiguration();
+ }
+ @Override
+ protected boolean setPropertyOnComponent(
+ Component component,
+ String name,
+ Object value) {
+ switch (name) {
+ case "additionalProperties": getOrCreateConfiguration((DebeziumOracleComponent) component).setAdditionalProperties((java.util.Map) value); return true;
+ case "bridgeErrorHandler": ((DebeziumOracleComponent) component).setBridgeErrorHandler((boolean) value); return true;
+ case "configuration": ((DebeziumOracleComponent) component).setConfiguration((org.apache.camel.component.debezium.configuration.OracleConnectorEmbeddedDebeziumConfiguration) value); return true;
+ case "internalKeyConverter": getOrCreateConfiguration((DebeziumOracleComponent) component).setInternalKeyConverter((java.lang.String) value); return true;
+ case "internalValueConverter": getOrCreateConfiguration((DebeziumOracleComponent) component).setInternalValueConverter((java.lang.String) value); return true;
+ case "offsetCommitPolicy": getOrCreateConfiguration((DebeziumOracleComponent) component).setOffsetCommitPolicy((java.lang.String) value); return true;
+ case "offsetCommitTimeoutMs": getOrCreateConfiguration((DebeziumOracleComponent) component).setOffsetCommitTimeoutMs((long) value); return true;
+ case "offsetFlushIntervalMs": getOrCreateConfiguration((DebeziumOracleComponent) component).setOffsetFlushIntervalMs((long) value); return true;
+ case "offsetStorage": getOrCreateConfiguration((DebeziumOracleComponent) component).setOffsetStorage((java.lang.String) value); return true;
+ case "offsetStorageFileName": getOrCreateConfiguration((DebeziumOracleComponent) component).setOffsetStorageFileName((java.lang.String) value); return true;
+ case "offsetStoragePartitions": getOrCreateConfiguration((DebeziumOracleComponent) component).setOffsetStoragePartitions((int) value); return true;
+ case "offsetStorageReplicationFactor": getOrCreateConfiguration((DebeziumOracleComponent) component).setOffsetStorageReplicationFactor((int) value); return true;
+ case "offsetStorageTopic": getOrCreateConfiguration((DebeziumOracleComponent) component).setOffsetStorageTopic((java.lang.String) value); return true;
+ case "autowiredEnabled": ((DebeziumOracleComponent) component).setAutowiredEnabled((boolean) value); return true;
+ case "binaryHandlingMode": getOrCreateConfiguration((DebeziumOracleComponent) component).setBinaryHandlingMode((java.lang.String) value); return true;
+ case "columnBlacklist": getOrCreateConfiguration((DebeziumOracleComponent) component).setColumnBlacklist((java.lang.String) value); return true;
+ case "columnExcludeList": getOrCreateConfiguration((DebeziumOracleComponent) component).setColumnExcludeList((java.lang.String) value); return true;
+ case "columnIncludeList": getOrCreateConfiguration((DebeziumOracleComponent) component).setColumnIncludeList((java.lang.String) value); return true;
+ case "columnPropagateSourceType": getOrCreateConfiguration((DebeziumOracleComponent) component).setColumnPropagateSourceType((java.lang.String) value); return true;
+ case "columnWhitelist": getOrCreateConfiguration((DebeziumOracleComponent) component).setColumnWhitelist((java.lang.String) value); return true;
+ case "converters": getOrCreateConfiguration((DebeziumOracleComponent) component).setConverters((java.lang.String) value); return true;
+ case "databaseConnectionAdapter": getOrCreateConfiguration((DebeziumOracleComponent) component).setDatabaseConnectionAdapter((java.lang.String) value); return true;
+ case "databaseDbname": getOrCreateConfiguration((DebeziumOracleComponent) component).setDatabaseDbname((java.lang.String) value); return true;
+ case "databaseHistory": getOrCreateConfiguration((DebeziumOracleComponent) component).setDatabaseHistory((java.lang.String) value); return true;
+ case "databaseHistoryFileFilename": getOrCreateConfiguration((DebeziumOracleComponent) component).setDatabaseHistoryFileFilename((java.lang.String) value); return true;
+ case "databaseHistoryKafkaBootstrapServers": getOrCreateConfiguration((DebeziumOracleComponent) component).setDatabaseHistoryKafkaBootstrapServers((java.lang.String) value); return true;
+ case "databaseHistoryKafkaRecoveryAttempts": getOrCreateConfiguration((DebeziumOracleComponent) component).setDatabaseHistoryKafkaRecoveryAttempts((int) value); return true;
+ case "databaseHistoryKafkaRecoveryPollIntervalMs": getOrCreateConfiguration((DebeziumOracleComponent) component).setDatabaseHistoryKafkaRecoveryPollIntervalMs((int) value); return true;
+ case "databaseHistoryKafkaTopic": getOrCreateConfiguration((DebeziumOracleComponent) component).setDatabaseHistoryKafkaTopic((java.lang.String) value); return true;
+ case "databaseHistorySkipUnparseableDdl": getOrCreateConfiguration((DebeziumOracleComponent) component).setDatabaseHistorySkipUnparseableDdl((boolean) value); return true;
+ case "databaseHistoryStoreOnlyCapturedTablesDdl": getOrCreateConfiguration((DebeziumOracleComponent) component).setDatabaseHistoryStoreOnlyCapturedTablesDdl((boolean) value); return true;
+ case "databaseHistoryStoreOnlyMonitoredTablesDdl": getOrCreateConfiguration((DebeziumOracleComponent) component).setDatabaseHistoryStoreOnlyMonitoredTablesDdl((boolean) value); return true;
+ case "databaseHostname": getOrCreateConfiguration((DebeziumOracleComponent) component).setDatabaseHostname((java.lang.String) value); return true;
+ case "databaseOutServerName": getOrCreateConfiguration((DebeziumOracleComponent) component).setDatabaseOutServerName((java.lang.String) value); return true;
+ case "databasePassword": getOrCreateConfiguration((DebeziumOracleComponent) component).setDatabasePassword((java.lang.String) value); return true;
+ case "databasePdbName": getOrCreateConfiguration((DebeziumOracleComponent) component).setDatabasePdbName((java.lang.String) value); return true;
+ case "databasePort": getOrCreateConfiguration((DebeziumOracleComponent) component).setDatabasePort((int) value); return true;
+ case "databaseServerName": getOrCreateConfiguration((DebeziumOracleComponent) component).setDatabaseServerName((java.lang.String) value); return true;
+ case "databaseUrl": getOrCreateConfiguration((DebeziumOracleComponent) component).setDatabaseUrl((java.lang.String) value); return true;
+ case "databaseUser": getOrCreateConfiguration((DebeziumOracleComponent) component).setDatabaseUser((java.lang.String) value); return true;
+ case "datatypePropagateSourceType": getOrCreateConfiguration((DebeziumOracleComponent) component).setDatatypePropagateSourceType((java.lang.String) value); return true;
+ case "decimalHandlingMode": getOrCreateConfiguration((DebeziumOracleComponent) component).setDecimalHandlingMode((java.lang.String) value); return true;
+ case "eventProcessingFailureHandlingMode": getOrCreateConfiguration((DebeziumOracleComponent) component).setEventProcessingFailureHandlingMode((java.lang.String) value); return true;
+ case "heartbeatActionQuery": getOrCreateConfiguration((DebeziumOracleComponent) component).setHeartbeatActionQuery((java.lang.String) value); return true;
+ case "heartbeatIntervalMs": getOrCreateConfiguration((DebeziumOracleComponent) component).setHeartbeatIntervalMs((int) value); return true;
+ case "heartbeatTopicsPrefix": getOrCreateConfiguration((DebeziumOracleComponent) component).setHeartbeatTopicsPrefix((java.lang.String) value); return true;
+ case "includeSchemaChanges": getOrCreateConfiguration((DebeziumOracleComponent) component).setIncludeSchemaChanges((boolean) value); return true;
+ case "includeSchemaComments": getOrCreateConfiguration((DebeziumOracleComponent) component).setIncludeSchemaComments((boolean) value); return true;
+ case "intervalHandlingMode": getOrCreateConfiguration((DebeziumOracleComponent) component).setIntervalHandlingMode((java.lang.String) value); return true;
+ case "lobEnabled": getOrCreateConfiguration((DebeziumOracleComponent) component).setLobEnabled((boolean) value); return true;
+ case "logMiningArchiveDestinationName": getOrCreateConfiguration((DebeziumOracleComponent) component).setLogMiningArchiveDestinationName((java.lang.String) value); return true;
+ case "logMiningArchiveLogHours": getOrCreateConfiguration((DebeziumOracleComponent) component).setLogMiningArchiveLogHours((long) value); return true;
+ case "logMiningArchiveLogOnlyMode": getOrCreateConfiguration((DebeziumOracleComponent) component).setLogMiningArchiveLogOnlyMode((boolean) value); return true;
+ case "logMiningArchiveLogOnlyScnPollIntervalMs": getOrCreateConfiguration((DebeziumOracleComponent) component).setLogMiningArchiveLogOnlyScnPollIntervalMs((long) value); return true;
+ case "logMiningBatchSizeDefault": getOrCreateConfiguration((DebeziumOracleComponent) component).setLogMiningBatchSizeDefault((long) value); return true;
+ case "logMiningBatchSizeMax": getOrCreateConfiguration((DebeziumOracleComponent) component).setLogMiningBatchSizeMax((long) value); return true;
+ case "logMiningBatchSizeMin": getOrCreateConfiguration((DebeziumOracleComponent) component).setLogMiningBatchSizeMin((long) value); return true;
+ case "logMiningBufferDropOnStop": getOrCreateConfiguration((DebeziumOracleComponent) component).setLogMiningBufferDropOnStop((boolean) value); return true;
+ case "logMiningBufferInfinispanCacheEvents": getOrCreateConfiguration((DebeziumOracleComponent) component).setLogMiningBufferInfinispanCacheEvents((java.lang.String) value); return true;
+ case "logMiningBufferInfinispanCacheProcessedTransactions": getOrCreateConfiguration((DebeziumOracleComponent) component).setLogMiningBufferInfinispanCacheProcessedTransactions((java.lang.String) value); return true;
+ case "logMiningBufferInfinispanCacheSchemaChanges": getOrCreateConfiguration((DebeziumOracleComponent) component).setLogMiningBufferInfinispanCacheSchemaChanges((java.lang.String) value); return true;
+ case "logMiningBufferInfinispanCacheTransactions": getOrCreateConfiguration((DebeziumOracleComponent) component).setLogMiningBufferInfinispanCacheTransactions((java.lang.String) value); return true;
+ case "logMiningBufferType": getOrCreateConfiguration((DebeziumOracleComponent) component).setLogMiningBufferType((java.lang.String) value); return true;
+ case "logMiningScnGapDetectionGapSizeMin": getOrCreateConfiguration((DebeziumOracleComponent) component).setLogMiningScnGapDetectionGapSizeMin((long) value); return true;
+ case "logMiningScnGapDetectionTimeIntervalMaxMs": getOrCreateConfiguration((DebeziumOracleComponent) component).setLogMiningScnGapDetectionTimeIntervalMaxMs((long) value); return true;
+ case "logMiningSleepTimeDefaultMs": getOrCreateConfiguration((DebeziumOracleComponent) component).setLogMiningSleepTimeDefaultMs((long) value); return true;
+ case "logMiningSleepTimeIncrementMs": getOrCreateConfiguration((DebeziumOracleComponent) component).setLogMiningSleepTimeIncrementMs((long) value); return true;
+ case "logMiningSleepTimeMaxMs": getOrCreateConfiguration((DebeziumOracleComponent) component).setLogMiningSleepTimeMaxMs((long) value); return true;
+ case "logMiningSleepTimeMinMs": getOrCreateConfiguration((DebeziumOracleComponent) component).setLogMiningSleepTimeMinMs((long) value); return true;
+ case "logMiningStrategy": getOrCreateConfiguration((DebeziumOracleComponent) component).setLogMiningStrategy((java.lang.String) value); return true;
+ case "logMiningTransactionRetentionHours": getOrCreateConfiguration((DebeziumOracleComponent) component).setLogMiningTransactionRetentionHours((long) value); return true;
+ case "logMiningUsernameExcludeList": getOrCreateConfiguration((DebeziumOracleComponent) component).setLogMiningUsernameExcludeList((java.lang.String) value); return true;
+ case "maxBatchSize": getOrCreateConfiguration((DebeziumOracleComponent) component).setMaxBatchSize((int) value); return true;
+ case "maxQueueSize": getOrCreateConfiguration((DebeziumOracleComponent) component).setMaxQueueSize((int) value); return true;
+ case "maxQueueSizeInBytes": getOrCreateConfiguration((DebeziumOracleComponent) component).setMaxQueueSizeInBytes((long) value); return true;
+ case "messageKeyColumns": getOrCreateConfiguration((DebeziumOracleComponent) component).setMessageKeyColumns((java.lang.String) value); return true;
+ case "pollIntervalMs": getOrCreateConfiguration((DebeziumOracleComponent) component).setPollIntervalMs((long) value); return true;
+ case "provideTransactionMetadata": getOrCreateConfiguration((DebeziumOracleComponent) component).setProvideTransactionMetadata((boolean) value); return true;
+ 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 "signalDataCollection": getOrCreateConfiguration((DebeziumOracleComponent) component).setSignalDataCollection((java.lang.String) value); return true;
+ case "skippedOperations": getOrCreateConfiguration((DebeziumOracleComponent) component).setSkippedOperations((java.lang.String) value); return true;
+ case "snapshotDelayMs": getOrCreateConfiguration((DebeziumOracleComponent) component).setSnapshotDelayMs((long) value); return true;
+ case "snapshotEnhancePredicateScn": getOrCreateConfiguration((DebeziumOracleComponent) component).setSnapshotEnhancePredicateScn((java.lang.String) value); return true;
+ case "snapshotFetchSize": getOrCreateConfiguration((DebeziumOracleComponent) component).setSnapshotFetchSize((int) value); return true;
+ case "snapshotIncludeCollectionList": getOrCreateConfiguration((DebeziumOracleComponent) component).setSnapshotIncludeCollectionList((java.lang.String) value); return true;
+ case "snapshotLockingMode": getOrCreateConfiguration((DebeziumOracleComponent) component).setSnapshotLockingMode((java.lang.String) value); return true;
+ case "snapshotLockTimeoutMs": getOrCreateConfiguration((DebeziumOracleComponent) component).setSnapshotLockTimeoutMs((long) value); return true;
+ 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 "sourceStructVersion": getOrCreateConfiguration((DebeziumOracleComponent) component).setSourceStructVersion((java.lang.String) value); return true;
+ case "tableBlacklist": getOrCreateConfiguration((DebeziumOracleComponent) component).setTableBlacklist((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 "tableWhitelist": getOrCreateConfiguration((DebeziumOracleComponent) component).setTableWhitelist((java.lang.String) value); return true;
+ case "timePrecisionMode": getOrCreateConfiguration((DebeziumOracleComponent) component).setTimePrecisionMode((java.lang.String) value); return true;
+ case "tombstonesOnDelete": getOrCreateConfiguration((DebeziumOracleComponent) component).setTombstonesOnDelete((boolean) value); return true;
+ case "transactionTopic": getOrCreateConfiguration((DebeziumOracleComponent) component).setTransactionTopic((java.lang.String) value); return true;
+ case "unavailableValuePlaceholder": getOrCreateConfiguration((DebeziumOracleComponent) component).setUnavailableValuePlaceholder((java.lang.String) value); return true;
+ default: return false;
+ }
+ }
+ }
+}
\ No newline at end of file
diff --git a/dsl/camel-componentdsl/src/generated/resources/metadata.json b/dsl/camel-componentdsl/src/generated/resources/metadata.json
index 341b6b31bad..434741d958e 100644
--- a/dsl/camel-componentdsl/src/generated/resources/metadata.json
+++ b/dsl/camel-componentdsl/src/generated/resources/metadata.json
@@ -1685,6 +1685,28 @@
"producerOnly": false,
"lenientProperties": false
},
+ "DebeziumOracleComponentBuilderFactory": {
+ "kind": "component",
+ "name": "debezium-oracle",
+ "title": "Debezium Oracle Connector",
+ "description": "Capture changes from a Oracle database.",
+ "deprecated": false,
+ "firstVersion": "3.17.0",
+ "label": "database,sql",
+ "javaType": "org.apache.camel.component.debezium.DebeziumOracleComponent",
+ "supportLevel": "Preview",
+ "groupId": "org.apache.camel",
+ "artifactId": "camel-debezium-oracle",
+ "version": "3.17.0-SNAPSHOT",
+ "scheme": "debezium-oracle",
+ "extendsScheme": "",
+ "syntax": "debezium-oracle:name",
+ "async": false,
+ "api": false,
+ "consumerOnly": true,
+ "producerOnly": false,
+ "lenientProperties": false
+ },
"DebeziumPostgresComponentBuilderFactory": {
"kind": "component",
"name": "debezium-postgres",
diff --git a/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/EndpointBuilderFactory.java b/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/EndpointBuilderFactory.java
index 62da8767b25..12b3e590b90 100644
--- a/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/EndpointBuilderFactory.java
+++ b/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/EndpointBuilderFactory.java
@@ -81,6 +81,7 @@ public interface EndpointBuilderFactory
org.apache.camel.builder.endpoint.dsl.Ddb2StreamEndpointBuilderFactory.Ddb2StreamBuilders,
org.apache.camel.builder.endpoint.dsl.DebeziumMongodbEndpointBuilderFactory.DebeziumMongodbBuilders,
org.apache.camel.builder.endpoint.dsl.DebeziumMySqlEndpointBuilderFactory.DebeziumMySqlBuilders,
+ org.apache.camel.builder.endpoint.dsl.DebeziumOracleEndpointBuilderFactory.DebeziumOracleBuilders,
org.apache.camel.builder.endpoint.dsl.DebeziumPostgresEndpointBuilderFactory.DebeziumPostgresBuilders,
org.apache.camel.builder.endpoint.dsl.DebeziumSqlserverEndpointBuilderFactory.DebeziumSqlserverBuilders,
org.apache.camel.builder.endpoint.dsl.DigitalOceanEndpointBuilderFactory.DigitalOceanBuilders,
diff --git a/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/EndpointBuilders.java b/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/EndpointBuilders.java
index 53a0cbcfb7c..e4fb99bf548 100644
--- a/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/EndpointBuilders.java
+++ b/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/EndpointBuilders.java
@@ -78,6 +78,7 @@ public interface EndpointBuilders
org.apache.camel.builder.endpoint.dsl.Ddb2StreamEndpointBuilderFactory,
org.apache.camel.builder.endpoint.dsl.DebeziumMongodbEndpointBuilderFactory,
org.apache.camel.builder.endpoint.dsl.DebeziumMySqlEndpointBuilderFactory,
+ org.apache.camel.builder.endpoint.dsl.DebeziumOracleEndpointBuilderFactory,
org.apache.camel.builder.endpoint.dsl.DebeziumPostgresEndpointBuilderFactory,
org.apache.camel.builder.endpoint.dsl.DebeziumSqlserverEndpointBuilderFactory,
org.apache.camel.builder.endpoint.dsl.DigitalOceanEndpointBuilderFactory,
diff --git a/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/StaticEndpointBuilders.java b/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/StaticEndpointBuilders.java
index a360e2ab739..d7f522cc95c 100644
--- a/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/StaticEndpointBuilders.java
+++ b/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/StaticEndpointBuilders.java
@@ -3432,6 +3432,51 @@ public class StaticEndpointBuilders {
String path) {
return org.apache.camel.builder.endpoint.dsl.DebeziumMySqlEndpointBuilderFactory.endpointBuilder(componentName, path);
}
+ /**
+ * Debezium Oracle Connector (camel-debezium-oracle)
+ * Capture changes from a Oracle database.
+ *
+ * Category: database,sql
+ * Since: 3.17
+ * Maven coordinates: org.apache.camel:camel-debezium-oracle
+ *
+ * Syntax: <code>debezium-oracle:name</code>
+ *
+ * Path parameter: name (required)
+ * Unique name for the connector. Attempting to register again with the same
+ * name will fail.
+ *
+ * @param path name
+ * @return the dsl builder
+ */
+ public static org.apache.camel.builder.endpoint.dsl.DebeziumOracleEndpointBuilderFactory.DebeziumOracleEndpointBuilder debeziumOracle(
+ String path) {
+ return org.apache.camel.builder.endpoint.dsl.DebeziumOracleEndpointBuilderFactory.endpointBuilder("debezium-oracle", path);
+ }
+ /**
+ * Debezium Oracle Connector (camel-debezium-oracle)
+ * Capture changes from a Oracle database.
+ *
+ * Category: database,sql
+ * Since: 3.17
+ * Maven coordinates: org.apache.camel:camel-debezium-oracle
+ *
+ * Syntax: <code>debezium-oracle:name</code>
+ *
+ * Path parameter: name (required)
+ * Unique name for the connector. Attempting to register again with the same
+ * name will fail.
+ *
+ * @param componentName to use a custom component name for the endpoint
+ * instead of the default name
+ * @param path name
+ * @return the dsl builder
+ */
+ public static org.apache.camel.builder.endpoint.dsl.DebeziumOracleEndpointBuilderFactory.DebeziumOracleEndpointBuilder debeziumOracle(
+ String componentName,
+ String path) {
+ return org.apache.camel.builder.endpoint.dsl.DebeziumOracleEndpointBuilderFactory.endpointBuilder(componentName, path);
+ }
/**
* Debezium PostgresSQL Connector (camel-debezium-postgres)
* Capture changes from a PostgresSQL database.
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
new file mode 100644
index 00000000000..f43262b5f12
--- /dev/null
+++ b/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/DebeziumOracleEndpointBuilderFactory.java
@@ -0,0 +1,2738 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.camel.builder.endpoint.dsl;
+
+import java.util.*;
+import java.util.Map;
+import java.util.concurrent.*;
+import java.util.function.*;
+import java.util.stream.*;
+import javax.annotation.Generated;
+import org.apache.camel.builder.EndpointConsumerBuilder;
+import org.apache.camel.builder.EndpointProducerBuilder;
+import org.apache.camel.builder.endpoint.AbstractEndpointBuilder;
+
+/**
+ * Capture changes from a Oracle database.
+ *
+ * Generated by camel build tools - do NOT edit this file!
+ */
+@Generated("org.apache.camel.maven.packaging.EndpointDslMojo")
+public interface DebeziumOracleEndpointBuilderFactory {
+
+
+ /**
+ * Builder for endpoint for the Debezium Oracle Connector component.
+ */
+ public interface DebeziumOracleEndpointBuilder
+ extends
+ EndpointConsumerBuilder {
+ default AdvancedDebeziumOracleEndpointBuilder advanced() {
+ return (AdvancedDebeziumOracleEndpointBuilder) this;
+ }
+ /**
+ * Additional properties for debezium components in case they can't be
+ * set directly on the camel configurations (e.g: setting Kafka Connect
+ * properties needed by Debezium engine, for example setting
+ * KafkaOffsetBackingStore), the properties have to be prefixed with
+ * additionalProperties.. E.g:
+ * additionalProperties.transactional.id=12345&amp;additionalProperties.schema.registry.url=http://localhost:8811/avro.
+ *
+ * The option is a: <code>java.util.Map&lt;java.lang.String,
+ * java.lang.Object&gt;</code> type.
+ * The option is multivalued, and you can use the
+ * additionalProperties(String, Object) method to add a value (call the
+ * method multiple times to set more values).
+ *
+ * Group: common
+ *
+ * @param key the option key
+ * @param value the option value
+ * @return the dsl builder
+ */
+ default DebeziumOracleEndpointBuilder additionalProperties(
+ String key,
+ Object value) {
+ doSetMultiValueProperty("additionalProperties", "additionalProperties." + key, value);
+ return this;
+ }
+ /**
+ * Additional properties for debezium components in case they can't be
+ * set directly on the camel configurations (e.g: setting Kafka Connect
+ * properties needed by Debezium engine, for example setting
+ * KafkaOffsetBackingStore), the properties have to be prefixed with
+ * additionalProperties.. E.g:
+ * additionalProperties.transactional.id=12345&amp;additionalProperties.schema.registry.url=http://localhost:8811/avro.
+ *
+ * The option is a: <code>java.util.Map&lt;java.lang.String,
+ * java.lang.Object&gt;</code> type.
+ * The option is multivalued, and you can use the
+ * additionalProperties(String, Object) method to add a value (call the
+ * method multiple times to set more values).
+ *
+ * Group: common
+ *
+ * @param values the values
+ * @return the dsl builder
+ */
+ default DebeziumOracleEndpointBuilder additionalProperties(Map values) {
+ doSetMultiValueProperties("additionalProperties", "additionalProperties.", values);
+ return this;
+ }
+ /**
+ * Allows for bridging the consumer to the Camel routing Error Handler,
+ * which mean any exceptions occurred while the consumer is trying to
+ * pickup incoming messages, or the likes, will now be processed as a
+ * message and handled by the routing Error Handler. By default the
+ * consumer will use the org.apache.camel.spi.ExceptionHandler to deal
+ * with exceptions, that will be logged at WARN or ERROR level and
+ * ignored.
+ *
+ * The option is a: <code>boolean</code> type.
+ *
+ * Default: false
+ * Group: consumer
+ *
+ * @param bridgeErrorHandler the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleEndpointBuilder bridgeErrorHandler(
+ boolean bridgeErrorHandler) {
+ doSetProperty("bridgeErrorHandler", bridgeErrorHandler);
+ return this;
+ }
+ /**
+ * Allows for bridging the consumer to the Camel routing Error Handler,
+ * which mean any exceptions occurred while the consumer is trying to
+ * pickup incoming messages, or the likes, will now be processed as a
+ * message and handled by the routing Error Handler. By default the
+ * consumer will use the org.apache.camel.spi.ExceptionHandler to deal
+ * with exceptions, that will be logged at WARN or ERROR level and
+ * ignored.
+ *
+ * The option will be converted to a <code>boolean</code>
+ * type.
+ *
+ * Default: false
+ * Group: consumer
+ *
+ * @param bridgeErrorHandler the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleEndpointBuilder bridgeErrorHandler(
+ String bridgeErrorHandler) {
+ doSetProperty("bridgeErrorHandler", bridgeErrorHandler);
+ return this;
+ }
+ /**
+ * The Converter class that should be used to serialize and deserialize
+ * key data for offsets. The default is JSON converter.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Default: org.apache.kafka.connect.json.JsonConverter
+ * Group: consumer
+ *
+ * @param internalKeyConverter the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleEndpointBuilder internalKeyConverter(
+ String internalKeyConverter) {
+ doSetProperty("internalKeyConverter", internalKeyConverter);
+ return this;
+ }
+ /**
+ * The Converter class that should be used to serialize and deserialize
+ * value data for offsets. The default is JSON converter.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Default: org.apache.kafka.connect.json.JsonConverter
+ * Group: consumer
+ *
+ * @param internalValueConverter the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleEndpointBuilder internalValueConverter(
+ String internalValueConverter) {
+ doSetProperty("internalValueConverter", internalValueConverter);
+ return this;
+ }
+ /**
+ * The name of the Java class of the commit policy. It defines when
+ * offsets commit has to be triggered based on the number of events
+ * processed and the time elapsed since the last commit. This class must
+ * implement the interface 'OffsetCommitPolicy'. The default is a
+ * periodic commit policy based upon time intervals.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Default:
+ * io.debezium.embedded.spi.OffsetCommitPolicy.PeriodicCommitOffsetPolicy
+ * Group: consumer
+ *
+ * @param offsetCommitPolicy the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleEndpointBuilder offsetCommitPolicy(
+ String offsetCommitPolicy) {
+ doSetProperty("offsetCommitPolicy", offsetCommitPolicy);
+ return this;
+ }
+ /**
+ * Maximum number of milliseconds to wait for records to flush and
+ * partition offset data to be committed to offset storage before
+ * cancelling the process and restoring the offset data to be committed
+ * in a future attempt. The default is 5 seconds.
+ *
+ * The option is a: <code>long</code> type.
+ *
+ * Default: 5000
+ * Group: consumer
+ *
+ * @param offsetCommitTimeoutMs the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleEndpointBuilder offsetCommitTimeoutMs(
+ long offsetCommitTimeoutMs) {
+ doSetProperty("offsetCommitTimeoutMs", offsetCommitTimeoutMs);
+ return this;
+ }
+ /**
+ * Maximum number of milliseconds to wait for records to flush and
+ * partition offset data to be committed to offset storage before
+ * cancelling the process and restoring the offset data to be committed
+ * in a future attempt. The default is 5 seconds.
+ *
+ * The option will be converted to a <code>long</code> type.
+ *
+ * Default: 5000
+ * Group: consumer
+ *
+ * @param offsetCommitTimeoutMs the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleEndpointBuilder offsetCommitTimeoutMs(
+ String offsetCommitTimeoutMs) {
+ doSetProperty("offsetCommitTimeoutMs", offsetCommitTimeoutMs);
+ return this;
+ }
+ /**
+ * Interval at which to try committing offsets. The default is 1 minute.
+ *
+ * The option is a: <code>long</code> type.
+ *
+ * Default: 60000
+ * Group: consumer
+ *
+ * @param offsetFlushIntervalMs the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleEndpointBuilder offsetFlushIntervalMs(
+ long offsetFlushIntervalMs) {
+ doSetProperty("offsetFlushIntervalMs", offsetFlushIntervalMs);
+ return this;
+ }
+ /**
+ * Interval at which to try committing offsets. The default is 1 minute.
+ *
+ * The option will be converted to a <code>long</code> type.
+ *
+ * Default: 60000
+ * Group: consumer
+ *
+ * @param offsetFlushIntervalMs the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleEndpointBuilder offsetFlushIntervalMs(
+ String offsetFlushIntervalMs) {
+ doSetProperty("offsetFlushIntervalMs", offsetFlushIntervalMs);
+ return this;
+ }
+ /**
+ * The name of the Java class that is responsible for persistence of
+ * connector offsets.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Default: org.apache.kafka.connect.storage.FileOffsetBackingStore
+ * Group: consumer
+ *
+ * @param offsetStorage the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleEndpointBuilder offsetStorage(String offsetStorage) {
+ doSetProperty("offsetStorage", offsetStorage);
+ return this;
+ }
+ /**
+ * Path to file where offsets are to be stored. Required when
+ * offset.storage is set to the FileOffsetBackingStore.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: consumer
+ *
+ * @param offsetStorageFileName the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleEndpointBuilder offsetStorageFileName(
+ String offsetStorageFileName) {
+ doSetProperty("offsetStorageFileName", offsetStorageFileName);
+ return this;
+ }
+ /**
+ * The number of partitions used when creating the offset storage topic.
+ * Required when offset.storage is set to the 'KafkaOffsetBackingStore'.
+ *
+ * The option is a: <code>int</code> type.
+ *
+ * Group: consumer
+ *
+ * @param offsetStoragePartitions the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleEndpointBuilder offsetStoragePartitions(
+ int offsetStoragePartitions) {
+ doSetProperty("offsetStoragePartitions", offsetStoragePartitions);
+ return this;
+ }
+ /**
+ * The number of partitions used when creating the offset storage topic.
+ * Required when offset.storage is set to the 'KafkaOffsetBackingStore'.
+ *
+ * The option will be converted to a <code>int</code> type.
+ *
+ * Group: consumer
+ *
+ * @param offsetStoragePartitions the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleEndpointBuilder offsetStoragePartitions(
+ String offsetStoragePartitions) {
+ doSetProperty("offsetStoragePartitions", offsetStoragePartitions);
+ return this;
+ }
+ /**
+ * Replication factor used when creating the offset storage topic.
+ * Required when offset.storage is set to the KafkaOffsetBackingStore.
+ *
+ * The option is a: <code>int</code> type.
+ *
+ * Group: consumer
+ *
+ * @param offsetStorageReplicationFactor the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleEndpointBuilder offsetStorageReplicationFactor(
+ int offsetStorageReplicationFactor) {
+ doSetProperty("offsetStorageReplicationFactor", offsetStorageReplicationFactor);
+ return this;
+ }
+ /**
+ * Replication factor used when creating the offset storage topic.
+ * Required when offset.storage is set to the KafkaOffsetBackingStore.
+ *
+ * The option will be converted to a <code>int</code> type.
+ *
+ * Group: consumer
+ *
+ * @param offsetStorageReplicationFactor the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleEndpointBuilder offsetStorageReplicationFactor(
+ String offsetStorageReplicationFactor) {
+ doSetProperty("offsetStorageReplicationFactor", offsetStorageReplicationFactor);
+ return this;
+ }
+ /**
+ * The name of the Kafka topic where offsets are to be stored. Required
+ * when offset.storage is set to the KafkaOffsetBackingStore.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: consumer
+ *
+ * @param offsetStorageTopic the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleEndpointBuilder offsetStorageTopic(
+ String offsetStorageTopic) {
+ doSetProperty("offsetStorageTopic", offsetStorageTopic);
+ return this;
+ }
+ /**
+ * Specify how binary (blob, binary, etc.) columns should be represented
+ * in change events, including:'bytes' represents binary data as byte
+ * array (default)'base64' represents binary data as base64-encoded
+ * string'hex' represents binary data as hex-encoded (base16) string.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Default: bytes
+ * Group: oracle
+ *
+ * @param binaryHandlingMode the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleEndpointBuilder binaryHandlingMode(
+ String binaryHandlingMode) {
+ doSetProperty("binaryHandlingMode", binaryHandlingMode);
+ return this;
+ }
+ /**
+ * Regular expressions matching columns to exclude from change events
+ * (deprecated, use column.exclude.list instead).
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: oracle
+ *
+ * @param columnBlacklist the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleEndpointBuilder columnBlacklist(
+ String columnBlacklist) {
+ doSetProperty("columnBlacklist", columnBlacklist);
+ return this;
+ }
+ /**
+ * Regular expressions matching columns to exclude from change events.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: oracle
+ *
+ * @param columnExcludeList the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleEndpointBuilder columnExcludeList(
+ String columnExcludeList) {
+ doSetProperty("columnExcludeList", columnExcludeList);
+ return this;
+ }
+ /**
+ * Regular expressions matching columns to include in change events.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: oracle
+ *
+ * @param columnIncludeList the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleEndpointBuilder columnIncludeList(
+ String columnIncludeList) {
+ doSetProperty("columnIncludeList", columnIncludeList);
+ return this;
+ }
+ /**
+ * A comma-separated list of regular expressions matching
+ * fully-qualified names of columns that adds the columns original type
+ * and original length as parameters to the corresponding field schemas
+ * in the emitted change records.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: oracle
+ *
+ * @param columnPropagateSourceType the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleEndpointBuilder columnPropagateSourceType(
+ String columnPropagateSourceType) {
+ doSetProperty("columnPropagateSourceType", columnPropagateSourceType);
+ return this;
+ }
+ /**
+ * Regular expressions matching columns to include in change events
+ * (deprecated, use column.include.list instead).
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: oracle
+ *
+ * @param columnWhitelist the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleEndpointBuilder columnWhitelist(
+ String columnWhitelist) {
+ doSetProperty("columnWhitelist", columnWhitelist);
+ return this;
+ }
+ /**
+ * Optional list of custom converters that would be used instead of
+ * default ones. The converters are defined using '.type' config option
+ * and configured using options '.'.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: oracle
+ *
+ * @param converters the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleEndpointBuilder converters(String converters) {
+ doSetProperty("converters", converters);
+ return this;
+ }
+ /**
+ * The adapter to use when capturing changes from the database. Options
+ * include: 'logminer': (the default) to capture changes using native
+ * Oracle LogMiner; 'xstream' to capture changes using Oracle XStreams.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Default: LogMiner
+ * Group: oracle
+ *
+ * @param databaseConnectionAdapter the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleEndpointBuilder databaseConnectionAdapter(
+ String databaseConnectionAdapter) {
+ doSetProperty("databaseConnectionAdapter", databaseConnectionAdapter);
+ return this;
+ }
+ /**
+ * The name of the database from which the connector should capture
+ * changes.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: oracle
+ *
+ * @param databaseDbname the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleEndpointBuilder databaseDbname(
+ String databaseDbname) {
+ doSetProperty("databaseDbname", databaseDbname);
+ return this;
+ }
+ /**
+ * The name of the DatabaseHistory class that should be used to store
+ * and recover database schema changes. The configuration properties for
+ * the history are prefixed with the 'database.history.' string.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Default: class io.debezium.relational.history.KafkaDatabaseHistory
+ * Group: oracle
+ *
+ * @param databaseHistory the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleEndpointBuilder databaseHistory(
+ String databaseHistory) {
+ doSetProperty("databaseHistory", databaseHistory);
+ return this;
+ }
+ /**
+ * The path to the file that will be used to record the database
+ * history.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: oracle
+ *
+ * @param databaseHistoryFileFilename the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleEndpointBuilder databaseHistoryFileFilename(
+ String databaseHistoryFileFilename) {
+ doSetProperty("databaseHistoryFileFilename", databaseHistoryFileFilename);
+ return this;
+ }
+ /**
+ * A list of host/port pairs that the connector will use for
+ * establishing the initial connection to the Kafka cluster for
+ * retrieving database schema history previously stored by the
+ * connector. This should point to the same Kafka cluster used by the
+ * Kafka Connect process.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: oracle
+ *
+ * @param databaseHistoryKafkaBootstrapServers the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleEndpointBuilder databaseHistoryKafkaBootstrapServers(
+ String databaseHistoryKafkaBootstrapServers) {
+ doSetProperty("databaseHistoryKafkaBootstrapServers", databaseHistoryKafkaBootstrapServers);
+ return this;
+ }
+ /**
+ * The number of attempts in a row that no data are returned from Kafka
+ * before recover completes. The maximum amount of time to wait after
+ * receiving no data is (recovery.attempts) x
+ * (recovery.poll.interval.ms).
+ *
+ * The option is a: <code>int</code> type.
+ *
+ * Default: 100
+ * Group: oracle
+ *
+ * @param databaseHistoryKafkaRecoveryAttempts the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleEndpointBuilder databaseHistoryKafkaRecoveryAttempts(
+ int databaseHistoryKafkaRecoveryAttempts) {
+ doSetProperty("databaseHistoryKafkaRecoveryAttempts", databaseHistoryKafkaRecoveryAttempts);
+ return this;
+ }
+ /**
+ * The number of attempts in a row that no data are returned from Kafka
+ * before recover completes. The maximum amount of time to wait after
+ * receiving no data is (recovery.attempts) x
+ * (recovery.poll.interval.ms).
+ *
+ * The option will be converted to a <code>int</code> type.
+ *
+ * Default: 100
+ * Group: oracle
+ *
+ * @param databaseHistoryKafkaRecoveryAttempts the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleEndpointBuilder databaseHistoryKafkaRecoveryAttempts(
+ String databaseHistoryKafkaRecoveryAttempts) {
+ doSetProperty("databaseHistoryKafkaRecoveryAttempts", databaseHistoryKafkaRecoveryAttempts);
+ return this;
+ }
+ /**
+ * The number of milliseconds to wait while polling for persisted data
+ * during recovery.
+ *
+ * The option is a: <code>int</code> type.
+ *
+ * Default: 100ms
+ * Group: oracle
+ *
+ * @param databaseHistoryKafkaRecoveryPollIntervalMs the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleEndpointBuilder databaseHistoryKafkaRecoveryPollIntervalMs(
+ int databaseHistoryKafkaRecoveryPollIntervalMs) {
+ doSetProperty("databaseHistoryKafkaRecoveryPollIntervalMs", databaseHistoryKafkaRecoveryPollIntervalMs);
+ return this;
+ }
+ /**
+ * The number of milliseconds to wait while polling for persisted data
+ * during recovery.
+ *
+ * The option will be converted to a <code>int</code> type.
+ *
+ * Default: 100ms
+ * Group: oracle
+ *
+ * @param databaseHistoryKafkaRecoveryPollIntervalMs the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleEndpointBuilder databaseHistoryKafkaRecoveryPollIntervalMs(
+ String databaseHistoryKafkaRecoveryPollIntervalMs) {
+ doSetProperty("databaseHistoryKafkaRecoveryPollIntervalMs", databaseHistoryKafkaRecoveryPollIntervalMs);
+ return this;
+ }
+ /**
+ * The name of the topic for the database schema history.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: oracle
+ *
+ * @param databaseHistoryKafkaTopic the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleEndpointBuilder databaseHistoryKafkaTopic(
+ String databaseHistoryKafkaTopic) {
+ doSetProperty("databaseHistoryKafkaTopic", databaseHistoryKafkaTopic);
+ return this;
+ }
+ /**
+ * Controls the action Debezium will take when it meets a DDL statement
+ * in binlog, that it cannot parse.By default the connector will stop
+ * operating but by changing the setting it can ignore the statements
+ * which it cannot parse. If skipping is enabled then Debezium can miss
+ * metadata changes.
+ *
+ * The option is a: <code>boolean</code> type.
+ *
+ * Default: false
+ * Group: oracle
+ *
+ * @param databaseHistorySkipUnparseableDdl the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleEndpointBuilder databaseHistorySkipUnparseableDdl(
+ boolean databaseHistorySkipUnparseableDdl) {
+ doSetProperty("databaseHistorySkipUnparseableDdl", databaseHistorySkipUnparseableDdl);
+ return this;
+ }
+ /**
+ * Controls the action Debezium will take when it meets a DDL statement
+ * in binlog, that it cannot parse.By default the connector will stop
+ * operating but by changing the setting it can ignore the statements
+ * which it cannot parse. If skipping is enabled then Debezium can miss
+ * metadata changes.
+ *
+ * The option will be converted to a <code>boolean</code>
+ * type.
+ *
+ * Default: false
+ * Group: oracle
+ *
+ * @param databaseHistorySkipUnparseableDdl the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleEndpointBuilder databaseHistorySkipUnparseableDdl(
+ String databaseHistorySkipUnparseableDdl) {
+ doSetProperty("databaseHistorySkipUnparseableDdl", databaseHistorySkipUnparseableDdl);
+ return this;
+ }
+ /**
+ * Controls what DDL will Debezium store in database history. By default
+ * (false) Debezium will store all incoming DDL statements. If set to
+ * true, then only DDL that manipulates a captured table will be stored.
+ *
+ * The option is a: <code>boolean</code> type.
+ *
+ * Default: false
+ * Group: oracle
+ *
+ * @param databaseHistoryStoreOnlyCapturedTablesDdl the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleEndpointBuilder databaseHistoryStoreOnlyCapturedTablesDdl(
+ boolean databaseHistoryStoreOnlyCapturedTablesDdl) {
+ doSetProperty("databaseHistoryStoreOnlyCapturedTablesDdl", databaseHistoryStoreOnlyCapturedTablesDdl);
+ return this;
+ }
+ /**
+ * Controls what DDL will Debezium store in database history. By default
+ * (false) Debezium will store all incoming DDL statements. If set to
+ * true, then only DDL that manipulates a captured table will be stored.
+ *
+ * The option will be converted to a <code>boolean</code>
+ * type.
+ *
+ * Default: false
+ * Group: oracle
+ *
+ * @param databaseHistoryStoreOnlyCapturedTablesDdl the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleEndpointBuilder databaseHistoryStoreOnlyCapturedTablesDdl(
+ String databaseHistoryStoreOnlyCapturedTablesDdl) {
+ doSetProperty("databaseHistoryStoreOnlyCapturedTablesDdl", databaseHistoryStoreOnlyCapturedTablesDdl);
+ return this;
+ }
+ /**
+ * Controls what DDL will Debezium store in database history. By default
+ * (false) Debezium will store all incoming DDL statements. If set to
+ * true, then only DDL that manipulates a monitored table will be stored
+ * (deprecated, use database.history.store.only.captured.tables.ddl
+ * instead).
+ *
+ * The option is a: <code>boolean</code> type.
+ *
+ * Default: false
+ * Group: oracle
+ *
+ * @param databaseHistoryStoreOnlyMonitoredTablesDdl the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleEndpointBuilder databaseHistoryStoreOnlyMonitoredTablesDdl(
+ boolean databaseHistoryStoreOnlyMonitoredTablesDdl) {
+ doSetProperty("databaseHistoryStoreOnlyMonitoredTablesDdl", databaseHistoryStoreOnlyMonitoredTablesDdl);
+ return this;
+ }
+ /**
+ * Controls what DDL will Debezium store in database history. By default
+ * (false) Debezium will store all incoming DDL statements. If set to
+ * true, then only DDL that manipulates a monitored table will be stored
+ * (deprecated, use database.history.store.only.captured.tables.ddl
+ * instead).
+ *
+ * The option will be converted to a <code>boolean</code>
+ * type.
+ *
+ * Default: false
+ * Group: oracle
+ *
+ * @param databaseHistoryStoreOnlyMonitoredTablesDdl the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleEndpointBuilder databaseHistoryStoreOnlyMonitoredTablesDdl(
+ String databaseHistoryStoreOnlyMonitoredTablesDdl) {
+ doSetProperty("databaseHistoryStoreOnlyMonitoredTablesDdl", databaseHistoryStoreOnlyMonitoredTablesDdl);
+ return this;
+ }
+ /**
+ * Resolvable hostname or IP address of the database server.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: oracle
+ *
+ * @param databaseHostname the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleEndpointBuilder databaseHostname(
+ String databaseHostname) {
+ doSetProperty("databaseHostname", databaseHostname);
+ return this;
+ }
+ /**
+ * Name of the XStream Out server to connect to.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: oracle
+ *
+ * @param databaseOutServerName the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleEndpointBuilder databaseOutServerName(
+ String databaseOutServerName) {
+ doSetProperty("databaseOutServerName", databaseOutServerName);
+ return this;
+ }
+ /**
+ * Password of the database user to be used when connecting to the
+ * database.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Required: true
+ * Group: oracle
+ *
+ * @param databasePassword the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleEndpointBuilder databasePassword(
+ String databasePassword) {
+ doSetProperty("databasePassword", databasePassword);
+ return this;
+ }
+ /**
+ * Name of the pluggable database when working with a multi-tenant
+ * set-up. The CDB name must be given via database.dbname in this case.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: oracle
+ *
+ * @param databasePdbName the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleEndpointBuilder databasePdbName(
+ String databasePdbName) {
+ doSetProperty("databasePdbName", databasePdbName);
+ return this;
+ }
+ /**
+ * Port of the database server.
+ *
+ * The option is a: <code>int</code> type.
+ *
+ * Default: 1528
+ * Group: oracle
+ *
+ * @param databasePort the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleEndpointBuilder databasePort(int databasePort) {
+ doSetProperty("databasePort", databasePort);
+ return this;
+ }
+ /**
+ * Port of the database server.
+ *
+ * The option will be converted to a <code>int</code> type.
+ *
+ * Default: 1528
+ * Group: oracle
+ *
+ * @param databasePort the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleEndpointBuilder databasePort(String databasePort) {
+ doSetProperty("databasePort", databasePort);
+ return this;
+ }
+ /**
+ * Unique name that identifies the database server and all recorded
+ * offsets, and that is used as a prefix for all schemas and topics.
+ * Each distinct installation should have a separate namespace and be
+ * monitored by at most one Debezium connector.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Required: true
+ * Group: oracle
+ *
+ * @param databaseServerName the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleEndpointBuilder databaseServerName(
+ String databaseServerName) {
+ doSetProperty("databaseServerName", databaseServerName);
+ return this;
+ }
+ /**
+ * Complete JDBC URL as an alternative to specifying hostname, port and
+ * database provided as a way to support alternative connection
+ * scenarios.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: oracle
+ *
+ * @param databaseUrl the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleEndpointBuilder databaseUrl(String databaseUrl) {
+ doSetProperty("databaseUrl", databaseUrl);
+ return this;
+ }
+ /**
+ * Name of the database user to be used when connecting to the database.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: oracle
+ *
+ * @param databaseUser the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleEndpointBuilder databaseUser(String databaseUser) {
+ doSetProperty("databaseUser", databaseUser);
+ return this;
+ }
+ /**
+ * A comma-separated list of regular expressions matching the
+ * database-specific data type names that adds the data type's original
+ * type and original length as parameters to the corresponding field
+ * schemas in the emitted change records.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: oracle
+ *
+ * @param datatypePropagateSourceType the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleEndpointBuilder datatypePropagateSourceType(
+ String datatypePropagateSourceType) {
+ doSetProperty("datatypePropagateSourceType", datatypePropagateSourceType);
+ return this;
+ }
+ /**
+ * Specify how DECIMAL and NUMERIC columns should be represented in
+ * change events, including:'precise' (the default) uses
+ * java.math.BigDecimal to represent values, which are encoded in the
+ * change events using a binary representation and Kafka Connect's
+ * 'org.apache.kafka.connect.data.Decimal' type; 'string' uses string to
+ * represent values; 'double' represents values using Java's 'double',
+ * which may not offer the precision but will be far easier to use in
+ * consumers.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Default: precise
+ * Group: oracle
+ *
+ * @param decimalHandlingMode the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleEndpointBuilder decimalHandlingMode(
+ String decimalHandlingMode) {
+ doSetProperty("decimalHandlingMode", decimalHandlingMode);
+ return this;
+ }
+ /**
+ * Specify how failures during processing of events (i.e. when
+ * encountering a corrupted event) should be handled, including:'fail'
+ * (the default) an exception indicating the problematic event and its
+ * position is raised, causing the connector to be stopped; 'warn' the
+ * problematic event and its position will be logged and the event will
+ * be skipped;'ignore' the problematic event will be skipped.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Default: fail
+ * Group: oracle
+ *
+ * @param eventProcessingFailureHandlingMode the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleEndpointBuilder eventProcessingFailureHandlingMode(
+ String eventProcessingFailureHandlingMode) {
+ doSetProperty("eventProcessingFailureHandlingMode", eventProcessingFailureHandlingMode);
+ return this;
+ }
+ /**
+ * The query executed with every heartbeat.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: oracle
+ *
+ * @param heartbeatActionQuery the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleEndpointBuilder heartbeatActionQuery(
+ String heartbeatActionQuery) {
+ doSetProperty("heartbeatActionQuery", heartbeatActionQuery);
+ return this;
+ }
+ /**
+ * Length of an interval in milli-seconds in in which the connector
+ * periodically sends heartbeat messages to a heartbeat topic. Use 0 to
+ * disable heartbeat messages. Disabled by default.
+ *
+ * The option is a: <code>int</code> type.
+ *
+ * Default: 0ms
+ * Group: oracle
+ *
+ * @param heartbeatIntervalMs the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleEndpointBuilder heartbeatIntervalMs(
+ int heartbeatIntervalMs) {
+ doSetProperty("heartbeatIntervalMs", heartbeatIntervalMs);
+ return this;
+ }
+ /**
+ * Length of an interval in milli-seconds in in which the connector
+ * periodically sends heartbeat messages to a heartbeat topic. Use 0 to
+ * disable heartbeat messages. Disabled by default.
+ *
+ * The option will be converted to a <code>int</code> type.
+ *
+ * Default: 0ms
+ * Group: oracle
+ *
+ * @param heartbeatIntervalMs the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleEndpointBuilder heartbeatIntervalMs(
+ String heartbeatIntervalMs) {
+ doSetProperty("heartbeatIntervalMs", heartbeatIntervalMs);
+ return this;
+ }
+ /**
+ * The prefix that is used to name heartbeat topics.Defaults to
+ * __debezium-heartbeat.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Default: __debezium-heartbeat
+ * Group: oracle
+ *
+ * @param heartbeatTopicsPrefix the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleEndpointBuilder heartbeatTopicsPrefix(
+ String heartbeatTopicsPrefix) {
+ doSetProperty("heartbeatTopicsPrefix", heartbeatTopicsPrefix);
+ return this;
+ }
+ /**
+ * Whether the connector should publish changes in the database schema
+ * to a Kafka topic with the same name as the database server ID. Each
+ * schema change will be recorded using a key that contains the database
+ * name and whose value include logical description of the new schema
+ * and optionally the DDL statement(s).The default is 'true'. This is
+ * independent of how the connector internally records database history.
+ *
+ * The option is a: <code>boolean</code> type.
+ *
+ * Default: true
+ * Group: oracle
+ *
+ * @param includeSchemaChanges the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleEndpointBuilder includeSchemaChanges(
+ boolean includeSchemaChanges) {
+ doSetProperty("includeSchemaChanges", includeSchemaChanges);
+ return this;
+ }
+ /**
+ * Whether the connector should publish changes in the database schema
+ * to a Kafka topic with the same name as the database server ID. Each
+ * schema change will be recorded using a key that contains the database
+ * name and whose value include logical description of the new schema
+ * and optionally the DDL statement(s).The default is 'true'. This is
+ * independent of how the connector internally records database history.
+ *
+ * The option will be converted to a <code>boolean</code>
+ * type.
+ *
+ * Default: true
+ * Group: oracle
+ *
+ * @param includeSchemaChanges the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleEndpointBuilder includeSchemaChanges(
+ String includeSchemaChanges) {
+ doSetProperty("includeSchemaChanges", includeSchemaChanges);
+ return this;
+ }
+ /**
+ * Whether the connector parse table and column's comment to metadata
+ * object.Note: Enable this option will bring the implications on memory
+ * usage. The number and size of ColumnImpl objects is what largely
+ * impacts how much memory is consumed by the Debezium connectors, and
+ * adding a String to each of them can potentially be quite heavy. The
+ * default is 'false'.
+ *
+ * The option is a: <code>boolean</code> type.
+ *
+ * Default: false
+ * Group: oracle
+ *
+ * @param includeSchemaComments the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleEndpointBuilder includeSchemaComments(
+ boolean includeSchemaComments) {
+ doSetProperty("includeSchemaComments", includeSchemaComments);
+ return this;
+ }
+ /**
+ * Whether the connector parse table and column's comment to metadata
+ * object.Note: Enable this option will bring the implications on memory
+ * usage. The number and size of ColumnImpl objects is what largely
+ * impacts how much memory is consumed by the Debezium connectors, and
+ * adding a String to each of them can potentially be quite heavy. The
+ * default is 'false'.
+ *
+ * The option will be converted to a <code>boolean</code>
+ * type.
+ *
+ * Default: false
+ * Group: oracle
+ *
+ * @param includeSchemaComments the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleEndpointBuilder includeSchemaComments(
+ String includeSchemaComments) {
+ doSetProperty("includeSchemaComments", includeSchemaComments);
+ return this;
+ }
+ /**
+ * Specify how INTERVAL columns should be represented in change events,
+ * including:'string' represents values as an exact ISO formatted
+ * string'numeric' (default) represents values using the inexact
+ * conversion into microseconds.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Default: numeric
+ * Group: oracle
+ *
+ * @param intervalHandlingMode the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleEndpointBuilder intervalHandlingMode(
+ String intervalHandlingMode) {
+ doSetProperty("intervalHandlingMode", intervalHandlingMode);
+ return this;
+ }
+ /**
+ * When set to false, the default, LOB fields will not be captured nor
+ * emitted. When set to true, the connector will capture LOB fields and
+ * emit changes for those fields like any other column type.
+ *
+ * The option is a: <code>boolean</code> type.
+ *
+ * Default: false
+ * Group: oracle
+ *
+ * @param lobEnabled the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleEndpointBuilder lobEnabled(boolean lobEnabled) {
+ doSetProperty("lobEnabled", lobEnabled);
+ return this;
+ }
+ /**
+ * When set to false, the default, LOB fields will not be captured nor
+ * emitted. When set to true, the connector will capture LOB fields and
+ * emit changes for those fields like any other column type.
+ *
+ * The option will be converted to a <code>boolean</code>
+ * type.
+ *
+ * Default: false
+ * Group: oracle
+ *
+ * @param lobEnabled the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleEndpointBuilder lobEnabled(String lobEnabled) {
+ doSetProperty("lobEnabled", lobEnabled);
+ return this;
+ }
+ /**
+ * Sets the specific archive log destination as the source for reading
+ * archive logs.When not set, the connector will automatically select
+ * the first LOCAL and VALID destination.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: oracle
+ *
+ * @param logMiningArchiveDestinationName the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleEndpointBuilder logMiningArchiveDestinationName(
+ String logMiningArchiveDestinationName) {
+ doSetProperty("logMiningArchiveDestinationName", logMiningArchiveDestinationName);
+ return this;
+ }
+ /**
+ * The number of hours in the past from SYSDATE to mine archive logs.
+ * Using 0 mines all available archive logs.
+ *
+ * The option is a: <code>long</code> type.
+ *
+ * Default: 0
+ * Group: oracle
+ *
+ * @param logMiningArchiveLogHours the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleEndpointBuilder logMiningArchiveLogHours(
+ long logMiningArchiveLogHours) {
+ doSetProperty("logMiningArchiveLogHours", logMiningArchiveLogHours);
+ return this;
+ }
+ /**
+ * The number of hours in the past from SYSDATE to mine archive logs.
+ * Using 0 mines all available archive logs.
+ *
+ * The option will be converted to a <code>long</code> type.
+ *
+ * Default: 0
+ * Group: oracle
+ *
+ * @param logMiningArchiveLogHours the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleEndpointBuilder logMiningArchiveLogHours(
+ String logMiningArchiveLogHours) {
+ doSetProperty("logMiningArchiveLogHours", logMiningArchiveLogHours);
+ return this;
+ }
+ /**
+ * When set to false, the default, the connector will mine both archive
+ * log and redo logs to emit change events. When set to true, the
+ * connector will only mine archive logs. There are circumstances where
+ * its advantageous to only mine archive logs and accept latency in
+ * event emission due to frequent revolving redo logs.
+ *
+ * The option is a: <code>boolean</code> type.
+ *
+ * Default: false
+ * Group: oracle
+ *
+ * @param logMiningArchiveLogOnlyMode the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleEndpointBuilder logMiningArchiveLogOnlyMode(
+ boolean logMiningArchiveLogOnlyMode) {
+ doSetProperty("logMiningArchiveLogOnlyMode", logMiningArchiveLogOnlyMode);
+ return this;
+ }
+ /**
+ * When set to false, the default, the connector will mine both archive
+ * log and redo logs to emit change events. When set to true, the
+ * connector will only mine archive logs. There are circumstances where
+ * its advantageous to only mine archive logs and accept latency in
+ * event emission due to frequent revolving redo logs.
+ *
+ * The option will be converted to a <code>boolean</code>
+ * type.
+ *
+ * Default: false
+ * Group: oracle
+ *
+ * @param logMiningArchiveLogOnlyMode the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleEndpointBuilder logMiningArchiveLogOnlyMode(
+ String logMiningArchiveLogOnlyMode) {
+ doSetProperty("logMiningArchiveLogOnlyMode", logMiningArchiveLogOnlyMode);
+ return this;
+ }
+ /**
+ * The interval in milliseconds to wait between polls checking to see if
+ * the SCN is in the archive logs.
+ *
+ * The option is a: <code>long</code> type.
+ *
+ * Default: 10s
+ * Group: oracle
+ *
+ * @param logMiningArchiveLogOnlyScnPollIntervalMs the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleEndpointBuilder logMiningArchiveLogOnlyScnPollIntervalMs(
+ long logMiningArchiveLogOnlyScnPollIntervalMs) {
+ doSetProperty("logMiningArchiveLogOnlyScnPollIntervalMs", logMiningArchiveLogOnlyScnPollIntervalMs);
+ return this;
+ }
+ /**
+ * The interval in milliseconds to wait between polls checking to see if
+ * the SCN is in the archive logs.
+ *
+ * The option will be converted to a <code>long</code> type.
+ *
+ * Default: 10s
+ * Group: oracle
+ *
+ * @param logMiningArchiveLogOnlyScnPollIntervalMs the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleEndpointBuilder logMiningArchiveLogOnlyScnPollIntervalMs(
+ String logMiningArchiveLogOnlyScnPollIntervalMs) {
+ doSetProperty("logMiningArchiveLogOnlyScnPollIntervalMs", logMiningArchiveLogOnlyScnPollIntervalMs);
+ return this;
+ }
+ /**
+ * The starting SCN interval size that the connector will use for
+ * reading data from redo/archive logs.
+ *
+ * The option is a: <code>long</code> type.
+ *
+ * Default: 20000
+ * Group: oracle
+ *
+ * @param logMiningBatchSizeDefault the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleEndpointBuilder logMiningBatchSizeDefault(
+ long logMiningBatchSizeDefault) {
+ doSetProperty("logMiningBatchSizeDefault", logMiningBatchSizeDefault);
+ return this;
+ }
+ /**
+ * The starting SCN interval size that the connector will use for
+ * reading data from redo/archive logs.
+ *
+ * The option will be converted to a <code>long</code> type.
+ *
+ * Default: 20000
+ * Group: oracle
+ *
+ * @param logMiningBatchSizeDefault the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleEndpointBuilder logMiningBatchSizeDefault(
+ String logMiningBatchSizeDefault) {
+ doSetProperty("logMiningBatchSizeDefault", logMiningBatchSizeDefault);
+ return this;
+ }
+ /**
+ * The maximum SCN interval size that this connector will use when
+ * reading from redo/archive logs.
+ *
+ * The option is a: <code>long</code> type.
+ *
+ * Default: 100000
+ * Group: oracle
+ *
+ * @param logMiningBatchSizeMax the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleEndpointBuilder logMiningBatchSizeMax(
+ long logMiningBatchSizeMax) {
+ doSetProperty("logMiningBatchSizeMax", logMiningBatchSizeMax);
+ return this;
+ }
+ /**
+ * The maximum SCN interval size that this connector will use when
+ * reading from redo/archive logs.
+ *
+ * The option will be converted to a <code>long</code> type.
+ *
+ * Default: 100000
+ * Group: oracle
+ *
+ * @param logMiningBatchSizeMax the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleEndpointBuilder logMiningBatchSizeMax(
+ String logMiningBatchSizeMax) {
+ doSetProperty("logMiningBatchSizeMax", logMiningBatchSizeMax);
+ return this;
+ }
+ /**
+ * The minimum SCN interval size that this connector will try to read
+ * from redo/archive logs. Active batch size will be also
+ * increased/decreased by this amount for tuning connector throughput
+ * when needed.
+ *
+ * The option is a: <code>long</code> type.
+ *
+ * Default: 1000
+ * Group: oracle
+ *
+ * @param logMiningBatchSizeMin the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleEndpointBuilder logMiningBatchSizeMin(
+ long logMiningBatchSizeMin) {
+ doSetProperty("logMiningBatchSizeMin", logMiningBatchSizeMin);
+ return this;
+ }
+ /**
+ * The minimum SCN interval size that this connector will try to read
+ * from redo/archive logs. Active batch size will be also
+ * increased/decreased by this amount for tuning connector throughput
+ * when needed.
+ *
+ * The option will be converted to a <code>long</code> type.
+ *
+ * Default: 1000
+ * Group: oracle
+ *
+ * @param logMiningBatchSizeMin the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleEndpointBuilder logMiningBatchSizeMin(
+ String logMiningBatchSizeMin) {
+ doSetProperty("logMiningBatchSizeMin", logMiningBatchSizeMin);
+ return this;
+ }
+ /**
+ * When set to true the underlying buffer cache is not retained when the
+ * connector is stopped. When set to false (the default), the buffer
+ * cache is retained across restarts.
+ *
+ * The option is a: <code>boolean</code> type.
+ *
+ * Default: false
+ * Group: oracle
+ *
+ * @param logMiningBufferDropOnStop the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleEndpointBuilder logMiningBufferDropOnStop(
+ boolean logMiningBufferDropOnStop) {
+ doSetProperty("logMiningBufferDropOnStop", logMiningBufferDropOnStop);
+ return this;
+ }
+ /**
+ * When set to true the underlying buffer cache is not retained when the
+ * connector is stopped. When set to false (the default), the buffer
+ * cache is retained across restarts.
+ *
+ * The option will be converted to a <code>boolean</code>
+ * type.
+ *
+ * Default: false
+ * Group: oracle
+ *
+ * @param logMiningBufferDropOnStop the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleEndpointBuilder logMiningBufferDropOnStop(
+ String logMiningBufferDropOnStop) {
+ doSetProperty("logMiningBufferDropOnStop", logMiningBufferDropOnStop);
+ return this;
+ }
+ /**
+ * Specifies the XML configuration for the Infinispan 'events' cache.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: oracle
+ *
+ * @param logMiningBufferInfinispanCacheEvents the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleEndpointBuilder logMiningBufferInfinispanCacheEvents(
+ String logMiningBufferInfinispanCacheEvents) {
+ doSetProperty("logMiningBufferInfinispanCacheEvents", logMiningBufferInfinispanCacheEvents);
+ return this;
+ }
+ /**
+ * Specifies the XML configuration for the Infinispan
+ * 'processed-transactions' cache.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: oracle
+ *
+ * @param logMiningBufferInfinispanCacheProcessedTransactions the value
+ * to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleEndpointBuilder logMiningBufferInfinispanCacheProcessedTransactions(
+ String logMiningBufferInfinispanCacheProcessedTransactions) {
+ doSetProperty("logMiningBufferInfinispanCacheProcessedTransactions", logMiningBufferInfinispanCacheProcessedTransactions);
+ return this;
+ }
+ /**
+ * Specifies the XML configuration for the Infinispan 'schema-changes'
+ * cache.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: oracle
+ *
+ * @param logMiningBufferInfinispanCacheSchemaChanges the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleEndpointBuilder logMiningBufferInfinispanCacheSchemaChanges(
+ String logMiningBufferInfinispanCacheSchemaChanges) {
+ doSetProperty("logMiningBufferInfinispanCacheSchemaChanges", logMiningBufferInfinispanCacheSchemaChanges);
+ return this;
+ }
+ /**
+ * Specifies the XML configuration for the Infinispan 'transactions'
+ * cache.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: oracle
+ *
+ * @param logMiningBufferInfinispanCacheTransactions the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleEndpointBuilder logMiningBufferInfinispanCacheTransactions(
+ String logMiningBufferInfinispanCacheTransactions) {
+ doSetProperty("logMiningBufferInfinispanCacheTransactions", logMiningBufferInfinispanCacheTransactions);
+ return this;
+ }
+ /**
+ * The buffer type controls how the connector manages buffering
+ * transaction data. memory - Uses the JVM process' heap to buffer all
+ * transaction data. infinispan_embedded - This option uses an embedded
+ * Infinispan cache to buffer transaction data and persist it to disk.
+ * infinispan_remote - This option uses a remote Infinispan cluster to
+ * buffer transaction data and persist it to disk.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Default: memory
+ * Group: oracle
+ *
+ * @param logMiningBufferType the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleEndpointBuilder logMiningBufferType(
+ String logMiningBufferType) {
+ doSetProperty("logMiningBufferType", logMiningBufferType);
+ return this;
+ }
+ /**
+ * Used for SCN gap detection, if the difference between current SCN and
+ * previous end SCN is bigger than this value, and the time difference
+ * of current SCN and previous end SCN is smaller than
+ * log.mining.scn.gap.detection.time.interval.max.ms, consider it a SCN
+ * gap.
+ *
+ * The option is a: <code>long</code> type.
+ *
+ * Default: 1000000
+ * Group: oracle
+ *
+ * @param logMiningScnGapDetectionGapSizeMin the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleEndpointBuilder logMiningScnGapDetectionGapSizeMin(
+ long logMiningScnGapDetectionGapSizeMin) {
+ doSetProperty("logMiningScnGapDetectionGapSizeMin", logMiningScnGapDetectionGapSizeMin);
+ return this;
+ }
+ /**
+ * Used for SCN gap detection, if the difference between current SCN and
+ * previous end SCN is bigger than this value, and the time difference
+ * of current SCN and previous end SCN is smaller than
+ * log.mining.scn.gap.detection.time.interval.max.ms, consider it a SCN
+ * gap.
+ *
+ * The option will be converted to a <code>long</code> type.
+ *
+ * Default: 1000000
+ * Group: oracle
+ *
+ * @param logMiningScnGapDetectionGapSizeMin the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleEndpointBuilder logMiningScnGapDetectionGapSizeMin(
+ String logMiningScnGapDetectionGapSizeMin) {
+ doSetProperty("logMiningScnGapDetectionGapSizeMin", logMiningScnGapDetectionGapSizeMin);
+ return this;
+ }
+ /**
+ * Used for SCN gap detection, if the difference between current SCN and
+ * previous end SCN is bigger than
+ * log.mining.scn.gap.detection.gap.size.min, and the time difference of
+ * current SCN and previous end SCN is smaller than this value, consider
+ * it a SCN gap.
+ *
+ * The option is a: <code>long</code> type.
+ *
+ * Default: 20s
+ * Group: oracle
+ *
+ * @param logMiningScnGapDetectionTimeIntervalMaxMs the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleEndpointBuilder logMiningScnGapDetectionTimeIntervalMaxMs(
+ long logMiningScnGapDetectionTimeIntervalMaxMs) {
+ doSetProperty("logMiningScnGapDetectionTimeIntervalMaxMs", logMiningScnGapDetectionTimeIntervalMaxMs);
+ return this;
+ }
+ /**
+ * Used for SCN gap detection, if the difference between current SCN and
+ * previous end SCN is bigger than
+ * log.mining.scn.gap.detection.gap.size.min, and the time difference of
+ * current SCN and previous end SCN is smaller than this value, consider
+ * it a SCN gap.
+ *
+ * The option will be converted to a <code>long</code> type.
+ *
+ * Default: 20s
+ * Group: oracle
+ *
+ * @param logMiningScnGapDetectionTimeIntervalMaxMs the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleEndpointBuilder logMiningScnGapDetectionTimeIntervalMaxMs(
+ String logMiningScnGapDetectionTimeIntervalMaxMs) {
+ doSetProperty("logMiningScnGapDetectionTimeIntervalMaxMs", logMiningScnGapDetectionTimeIntervalMaxMs);
+ return this;
+ }
+ /**
+ * The amount of time that the connector will sleep after reading data
+ * from redo/archive logs and before starting reading data again. Value
+ * is in milliseconds.
+ *
+ * The option is a: <code>long</code> type.
+ *
+ * Default: 1s
+ * Group: oracle
+ *
+ * @param logMiningSleepTimeDefaultMs the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleEndpointBuilder logMiningSleepTimeDefaultMs(
+ long logMiningSleepTimeDefaultMs) {
+ doSetProperty("logMiningSleepTimeDefaultMs", logMiningSleepTimeDefaultMs);
+ return this;
+ }
+ /**
+ * The amount of time that the connector will sleep after reading data
+ * from redo/archive logs and before starting reading data again. Value
+ * is in milliseconds.
+ *
+ * The option will be converted to a <code>long</code> type.
+ *
+ * Default: 1s
+ * Group: oracle
+ *
+ * @param logMiningSleepTimeDefaultMs the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleEndpointBuilder logMiningSleepTimeDefaultMs(
+ String logMiningSleepTimeDefaultMs) {
+ doSetProperty("logMiningSleepTimeDefaultMs", logMiningSleepTimeDefaultMs);
+ return this;
+ }
+ /**
+ * The maximum amount of time that the connector will use to tune the
+ * optimal sleep time when reading data from LogMiner. Value is in
+ * milliseconds.
+ *
+ * The option is a: <code>long</code> type.
+ *
+ * Default: 200ms
+ * Group: oracle
+ *
+ * @param logMiningSleepTimeIncrementMs the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleEndpointBuilder logMiningSleepTimeIncrementMs(
+ long logMiningSleepTimeIncrementMs) {
+ doSetProperty("logMiningSleepTimeIncrementMs", logMiningSleepTimeIncrementMs);
+ return this;
+ }
+ /**
+ * The maximum amount of time that the connector will use to tune the
+ * optimal sleep time when reading data from LogMiner. Value is in
+ * milliseconds.
+ *
+ * The option will be converted to a <code>long</code> type.
+ *
+ * Default: 200ms
+ * Group: oracle
+ *
+ * @param logMiningSleepTimeIncrementMs the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleEndpointBuilder logMiningSleepTimeIncrementMs(
+ String logMiningSleepTimeIncrementMs) {
+ doSetProperty("logMiningSleepTimeIncrementMs", logMiningSleepTimeIncrementMs);
+ return this;
+ }
+ /**
+ * The maximum amount of time that the connector will sleep after
+ * reading data from redo/archive logs and before starting reading data
+ * again. Value is in milliseconds.
+ *
+ * The option is a: <code>long</code> type.
+ *
+ * Default: 3s
+ * Group: oracle
+ *
+ * @param logMiningSleepTimeMaxMs the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleEndpointBuilder logMiningSleepTimeMaxMs(
+ long logMiningSleepTimeMaxMs) {
+ doSetProperty("logMiningSleepTimeMaxMs", logMiningSleepTimeMaxMs);
+ return this;
+ }
+ /**
+ * The maximum amount of time that the connector will sleep after
+ * reading data from redo/archive logs and before starting reading data
+ * again. Value is in milliseconds.
+ *
+ * The option will be converted to a <code>long</code> type.
+ *
+ * Default: 3s
+ * Group: oracle
+ *
+ * @param logMiningSleepTimeMaxMs the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleEndpointBuilder logMiningSleepTimeMaxMs(
+ String logMiningSleepTimeMaxMs) {
+ doSetProperty("logMiningSleepTimeMaxMs", logMiningSleepTimeMaxMs);
+ return this;
+ }
+ /**
+ * The minimum amount of time that the connector will sleep after
+ * reading data from redo/archive logs and before starting reading data
+ * again. Value is in milliseconds.
+ *
+ * The option is a: <code>long</code> type.
+ *
+ * Default: 0ms
+ * Group: oracle
+ *
+ * @param logMiningSleepTimeMinMs the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleEndpointBuilder logMiningSleepTimeMinMs(
+ long logMiningSleepTimeMinMs) {
+ doSetProperty("logMiningSleepTimeMinMs", logMiningSleepTimeMinMs);
+ return this;
+ }
+ /**
+ * The minimum amount of time that the connector will sleep after
+ * reading data from redo/archive logs and before starting reading data
+ * again. Value is in milliseconds.
+ *
+ * The option will be converted to a <code>long</code> type.
+ *
+ * Default: 0ms
+ * Group: oracle
+ *
+ * @param logMiningSleepTimeMinMs the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleEndpointBuilder logMiningSleepTimeMinMs(
+ String logMiningSleepTimeMinMs) {
+ doSetProperty("logMiningSleepTimeMinMs", logMiningSleepTimeMinMs);
+ return this;
+ }
+ /**
+ * There are strategies: Online catalog with faster mining but no
+ * captured DDL. Another - with data dictionary loaded into REDO LOG
+ * files.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Default: redo_log_catalog
+ * Group: oracle
+ *
+ * @param logMiningStrategy the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleEndpointBuilder logMiningStrategy(
+ String logMiningStrategy) {
+ doSetProperty("logMiningStrategy", logMiningStrategy);
+ return this;
+ }
+ /**
+ * Hours to keep long running transactions in transaction buffer between
+ * log mining sessions. By default, all transactions are retained.
+ *
+ * The option is a: <code>long</code> type.
+ *
+ * Default: 0
+ * Group: oracle
+ *
+ * @param logMiningTransactionRetentionHours the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleEndpointBuilder logMiningTransactionRetentionHours(
+ long logMiningTransactionRetentionHours) {
+ doSetProperty("logMiningTransactionRetentionHours", logMiningTransactionRetentionHours);
+ return this;
+ }
+ /**
+ * Hours to keep long running transactions in transaction buffer between
+ * log mining sessions. By default, all transactions are retained.
+ *
+ * The option will be converted to a <code>long</code> type.
+ *
+ * Default: 0
+ * Group: oracle
+ *
+ * @param logMiningTransactionRetentionHours the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleEndpointBuilder logMiningTransactionRetentionHours(
+ String logMiningTransactionRetentionHours) {
+ doSetProperty("logMiningTransactionRetentionHours", logMiningTransactionRetentionHours);
+ return this;
+ }
+ /**
+ * Comma separated list of usernames to exclude from LogMiner query.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: oracle
+ *
+ * @param logMiningUsernameExcludeList the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleEndpointBuilder logMiningUsernameExcludeList(
+ String logMiningUsernameExcludeList) {
+ doSetProperty("logMiningUsernameExcludeList", logMiningUsernameExcludeList);
+ return this;
+ }
+ /**
+ * Maximum size of each batch of source records. Defaults to 2048.
+ *
+ * The option is a: <code>int</code> type.
+ *
+ * Default: 2048
+ * Group: oracle
+ *
+ * @param maxBatchSize the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleEndpointBuilder maxBatchSize(int maxBatchSize) {
+ doSetProperty("maxBatchSize", maxBatchSize);
+ return this;
+ }
+ /**
+ * Maximum size of each batch of source records. Defaults to 2048.
+ *
+ * The option will be converted to a <code>int</code> type.
+ *
+ * Default: 2048
+ * Group: oracle
+ *
+ * @param maxBatchSize the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleEndpointBuilder maxBatchSize(String maxBatchSize) {
+ doSetProperty("maxBatchSize", maxBatchSize);
+ return this;
+ }
+ /**
+ * Maximum size of the queue for change events read from the database
+ * log but not yet recorded or forwarded. Defaults to 8192, and should
+ * always be larger than the maximum batch size.
+ *
+ * The option is a: <code>int</code> type.
+ *
+ * Default: 8192
+ * Group: oracle
+ *
+ * @param maxQueueSize the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleEndpointBuilder maxQueueSize(int maxQueueSize) {
+ doSetProperty("maxQueueSize", maxQueueSize);
+ return this;
+ }
+ /**
+ * Maximum size of the queue for change events read from the database
+ * log but not yet recorded or forwarded. Defaults to 8192, and should
+ * always be larger than the maximum batch size.
+ *
+ * The option will be converted to a <code>int</code> type.
+ *
+ * Default: 8192
+ * Group: oracle
+ *
+ * @param maxQueueSize the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleEndpointBuilder maxQueueSize(String maxQueueSize) {
+ doSetProperty("maxQueueSize", maxQueueSize);
+ return this;
+ }
+ /**
+ * Maximum size of the queue in bytes for change events read from the
+ * database log but not yet recorded or forwarded. Defaults to 0. Mean
+ * the feature is not enabled.
+ *
+ * The option is a: <code>long</code> type.
+ *
+ * Default: 0
+ * Group: oracle
+ *
+ * @param maxQueueSizeInBytes the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleEndpointBuilder maxQueueSizeInBytes(
+ long maxQueueSizeInBytes) {
+ doSetProperty("maxQueueSizeInBytes", maxQueueSizeInBytes);
+ return this;
+ }
+ /**
+ * Maximum size of the queue in bytes for change events read from the
+ * database log but not yet recorded or forwarded. Defaults to 0. Mean
+ * the feature is not enabled.
+ *
+ * The option will be converted to a <code>long</code> type.
+ *
+ * Default: 0
+ * Group: oracle
+ *
+ * @param maxQueueSizeInBytes the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleEndpointBuilder maxQueueSizeInBytes(
+ String maxQueueSizeInBytes) {
+ doSetProperty("maxQueueSizeInBytes", maxQueueSizeInBytes);
+ return this;
+ }
+ /**
+ * A semicolon-separated list of expressions that match fully-qualified
+ * tables and column(s) to be used as message key. Each expression must
+ * match the pattern ':',where the table names could be defined as
+ * (DB_NAME.TABLE_NAME) or (SCHEMA_NAME.TABLE_NAME), depending on the
+ * specific connector,and the key columns are a comma-separated list of
+ * columns representing the custom key. For any table without an
+ * explicit key configuration the table's primary key column(s) will be
+ * used as message key.Example:
+ * dbserver1.inventory.orderlines:orderId,orderLineId;dbserver1.inventory.orders:id.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: oracle
+ *
+ * @param messageKeyColumns the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleEndpointBuilder messageKeyColumns(
+ String messageKeyColumns) {
+ doSetProperty("messageKeyColumns", messageKeyColumns);
+ return this;
+ }
+ /**
+ * Time to wait for new change events to appear after receiving no
+ * events, given in milliseconds. Defaults to 500 ms.
+ *
+ * The option is a: <code>long</code> type.
+ *
+ * Default: 500ms
+ * Group: oracle
+ *
+ * @param pollIntervalMs the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleEndpointBuilder pollIntervalMs(long pollIntervalMs) {
+ doSetProperty("pollIntervalMs", pollIntervalMs);
+ return this;
+ }
+ /**
+ * Time to wait for new change events to appear after receiving no
+ * events, given in milliseconds. Defaults to 500 ms.
+ *
+ * The option will be converted to a <code>long</code> type.
+ *
+ * Default: 500ms
+ * Group: oracle
+ *
+ * @param pollIntervalMs the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleEndpointBuilder pollIntervalMs(
+ String pollIntervalMs) {
+ doSetProperty("pollIntervalMs", pollIntervalMs);
+ return this;
+ }
+ /**
+ * Enables transaction metadata extraction together with event counting.
+ *
+ * The option is a: <code>boolean</code> type.
+ *
+ * Default: false
+ * Group: oracle
+ *
+ * @param provideTransactionMetadata the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleEndpointBuilder provideTransactionMetadata(
+ boolean provideTransactionMetadata) {
+ doSetProperty("provideTransactionMetadata", provideTransactionMetadata);
+ return this;
+ }
+ /**
+ * Enables transaction metadata extraction together with event counting.
+ *
+ * The option will be converted to a <code>boolean</code>
+ * type.
+ *
+ * Default: false
+ * Group: oracle
+ *
+ * @param provideTransactionMetadata the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleEndpointBuilder provideTransactionMetadata(
+ String provideTransactionMetadata) {
+ doSetProperty("provideTransactionMetadata", provideTransactionMetadata);
+ return this;
+ }
+ /**
+ * The maximum number of records that should be loaded into memory while
+ * streaming. A value of 0 uses the default JDBC fetch size.
+ *
+ * The option is a: <code>int</code> type.
+ *
+ * Default: 0
+ * Group: oracle
+ *
+ * @param queryFetchSize the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleEndpointBuilder queryFetchSize(int queryFetchSize) {
+ doSetProperty("queryFetchSize", queryFetchSize);
+ return this;
+ }
+ /**
+ * The maximum number of records that should be loaded into memory while
+ * streaming. A value of 0 uses the default JDBC fetch size.
+ *
+ * The option will be converted to a <code>int</code> type.
+ *
+ * Default: 0
+ * Group: oracle
+ *
+ * @param queryFetchSize the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleEndpointBuilder queryFetchSize(
+ String queryFetchSize) {
+ doSetProperty("queryFetchSize", queryFetchSize);
+ return this;
+ }
+ /**
+ * A comma-separated list of RAC node hostnames or ip addresses.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: oracle
+ *
+ * @param racNodes the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleEndpointBuilder racNodes(String racNodes) {
+ doSetProperty("racNodes", racNodes);
+ return this;
+ }
+ /**
+ * Time to wait before restarting connector after retriable exception
+ * occurs. Defaults to 10000ms.
+ *
+ * The option is a: <code>long</code> type.
+ *
+ * Default: 10s
+ * Group: oracle
+ *
+ * @param retriableRestartConnectorWaitMs the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleEndpointBuilder retriableRestartConnectorWaitMs(
+ long retriableRestartConnectorWaitMs) {
+ doSetProperty("retriableRestartConnectorWaitMs", retriableRestartConnectorWaitMs);
+ return this;
+ }
+ /**
+ * Time to wait before restarting connector after retriable exception
+ * occurs. Defaults to 10000ms.
+ *
+ * The option will be converted to a <code>long</code> type.
+ *
+ * Default: 10s
+ * Group: oracle
+ *
+ * @param retriableRestartConnectorWaitMs the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleEndpointBuilder retriableRestartConnectorWaitMs(
+ String retriableRestartConnectorWaitMs) {
+ 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 data collection that is used to send signals/commands
+ * to Debezium. Signaling is disabled when not set.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: oracle
+ *
+ * @param signalDataCollection the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleEndpointBuilder signalDataCollection(
+ String signalDataCollection) {
+ doSetProperty("signalDataCollection", signalDataCollection);
+ return this;
+ }
+ /**
+ * The comma-separated list of operations to skip during streaming,
+ * defined as: 'c' for inserts/create; 'u' for updates; 'd' for deletes.
+ * By default, no operations will be skipped.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: oracle
+ *
+ * @param skippedOperations the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleEndpointBuilder skippedOperations(
+ String skippedOperations) {
+ doSetProperty("skippedOperations", skippedOperations);
+ return this;
+ }
+ /**
+ * A delay period before a snapshot will begin, given in milliseconds.
+ * Defaults to 0 ms.
+ *
+ * The option is a: <code>long</code> type.
+ *
+ * Default: 0ms
+ * Group: oracle
+ *
+ * @param snapshotDelayMs the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleEndpointBuilder snapshotDelayMs(
+ long snapshotDelayMs) {
+ doSetProperty("snapshotDelayMs", snapshotDelayMs);
+ return this;
+ }
+ /**
+ * A delay period before a snapshot will begin, given in milliseconds.
+ * Defaults to 0 ms.
+ *
+ * The option will be converted to a <code>long</code> type.
+ *
+ * Default: 0ms
+ * Group: oracle
+ *
+ * @param snapshotDelayMs the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleEndpointBuilder snapshotDelayMs(
+ String snapshotDelayMs) {
+ doSetProperty("snapshotDelayMs", snapshotDelayMs);
+ return this;
+ }
+ /**
+ * A token to replace on snapshot predicate template.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: oracle
+ *
+ * @param snapshotEnhancePredicateScn the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleEndpointBuilder snapshotEnhancePredicateScn(
+ String snapshotEnhancePredicateScn) {
+ doSetProperty("snapshotEnhancePredicateScn", snapshotEnhancePredicateScn);
+ return this;
+ }
+ /**
+ * The maximum number of records that should be loaded into memory while
+ * performing a snapshot.
+ *
+ * The option is a: <code>int</code> type.
+ *
+ * Group: oracle
+ *
+ * @param snapshotFetchSize the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleEndpointBuilder snapshotFetchSize(
+ int snapshotFetchSize) {
+ doSetProperty("snapshotFetchSize", snapshotFetchSize);
+ return this;
+ }
+ /**
+ * The maximum number of records that should be loaded into memory while
+ * performing a snapshot.
+ *
+ * The option will be converted to a <code>int</code> type.
+ *
+ * Group: oracle
+ *
+ * @param snapshotFetchSize the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleEndpointBuilder snapshotFetchSize(
+ String snapshotFetchSize) {
+ doSetProperty("snapshotFetchSize", snapshotFetchSize);
+ return this;
+ }
+ /**
+ * this setting must be set to specify a list of tables/collections
+ * whose snapshot must be taken on creating or restarting the connector.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: oracle
+ *
+ * @param snapshotIncludeCollectionList the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleEndpointBuilder snapshotIncludeCollectionList(
+ String snapshotIncludeCollectionList) {
+ doSetProperty("snapshotIncludeCollectionList", snapshotIncludeCollectionList);
+ return this;
+ }
+ /**
+ * Controls how the connector holds locks on tables while performing the
+ * schema snapshot. The default is 'shared', which means the connector
+ * will hold a table lock that prevents exclusive table access for just
+ * the initial portion of the snapshot while the database schemas and
+ * other metadata are being read. The remaining work in a snapshot
+ * involves selecting all rows from each table, and this is done using a
+ * flashback query that requires no locks. However, in some cases it may
+ * be desirable to avoid locks entirely which can be done by specifying
+ * 'none'. This mode is only safe to use if no schema changes are
+ * happening while the snapshot is taken.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Default: shared
+ * Group: oracle
+ *
+ * @param snapshotLockingMode the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleEndpointBuilder snapshotLockingMode(
+ String snapshotLockingMode) {
+ doSetProperty("snapshotLockingMode", snapshotLockingMode);
+ return this;
+ }
+ /**
+ * The maximum number of millis to wait for table locks at the beginning
+ * of a snapshot. If locks cannot be acquired in this time frame, the
+ * snapshot will be aborted. Defaults to 10 seconds.
+ *
+ * The option is a: <code>long</code> type.
+ *
+ * Default: 10s
+ * Group: oracle
+ *
+ * @param snapshotLockTimeoutMs the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleEndpointBuilder snapshotLockTimeoutMs(
+ long snapshotLockTimeoutMs) {
+ doSetProperty("snapshotLockTimeoutMs", snapshotLockTimeoutMs);
+ return this;
+ }
+ /**
+ * The maximum number of millis to wait for table locks at the beginning
+ * of a snapshot. If locks cannot be acquired in this time frame, the
+ * snapshot will be aborted. Defaults to 10 seconds.
+ *
+ * The option will be converted to a <code>long</code> type.
+ *
+ * Default: 10s
+ * Group: oracle
+ *
+ * @param snapshotLockTimeoutMs the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleEndpointBuilder snapshotLockTimeoutMs(
+ String snapshotLockTimeoutMs) {
+ doSetProperty("snapshotLockTimeoutMs", snapshotLockTimeoutMs);
+ return this;
+ }
+ /**
+ * The maximum number of threads used to perform the snapshot. Defaults
+ * to 1.
+ *
+ * The option is a: <code>int</code> type.
+ *
+ * Default: 1
+ * Group: oracle
+ *
+ * @param snapshotMaxThreads the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleEndpointBuilder snapshotMaxThreads(
+ int snapshotMaxThreads) {
+ doSetProperty("snapshotMaxThreads", snapshotMaxThreads);
+ return this;
+ }
+ /**
+ * The maximum number of threads used to perform the snapshot. Defaults
+ * to 1.
+ *
+ * The option will be converted to a <code>int</code> type.
+ *
+ * Default: 1
+ * Group: oracle
+ *
+ * @param snapshotMaxThreads the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleEndpointBuilder snapshotMaxThreads(
+ String snapshotMaxThreads) {
+ doSetProperty("snapshotMaxThreads", snapshotMaxThreads);
+ return this;
+ }
+ /**
+ * The criteria for running a snapshot upon startup of the connector.
+ * Options include: 'initial' (the default) to specify the connector
+ * should run a snapshot only when no offsets are available for the
+ * logical server name; 'schema_only' to specify the connector should
+ * run a snapshot of the schema when no offsets are available for the
+ * logical server name.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Default: initial
+ * Group: oracle
+ *
+ * @param snapshotMode the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleEndpointBuilder snapshotMode(String snapshotMode) {
+ doSetProperty("snapshotMode", snapshotMode);
+ return this;
+ }
+ /**
+ * This property contains a comma-separated list of fully-qualified
+ * tables (DB_NAME.TABLE_NAME) or (SCHEMA_NAME.TABLE_NAME), depending on
+ * thespecific connectors. Select statements for the individual tables
+ * are specified in further configuration properties, one for each
+ * table, identified by the id
+ * 'snapshot.select.statement.overrides.DB_NAME.TABLE_NAME' or
+ * 'snapshot.select.statement.overrides.SCHEMA_NAME.TABLE_NAME',
+ * respectively. The value of those properties is the select statement
+ * to use when retrieving data from the specific table during
+ * snapshotting. A possible use case for large append-only tables is
+ * setting a specific point where to start (resume) snapshotting, in
+ * case a previous snapshotting was interrupted.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: oracle
+ *
+ * @param snapshotSelectStatementOverrides the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleEndpointBuilder snapshotSelectStatementOverrides(
+ String snapshotSelectStatementOverrides) {
+ doSetProperty("snapshotSelectStatementOverrides", snapshotSelectStatementOverrides);
+ return this;
+ }
+ /**
+ * A version of the format of the publicly visible source part in the
+ * message.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Default: v2
+ * Group: oracle
+ *
+ * @param sourceStructVersion the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleEndpointBuilder sourceStructVersion(
+ String sourceStructVersion) {
+ doSetProperty("sourceStructVersion", sourceStructVersion);
+ return this;
+ }
+ /**
+ * A comma-separated list of regular expressions that match the
+ * fully-qualified names of tables to be excluded from monitoring
+ * (deprecated, use table.exclude.list instead).
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: oracle
+ *
+ * @param tableBlacklist the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleEndpointBuilder tableBlacklist(
+ String tableBlacklist) {
+ doSetProperty("tableBlacklist", tableBlacklist);
+ return this;
+ }
+ /**
+ * A comma-separated list of regular expressions that match the
+ * fully-qualified names of tables to be excluded from monitoring.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: oracle
+ *
+ * @param tableExcludeList the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleEndpointBuilder tableExcludeList(
+ String tableExcludeList) {
+ doSetProperty("tableExcludeList", tableExcludeList);
+ return this;
+ }
+ /**
+ * The tables for which changes are to be captured.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: oracle
+ *
+ * @param tableIncludeList the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleEndpointBuilder tableIncludeList(
+ String tableIncludeList) {
+ doSetProperty("tableIncludeList", tableIncludeList);
+ return this;
+ }
+ /**
+ * The tables for which changes are to be captured (deprecated, use
+ * table.include.list instead).
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: oracle
+ *
+ * @param tableWhitelist the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleEndpointBuilder tableWhitelist(
+ String tableWhitelist) {
+ doSetProperty("tableWhitelist", tableWhitelist);
+ return this;
+ }
+ /**
+ * Time, date, and timestamps can be represented with different kinds of
+ * precisions, including:'adaptive' (the default) bases the precision of
+ * time, date, and timestamp values on the database column's precision;
+ * 'adaptive_time_microseconds' like 'adaptive' mode, but TIME fields
+ * always use microseconds precision;'connect' always represents time,
+ * date, and timestamp values using Kafka Connect's built-in
+ * representations for Time, Date, and Timestamp, which uses millisecond
+ * precision regardless of the database columns' precision .
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Default: adaptive
+ * Group: oracle
+ *
+ * @param timePrecisionMode the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleEndpointBuilder timePrecisionMode(
+ String timePrecisionMode) {
+ doSetProperty("timePrecisionMode", timePrecisionMode);
+ return this;
+ }
+ /**
+ * Whether delete operations should be represented by a delete event and
+ * a subsquenttombstone event (true) or only by a delete event (false).
+ * Emitting the tombstone event (the default behavior) allows Kafka to
+ * completely delete all events pertaining to the given key once the
+ * source record got deleted.
+ *
+ * The option is a: <code>boolean</code> type.
+ *
+ * Default: false
+ * Group: oracle
+ *
+ * @param tombstonesOnDelete the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleEndpointBuilder tombstonesOnDelete(
+ boolean tombstonesOnDelete) {
+ doSetProperty("tombstonesOnDelete", tombstonesOnDelete);
+ return this;
+ }
+ /**
+ * Whether delete operations should be represented by a delete event and
+ * a subsquenttombstone event (true) or only by a delete event (false).
+ * Emitting the tombstone event (the default behavior) allows Kafka to
+ * completely delete all events pertaining to the given key once the
+ * source record got deleted.
+ *
+ * The option will be converted to a <code>boolean</code>
+ * type.
+ *
+ * Default: false
+ * Group: oracle
+ *
+ * @param tombstonesOnDelete the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleEndpointBuilder tombstonesOnDelete(
+ String tombstonesOnDelete) {
+ doSetProperty("tombstonesOnDelete", tombstonesOnDelete);
+ return this;
+ }
+ /**
+ * The name of the transaction metadata topic. The placeholder
+ * ${database.server.name} can be used for referring to the connector's
+ * logical name; defaults to ${database.server.name}.transaction.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Default: ${database.server.name}.transaction
+ * Group: oracle
+ *
+ * @param transactionTopic the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleEndpointBuilder transactionTopic(
+ String transactionTopic) {
+ doSetProperty("transactionTopic", transactionTopic);
+ return this;
+ }
+ /**
+ * Specify the constant that will be provided by Debezium to indicate
+ * that the original value is unavailable and not provided by the
+ * database.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Default: __debezium_unavailable_value
+ * Group: oracle
+ *
+ * @param unavailableValuePlaceholder the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleEndpointBuilder unavailableValuePlaceholder(
+ String unavailableValuePlaceholder) {
+ doSetProperty("unavailableValuePlaceholder", unavailableValuePlaceholder);
+ return this;
+ }
+ }
+
+ /**
+ * Advanced builder for endpoint for the Debezium Oracle Connector
+ * component.
+ */
+ public interface AdvancedDebeziumOracleEndpointBuilder
+ extends
+ EndpointConsumerBuilder {
+ default DebeziumOracleEndpointBuilder basic() {
+ return (DebeziumOracleEndpointBuilder) this;
+ }
+ /**
+ * To let the consumer use a custom ExceptionHandler. Notice if the
+ * option bridgeErrorHandler is enabled then this option is not in use.
+ * By default the consumer will deal with exceptions, that will be
+ * logged at WARN or ERROR level and ignored.
+ *
+ * The option is a:
+ * <code>org.apache.camel.spi.ExceptionHandler</code> type.
+ *
+ * Group: consumer (advanced)
+ *
+ * @param exceptionHandler the value to set
+ * @return the dsl builder
+ */
+ default AdvancedDebeziumOracleEndpointBuilder exceptionHandler(
+ org.apache.camel.spi.ExceptionHandler exceptionHandler) {
+ doSetProperty("exceptionHandler", exceptionHandler);
+ return this;
+ }
+ /**
+ * To let the consumer use a custom ExceptionHandler. Notice if the
+ * option bridgeErrorHandler is enabled then this option is not in use.
+ * By default the consumer will deal with exceptions, that will be
+ * logged at WARN or ERROR level and ignored.
+ *
+ * The option will be converted to a
+ * <code>org.apache.camel.spi.ExceptionHandler</code> type.
+ *
+ * Group: consumer (advanced)
+ *
+ * @param exceptionHandler the value to set
+ * @return the dsl builder
+ */
+ default AdvancedDebeziumOracleEndpointBuilder exceptionHandler(
+ String exceptionHandler) {
+ doSetProperty("exceptionHandler", exceptionHandler);
+ return this;
+ }
+ /**
+ * Sets the exchange pattern when the consumer creates an exchange.
+ *
+ * The option is a:
+ * <code>org.apache.camel.ExchangePattern</code> type.
+ *
+ * Group: consumer (advanced)
+ *
+ * @param exchangePattern the value to set
+ * @return the dsl builder
+ */
+ default AdvancedDebeziumOracleEndpointBuilder exchangePattern(
+ org.apache.camel.ExchangePattern exchangePattern) {
+ doSetProperty("exchangePattern", exchangePattern);
+ return this;
+ }
+ /**
+ * Sets the exchange pattern when the consumer creates an exchange.
+ *
+ * The option will be converted to a
+ * <code>org.apache.camel.ExchangePattern</code> type.
+ *
+ * Group: consumer (advanced)
+ *
+ * @param exchangePattern the value to set
+ * @return the dsl builder
+ */
+ default AdvancedDebeziumOracleEndpointBuilder exchangePattern(
+ String exchangePattern) {
+ doSetProperty("exchangePattern", exchangePattern);
+ return this;
+ }
+ }
+
+ public interface DebeziumOracleBuilders {
+ /**
+ * Debezium Oracle Connector (camel-debezium-oracle)
+ * Capture changes from a Oracle database.
+ *
+ * Category: database,sql
+ * Since: 3.17
+ * Maven coordinates: org.apache.camel:camel-debezium-oracle
+ *
+ * Syntax: <code>debezium-oracle:name</code>
+ *
+ * Path parameter: name (required)
+ * Unique name for the connector. Attempting to register again with the
+ * same name will fail.
+ *
+ * @param path name
+ * @return the dsl builder
+ */
+ default DebeziumOracleEndpointBuilder debeziumOracle(String path) {
+ return DebeziumOracleEndpointBuilderFactory.endpointBuilder("debezium-oracle", path);
+ }
+ /**
+ * Debezium Oracle Connector (camel-debezium-oracle)
+ * Capture changes from a Oracle database.
+ *
+ * Category: database,sql
+ * Since: 3.17
+ * Maven coordinates: org.apache.camel:camel-debezium-oracle
+ *
+ * Syntax: <code>debezium-oracle:name</code>
+ *
+ * Path parameter: name (required)
+ * Unique name for the connector. Attempting to register again with the
+ * same name will fail.
+ *
+ * @param componentName to use a custom component name for the endpoint
+ * instead of the default name
+ * @param path name
+ * @return the dsl builder
+ */
+ default DebeziumOracleEndpointBuilder debeziumOracle(
+ String componentName,
+ String path) {
+ return DebeziumOracleEndpointBuilderFactory.endpointBuilder(componentName, path);
+ }
+ }
+ static DebeziumOracleEndpointBuilder endpointBuilder(
+ String componentName,
+ String path) {
+ class DebeziumOracleEndpointBuilderImpl extends AbstractEndpointBuilder implements DebeziumOracleEndpointBuilder, AdvancedDebeziumOracleEndpointBuilder {
+ public DebeziumOracleEndpointBuilderImpl(String path) {
+ super(componentName, path);
+ }
+ }
+ return new DebeziumOracleEndpointBuilderImpl(path);
+ }
+}
\ No newline at end of file
diff --git a/tooling/maven/camel-package-maven-plugin/src/main/java/org/apache/camel/maven/packaging/MojoHelper.java b/tooling/maven/camel-package-maven-plugin/src/main/java/org/apache/camel/maven/packaging/MojoHelper.java
index f42e08369d4..cc35907cac9 100644
--- a/tooling/maven/camel-package-maven-plugin/src/main/java/org/apache/camel/maven/packaging/MojoHelper.java
+++ b/tooling/maven/camel-package-maven-plugin/src/main/java/org/apache/camel/maven/packaging/MojoHelper.java
@@ -59,7 +59,8 @@ public final class MojoHelper {
dir.resolve("camel-google-secret-manager"));
case "camel-debezium":
return Arrays.asList(dir.resolve("camel-debezium-mongodb"), dir.resolve("camel-debezium-mysql"),
- dir.resolve("camel-debezium-postgres"), dir.resolve("camel-debezium-sqlserver"), dir.resolve("camel-debezium-oracle"));
+ dir.resolve("camel-debezium-postgres"), dir.resolve("camel-debezium-sqlserver"),
+ dir.resolve("camel-debezium-oracle"));
case "camel-microprofile":
return Arrays.asList(dir.resolve("camel-microprofile-config"),
dir.resolve("camel-microprofile-fault-tolerance"),
[camel] 01/02: CAMEL:17092:Debezium 1.7.0 - Oracle Connector - Add to tooling
Posted by ac...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel.git
commit 1aae556f1d05c0a21ba8260faf724497706e41ca
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Mon Apr 4 17:59:46 2022 +0200
CAMEL:17092:Debezium 1.7.0 - Oracle Connector - Add to tooling
---
.../src/main/java/org/apache/camel/maven/packaging/MojoHelper.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/tooling/maven/camel-package-maven-plugin/src/main/java/org/apache/camel/maven/packaging/MojoHelper.java b/tooling/maven/camel-package-maven-plugin/src/main/java/org/apache/camel/maven/packaging/MojoHelper.java
index f8254dded0a..f42e08369d4 100644
--- a/tooling/maven/camel-package-maven-plugin/src/main/java/org/apache/camel/maven/packaging/MojoHelper.java
+++ b/tooling/maven/camel-package-maven-plugin/src/main/java/org/apache/camel/maven/packaging/MojoHelper.java
@@ -59,7 +59,7 @@ public final class MojoHelper {
dir.resolve("camel-google-secret-manager"));
case "camel-debezium":
return Arrays.asList(dir.resolve("camel-debezium-mongodb"), dir.resolve("camel-debezium-mysql"),
- dir.resolve("camel-debezium-postgres"), dir.resolve("camel-debezium-sqlserver"));
+ dir.resolve("camel-debezium-postgres"), dir.resolve("camel-debezium-sqlserver"), dir.resolve("camel-debezium-oracle"));
case "camel-microprofile":
return Arrays.asList(dir.resolve("camel-microprofile-config"),
dir.resolve("camel-microprofile-fault-tolerance"),