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 5ed6d5dbb8ea198a9754617c7a29ba6aa66fae41
Author: Andrea Cosentino <anco...@gmail.com>
AuthorDate: Tue Jun 27 12:54:36 2023 +0200
CAMEL-19485 - camel-debezium - Upgrade to 2.3 - Align Mysql connector java
version to 8.0.33, used by Debezium
Signed-off-by: Andrea Cosentino <anco...@gmail.com>
---
camel-dependencies/pom.xml | 2 +-
.../dsl/DebeziumDb2ComponentBuilderFactory.java | 90 ++++++++-
.../DebeziumMongodbComponentBuilderFactory.java | 97 ++++++++-
.../dsl/DebeziumMysqlComponentBuilderFactory.java | 131 ++++++++++--
.../dsl/DebeziumOracleComponentBuilderFactory.java | 189 +++++++++++++++++-
.../DebeziumPostgresComponentBuilderFactory.java | 170 ++++++++++++++--
.../DebeziumSqlserverComponentBuilderFactory.java | 108 +++++++++-
.../dsl/DebeziumDb2EndpointBuilderFactory.java | 105 +++++++++-
.../dsl/DebeziumMongodbEndpointBuilderFactory.java | 109 +++++++++-
.../dsl/DebeziumMySqlEndpointBuilderFactory.java | 146 ++++++++++++--
.../dsl/DebeziumOracleEndpointBuilderFactory.java | 219 ++++++++++++++++++++-
.../DebeziumPostgresEndpointBuilderFactory.java | 184 ++++++++++++++---
.../DebeziumSqlserverEndpointBuilderFactory.java | 123 +++++++++++-
parent/pom.xml | 2 +-
14 files changed, 1565 insertions(+), 110 deletions(-)
diff --git a/camel-dependencies/pom.xml b/camel-dependencies/pom.xml
index c745b2320ea..d72b74a378c 100644
--- a/camel-dependencies/pom.xml
+++ b/camel-dependencies/pom.xml
@@ -110,7 +110,7 @@
<cxf-xjc-plugin-version>4.0.0</cxf-xjc-plugin-version>
<cxf-xjc-utils-version>4.0.0</cxf-xjc-utils-version>
<datasonnet-mapper-version>2.5.2-jakarta4</datasonnet-mapper-version>
-
<debezium-mysql-connector-version>8.0.32</debezium-mysql-connector-version>
+
<debezium-mysql-connector-version>8.0.33</debezium-mysql-connector-version>
<debezium-version>2.3.0.Final</debezium-version>
<depends-maven-plugin-version>1.4.0</depends-maven-plugin-version>
<derby-version>10.14.2.0</derby-version>
diff --git
a/dsl/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/DebeziumDb2ComponentBuilderFactory.java
b/dsl/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/DebeziumDb2ComponentBuilderFactory.java
index 705dae4e95a..82325b356e3 100644
---
a/dsl/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/DebeziumDb2ComponentBuilderFactory.java
+++
b/dsl/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/DebeziumDb2ComponentBuilderFactory.java
@@ -561,7 +561,8 @@ public interface DebeziumDb2ComponentBuilderFactory {
return this;
}
/**
- * The maximum size of chunk for incremental snapshotting.
+ * The maximum size of chunk (number of documents/rows) for incremental
+ * snapshotting.
*
* The option is a: <code>int</code> type.
*
@@ -649,6 +650,37 @@ public interface DebeziumDb2ComponentBuilderFactory {
doSetProperty("messageKeyColumns", messageKeyColumns);
return this;
}
+ /**
+ * List of notification channels names that are enabled.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: db2
+ *
+ * @param notificationEnabledChannels the value to set
+ * @return the dsl builder
+ */
+ default DebeziumDb2ComponentBuilder notificationEnabledChannels(
+ java.lang.String notificationEnabledChannels) {
+ doSetProperty("notificationEnabledChannels",
notificationEnabledChannels);
+ return this;
+ }
+ /**
+ * The name of the topic for the notifications. This is required in
case
+ * 'sink' is in the list of enabled channels.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: db2
+ *
+ * @param notificationSinkTopicName the value to set
+ * @return the dsl builder
+ */
+ default DebeziumDb2ComponentBuilder notificationSinkTopicName(
+ java.lang.String notificationSinkTopicName) {
+ doSetProperty("notificationSinkTopicName",
notificationSinkTopicName);
+ return this;
+ }
/**
* Time to wait for new change events to appear after receiving no
* events, given in milliseconds. Defaults to 500 ms.
@@ -847,6 +879,40 @@ public interface DebeziumDb2ComponentBuilderFactory {
doSetProperty("signalDataCollection", signalDataCollection);
return this;
}
+ /**
+ * List of channels names that are enabled. Source channel is enabled
by
+ * default.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Default: source
+ * Group: db2
+ *
+ * @param signalEnabledChannels the value to set
+ * @return the dsl builder
+ */
+ default DebeziumDb2ComponentBuilder signalEnabledChannels(
+ java.lang.String signalEnabledChannels) {
+ doSetProperty("signalEnabledChannels", signalEnabledChannels);
+ return this;
+ }
+ /**
+ * Interval for looking for new signals in registered channels, given
in
+ * milliseconds. Defaults to 5 seconds.
+ *
+ * The option is a: <code>long</code> type.
+ *
+ * Default: 5s
+ * Group: db2
+ *
+ * @param signalPollIntervalMs the value to set
+ * @return the dsl builder
+ */
+ default DebeziumDb2ComponentBuilder signalPollIntervalMs(
+ long signalPollIntervalMs) {
+ doSetProperty("signalPollIntervalMs", signalPollIntervalMs);
+ return this;
+ }
/**
* The comma-separated list of operations to skip during streaming,
* defined as: 'c' for inserts/create; 'u' for updates; 'd' for
deletes,
@@ -999,6 +1065,23 @@ public interface DebeziumDb2ComponentBuilderFactory {
doSetProperty("snapshotTablesOrderByRowCount",
snapshotTablesOrderByRowCount);
return this;
}
+ /**
+ * The name of the SourceInfoStructMaker class that returns SourceInfo
+ * schema and struct.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Default: io.debezium.connector.db2.Db2SourceInfoStructMaker
+ * Group: db2
+ *
+ * @param sourceinfoStructMaker the value to set
+ * @return the dsl builder
+ */
+ default DebeziumDb2ComponentBuilder sourceinfoStructMaker(
+ java.lang.String sourceinfoStructMaker) {
+ doSetProperty("sourceinfoStructMaker", sourceinfoStructMaker);
+ return this;
+ }
/**
* A comma-separated list of regular expressions that match the
* fully-qualified names of tables to be excluded from monitoring.
@@ -1185,6 +1268,8 @@ public interface DebeziumDb2ComponentBuilderFactory {
case "maxQueueSize":
getOrCreateConfiguration((DebeziumDb2Component)
component).setMaxQueueSize((int) value); return true;
case "maxQueueSizeInBytes":
getOrCreateConfiguration((DebeziumDb2Component)
component).setMaxQueueSizeInBytes((long) value); return true;
case "messageKeyColumns":
getOrCreateConfiguration((DebeziumDb2Component)
component).setMessageKeyColumns((java.lang.String) value); return true;
+ case "notificationEnabledChannels":
getOrCreateConfiguration((DebeziumDb2Component)
component).setNotificationEnabledChannels((java.lang.String) value); return
true;
+ case "notificationSinkTopicName":
getOrCreateConfiguration((DebeziumDb2Component)
component).setNotificationSinkTopicName((java.lang.String) value); return true;
case "pollIntervalMs":
getOrCreateConfiguration((DebeziumDb2Component)
component).setPollIntervalMs((long) value); return true;
case "provideTransactionMetadata":
getOrCreateConfiguration((DebeziumDb2Component)
component).setProvideTransactionMetadata((boolean) value); return true;
case "queryFetchSize":
getOrCreateConfiguration((DebeziumDb2Component)
component).setQueryFetchSize((int) value); return true;
@@ -1196,6 +1281,8 @@ public interface DebeziumDb2ComponentBuilderFactory {
case "schemaHistoryInternalStoreOnlyCapturedTablesDdl":
getOrCreateConfiguration((DebeziumDb2Component)
component).setSchemaHistoryInternalStoreOnlyCapturedTablesDdl((boolean) value);
return true;
case "schemaNameAdjustmentMode":
getOrCreateConfiguration((DebeziumDb2Component)
component).setSchemaNameAdjustmentMode((java.lang.String) value); return true;
case "signalDataCollection":
getOrCreateConfiguration((DebeziumDb2Component)
component).setSignalDataCollection((java.lang.String) value); return true;
+ case "signalEnabledChannels":
getOrCreateConfiguration((DebeziumDb2Component)
component).setSignalEnabledChannels((java.lang.String) value); return true;
+ case "signalPollIntervalMs":
getOrCreateConfiguration((DebeziumDb2Component)
component).setSignalPollIntervalMs((long) value); return true;
case "skippedOperations":
getOrCreateConfiguration((DebeziumDb2Component)
component).setSkippedOperations((java.lang.String) value); return true;
case "snapshotDelayMs":
getOrCreateConfiguration((DebeziumDb2Component)
component).setSnapshotDelayMs((long) value); return true;
case "snapshotFetchSize":
getOrCreateConfiguration((DebeziumDb2Component)
component).setSnapshotFetchSize((int) value); return true;
@@ -1204,6 +1291,7 @@ public interface DebeziumDb2ComponentBuilderFactory {
case "snapshotMode":
getOrCreateConfiguration((DebeziumDb2Component)
component).setSnapshotMode((java.lang.String) value); return true;
case "snapshotSelectStatementOverrides":
getOrCreateConfiguration((DebeziumDb2Component)
component).setSnapshotSelectStatementOverrides((java.lang.String) value);
return true;
case "snapshotTablesOrderByRowCount":
getOrCreateConfiguration((DebeziumDb2Component)
component).setSnapshotTablesOrderByRowCount((java.lang.String) value); return
true;
+ case "sourceinfoStructMaker":
getOrCreateConfiguration((DebeziumDb2Component)
component).setSourceinfoStructMaker((java.lang.String) value); return true;
case "tableExcludeList":
getOrCreateConfiguration((DebeziumDb2Component)
component).setTableExcludeList((java.lang.String) value); return true;
case "tableIgnoreBuiltin":
getOrCreateConfiguration((DebeziumDb2Component)
component).setTableIgnoreBuiltin((boolean) value); return true;
case "tableIncludeList":
getOrCreateConfiguration((DebeziumDb2Component)
component).setTableIncludeList((java.lang.String) value); return true;
diff --git
a/dsl/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/DebeziumMongodbComponentBuilderFactory.java
b/dsl/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/DebeziumMongodbComponentBuilderFactory.java
index 9e43f1d85f6..d1642539243 100644
---
a/dsl/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/DebeziumMongodbComponentBuilderFactory.java
+++
b/dsl/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/DebeziumMongodbComponentBuilderFactory.java
@@ -753,6 +753,37 @@ public interface DebeziumMongodbComponentBuilderFactory {
doSetProperty("mongodbUser", mongodbUser);
return this;
}
+ /**
+ * List of notification channels names that are enabled.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: mongodb
+ *
+ * @param notificationEnabledChannels the value to set
+ * @return the dsl builder
+ */
+ default DebeziumMongodbComponentBuilder notificationEnabledChannels(
+ java.lang.String notificationEnabledChannels) {
+ doSetProperty("notificationEnabledChannels",
notificationEnabledChannels);
+ return this;
+ }
+ /**
+ * The name of the topic for the notifications. This is required in
case
+ * 'sink' is in the list of enabled channels.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: mongodb
+ *
+ * @param notificationSinkTopicName the value to set
+ * @return the dsl builder
+ */
+ default DebeziumMongodbComponentBuilder notificationSinkTopicName(
+ java.lang.String notificationSinkTopicName) {
+ doSetProperty("notificationSinkTopicName",
notificationSinkTopicName);
+ return this;
+ }
/**
* Time to wait for new change events to appear after receiving no
* events, given in milliseconds. Defaults to 500 ms.
@@ -874,6 +905,40 @@ public interface DebeziumMongodbComponentBuilderFactory {
doSetProperty("signalDataCollection", signalDataCollection);
return this;
}
+ /**
+ * List of channels names that are enabled. Source channel is enabled
by
+ * default.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Default: source
+ * Group: mongodb
+ *
+ * @param signalEnabledChannels the value to set
+ * @return the dsl builder
+ */
+ default DebeziumMongodbComponentBuilder signalEnabledChannels(
+ java.lang.String signalEnabledChannels) {
+ doSetProperty("signalEnabledChannels", signalEnabledChannels);
+ return this;
+ }
+ /**
+ * Interval for looking for new signals in registered channels, given
in
+ * milliseconds. Defaults to 5 seconds.
+ *
+ * The option is a: <code>long</code> type.
+ *
+ * Default: 5s
+ * Group: mongodb
+ *
+ * @param signalPollIntervalMs the value to set
+ * @return the dsl builder
+ */
+ default DebeziumMongodbComponentBuilder signalPollIntervalMs(
+ long signalPollIntervalMs) {
+ doSetProperty("signalPollIntervalMs", signalPollIntervalMs);
+ return this;
+ }
/**
* The comma-separated list of operations to skip during streaming,
* defined as: 'c' for inserts/create; 'u' for updates; 'd' for
deletes,
@@ -979,9 +1044,13 @@ public interface DebeziumMongodbComponentBuilderFactory {
}
/**
* The criteria for running a snapshot upon startup of the connector.
- * Options include: 'initial' (the default) to specify the connector
- * should always perform an initial sync when required; 'never' to
- * specify the connector should never perform an initial sync.
+ * Select one of the following snapshot options: 'initial' (default):
If
+ * the connector does not detect any offsets for the logical server
+ * name, it runs a snapshot that captures the current full state of the
+ * configured tables. After the snapshot completes, the connector
begins
+ * to stream changes from the oplog. 'never': The connector does not
run
+ * a snapshot. Upon first startup, the connector immediately begins
+ * reading from the beginning of the oplog.
*
* The option is a: <code>java.lang.String</code> type.
*
@@ -996,6 +1065,23 @@ public interface DebeziumMongodbComponentBuilderFactory {
doSetProperty("snapshotMode", snapshotMode);
return this;
}
+ /**
+ * The name of the SourceInfoStructMaker class that returns SourceInfo
+ * schema and struct.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Default: io.debezium.connector.mongodb.MongoDbSourceInfoStructMaker
+ * Group: mongodb
+ *
+ * @param sourceinfoStructMaker the value to set
+ * @return the dsl builder
+ */
+ default DebeziumMongodbComponentBuilder sourceinfoStructMaker(
+ java.lang.String sourceinfoStructMaker) {
+ doSetProperty("sourceinfoStructMaker", sourceinfoStructMaker);
+ return this;
+ }
/**
* Whether delete operations should be represented by a delete event
and
* a subsequent tombstone event (true) or only by a delete event
@@ -1119,6 +1205,8 @@ public interface DebeziumMongodbComponentBuilderFactory {
case "mongodbSslEnabled":
getOrCreateConfiguration((DebeziumMongodbComponent)
component).setMongodbSslEnabled((boolean) value); return true;
case "mongodbSslInvalidHostnameAllowed":
getOrCreateConfiguration((DebeziumMongodbComponent)
component).setMongodbSslInvalidHostnameAllowed((boolean) value); return true;
case "mongodbUser":
getOrCreateConfiguration((DebeziumMongodbComponent)
component).setMongodbUser((java.lang.String) value); return true;
+ case "notificationEnabledChannels":
getOrCreateConfiguration((DebeziumMongodbComponent)
component).setNotificationEnabledChannels((java.lang.String) value); return
true;
+ case "notificationSinkTopicName":
getOrCreateConfiguration((DebeziumMongodbComponent)
component).setNotificationSinkTopicName((java.lang.String) value); return true;
case "pollIntervalMs":
getOrCreateConfiguration((DebeziumMongodbComponent)
component).setPollIntervalMs((long) value); return true;
case "provideTransactionMetadata":
getOrCreateConfiguration((DebeziumMongodbComponent)
component).setProvideTransactionMetadata((boolean) value); return true;
case "queryFetchSize":
getOrCreateConfiguration((DebeziumMongodbComponent)
component).setQueryFetchSize((int) value); return true;
@@ -1126,6 +1214,8 @@ public interface DebeziumMongodbComponentBuilderFactory {
case "schemaHistoryInternalFileFilename":
getOrCreateConfiguration((DebeziumMongodbComponent)
component).setSchemaHistoryInternalFileFilename((java.lang.String) value);
return true;
case "schemaNameAdjustmentMode":
getOrCreateConfiguration((DebeziumMongodbComponent)
component).setSchemaNameAdjustmentMode((java.lang.String) value); return true;
case "signalDataCollection":
getOrCreateConfiguration((DebeziumMongodbComponent)
component).setSignalDataCollection((java.lang.String) value); return true;
+ case "signalEnabledChannels":
getOrCreateConfiguration((DebeziumMongodbComponent)
component).setSignalEnabledChannels((java.lang.String) value); return true;
+ case "signalPollIntervalMs":
getOrCreateConfiguration((DebeziumMongodbComponent)
component).setSignalPollIntervalMs((long) value); return true;
case "skippedOperations":
getOrCreateConfiguration((DebeziumMongodbComponent)
component).setSkippedOperations((java.lang.String) value); return true;
case "snapshotCollectionFilterOverrides":
getOrCreateConfiguration((DebeziumMongodbComponent)
component).setSnapshotCollectionFilterOverrides((java.lang.String) value);
return true;
case "snapshotDelayMs":
getOrCreateConfiguration((DebeziumMongodbComponent)
component).setSnapshotDelayMs((long) value); return true;
@@ -1133,6 +1223,7 @@ public interface DebeziumMongodbComponentBuilderFactory {
case "snapshotIncludeCollectionList":
getOrCreateConfiguration((DebeziumMongodbComponent)
component).setSnapshotIncludeCollectionList((java.lang.String) value); return
true;
case "snapshotMaxThreads":
getOrCreateConfiguration((DebeziumMongodbComponent)
component).setSnapshotMaxThreads((int) value); return true;
case "snapshotMode":
getOrCreateConfiguration((DebeziumMongodbComponent)
component).setSnapshotMode((java.lang.String) value); return true;
+ case "sourceinfoStructMaker":
getOrCreateConfiguration((DebeziumMongodbComponent)
component).setSourceinfoStructMaker((java.lang.String) value); return true;
case "tombstonesOnDelete":
getOrCreateConfiguration((DebeziumMongodbComponent)
component).setTombstonesOnDelete((boolean) value); return true;
case "topicNamingStrategy":
getOrCreateConfiguration((DebeziumMongodbComponent)
component).setTopicNamingStrategy((java.lang.String) value); return true;
case "topicPrefix":
getOrCreateConfiguration((DebeziumMongodbComponent)
component).setTopicPrefix((java.lang.String) value); return true;
diff --git
a/dsl/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/DebeziumMysqlComponentBuilderFactory.java
b/dsl/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/DebeziumMysqlComponentBuilderFactory.java
index ffc80af5b3d..38b7ef22104 100644
---
a/dsl/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/DebeziumMysqlComponentBuilderFactory.java
+++
b/dsl/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/DebeziumMysqlComponentBuilderFactory.java
@@ -663,9 +663,9 @@ public interface DebeziumMysqlComponentBuilderFactory {
}
/**
* Whether to use an encrypted connection to MySQL. Options include:
- * 'disabled' (the default) to use an unencrypted connection;
- * 'preferred' to establish a secure (encrypted) connection if the
- * server supports secure connections, but fall back to an unencrypted
+ * 'disabled' to use an unencrypted connection; 'preferred' (the
+ * default) to establish a secure (encrypted) connection if the server
+ * supports secure connections, but fall back to an unencrypted
* connection otherwise; 'required' to use a secure (encrypted)
* connection, and fail if one cannot be established; 'verify_ca' like
* 'required' but additionally verify the server TLS certificate
against
@@ -676,7 +676,7 @@ public interface DebeziumMysqlComponentBuilderFactory {
*
* The option is a: <code>java.lang.String</code> type.
*
- * Default: disabled
+ * Default: preferred
* Group: mysql
*
* @param databaseSslMode the value to set
@@ -1048,7 +1048,8 @@ public interface DebeziumMysqlComponentBuilderFactory {
return this;
}
/**
- * The maximum size of chunk for incremental snapshotting.
+ * The maximum size of chunk (number of documents/rows) for incremental
+ * snapshotting.
*
* The option is a: <code>int</code> type.
*
@@ -1155,6 +1156,37 @@ public interface DebeziumMysqlComponentBuilderFactory {
doSetProperty("minRowCountToStreamResults",
minRowCountToStreamResults);
return this;
}
+ /**
+ * List of notification channels names that are enabled.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: mysql
+ *
+ * @param notificationEnabledChannels the value to set
+ * @return the dsl builder
+ */
+ default DebeziumMysqlComponentBuilder notificationEnabledChannels(
+ java.lang.String notificationEnabledChannels) {
+ doSetProperty("notificationEnabledChannels",
notificationEnabledChannels);
+ return this;
+ }
+ /**
+ * The name of the topic for the notifications. This is required in
case
+ * 'sink' is in the list of enabled channels.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: mysql
+ *
+ * @param notificationSinkTopicName the value to set
+ * @return the dsl builder
+ */
+ default DebeziumMysqlComponentBuilder notificationSinkTopicName(
+ java.lang.String notificationSinkTopicName) {
+ doSetProperty("notificationSinkTopicName",
notificationSinkTopicName);
+ return this;
+ }
/**
* Time to wait for new change events to appear after receiving no
* events, given in milliseconds. Defaults to 500 ms.
@@ -1352,6 +1384,40 @@ public interface DebeziumMysqlComponentBuilderFactory {
doSetProperty("signalDataCollection", signalDataCollection);
return this;
}
+ /**
+ * List of channels names that are enabled. Source channel is enabled
by
+ * default.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Default: source
+ * Group: mysql
+ *
+ * @param signalEnabledChannels the value to set
+ * @return the dsl builder
+ */
+ default DebeziumMysqlComponentBuilder signalEnabledChannels(
+ java.lang.String signalEnabledChannels) {
+ doSetProperty("signalEnabledChannels", signalEnabledChannels);
+ return this;
+ }
+ /**
+ * Interval for looking for new signals in registered channels, given
in
+ * milliseconds. Defaults to 5 seconds.
+ *
+ * The option is a: <code>long</code> type.
+ *
+ * Default: 5s
+ * Group: mysql
+ *
+ * @param signalPollIntervalMs the value to set
+ * @return the dsl builder
+ */
+ default DebeziumMysqlComponentBuilder signalPollIntervalMs(
+ long signalPollIntervalMs) {
+ doSetProperty("signalPollIntervalMs", signalPollIntervalMs);
+ return this;
+ }
/**
* The comma-separated list of operations to skip during streaming,
* defined as: 'c' for inserts/create; 'u' for updates; 'd' for
deletes,
@@ -1488,17 +1554,28 @@ public interface DebeziumMysqlComponentBuilderFactory {
}
/**
* The criteria for running a snapshot upon startup of the connector.
- * Options include: 'when_needed' to specify that the connector run a
- * snapshot upon startup whenever it deems it necessary; 'schema_only'
- * to only take a snapshot of the schema (table structures) but no
- * actual data; 'initial' (the default) to specify the connector can
run
- * a snapshot only when no offsets are available for the logical server
- * name; 'initial_only' same as 'initial' except the connector should
- * stop after completing the snapshot and before it would normally read
- * the binlog; and'never' to specify the connector should never run a
- * snapshot and that upon first startup the connector should read from
- * the beginning of the binlog. The 'never' mode should be used with
- * care, and only when the binlog is known to contain all history.
+ * Select one of the following snapshot options: 'when_needed': On
+ * startup, the connector runs a snapshot if one is needed.;
+ * 'schema_only': If the connector does not detect any offsets for the
+ * logical server name, it runs a snapshot that captures only the
schema
+ * (table structures), but not any table data. After the snapshot
+ * completes, the connector begins to stream changes from the binlog.;
+ * 'schema_only_recovery': The connector performs a snapshot that
+ * captures only the database schema history. The connector then
+ * transitions back to streaming. Use this setting to restore a
+ * corrupted or lost database schema history topic. Do not use if the
+ * database schema was modified after the connector stopped.; 'initial'
+ * (default): If the connector does not detect any offsets for the
+ * logical server name, it runs a snapshot that captures the current
+ * full state of the configured tables. After the snapshot completes,
+ * the connector begins to stream changes from the binlog.;
+ * 'initial_only': The connector performs a snapshot as it does for the
+ * 'initial' option, but after the connector completes the snapshot, it
+ * stops, and does not stream changes from the binlog.; 'never': The
+ * connector does not run a snapshot. Upon first startup, the connector
+ * immediately begins reading from the beginning of the binlog. The
+ * 'never' mode should be used with care, and only when the binlog is
+ * known to contain all history.
*
* The option is a: <code>java.lang.String</code> type.
*
@@ -1586,6 +1663,23 @@ public interface DebeziumMysqlComponentBuilderFactory {
doSetProperty("snapshotTablesOrderByRowCount",
snapshotTablesOrderByRowCount);
return this;
}
+ /**
+ * The name of the SourceInfoStructMaker class that returns SourceInfo
+ * schema and struct.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Default: io.debezium.connector.mysql.MySqlSourceInfoStructMaker
+ * Group: mysql
+ *
+ * @param sourceinfoStructMaker the value to set
+ * @return the dsl builder
+ */
+ default DebeziumMysqlComponentBuilder sourceinfoStructMaker(
+ java.lang.String sourceinfoStructMaker) {
+ doSetProperty("sourceinfoStructMaker", sourceinfoStructMaker);
+ return this;
+ }
/**
* A comma-separated list of regular expressions that match the
* fully-qualified names of tables to be excluded from monitoring.
@@ -1798,6 +1892,8 @@ public interface DebeziumMysqlComponentBuilderFactory {
case "maxQueueSizeInBytes":
getOrCreateConfiguration((DebeziumMySqlComponent)
component).setMaxQueueSizeInBytes((long) value); return true;
case "messageKeyColumns":
getOrCreateConfiguration((DebeziumMySqlComponent)
component).setMessageKeyColumns((java.lang.String) value); return true;
case "minRowCountToStreamResults":
getOrCreateConfiguration((DebeziumMySqlComponent)
component).setMinRowCountToStreamResults((int) value); return true;
+ case "notificationEnabledChannels":
getOrCreateConfiguration((DebeziumMySqlComponent)
component).setNotificationEnabledChannels((java.lang.String) value); return
true;
+ case "notificationSinkTopicName":
getOrCreateConfiguration((DebeziumMySqlComponent)
component).setNotificationSinkTopicName((java.lang.String) value); return true;
case "pollIntervalMs":
getOrCreateConfiguration((DebeziumMySqlComponent)
component).setPollIntervalMs((long) value); return true;
case "provideTransactionMetadata":
getOrCreateConfiguration((DebeziumMySqlComponent)
component).setProvideTransactionMetadata((boolean) value); return true;
case "queryFetchSize":
getOrCreateConfiguration((DebeziumMySqlComponent)
component).setQueryFetchSize((int) value); return true;
@@ -1809,6 +1905,8 @@ public interface DebeziumMysqlComponentBuilderFactory {
case "schemaHistoryInternalStoreOnlyCapturedTablesDdl":
getOrCreateConfiguration((DebeziumMySqlComponent)
component).setSchemaHistoryInternalStoreOnlyCapturedTablesDdl((boolean) value);
return true;
case "schemaNameAdjustmentMode":
getOrCreateConfiguration((DebeziumMySqlComponent)
component).setSchemaNameAdjustmentMode((java.lang.String) value); return true;
case "signalDataCollection":
getOrCreateConfiguration((DebeziumMySqlComponent)
component).setSignalDataCollection((java.lang.String) value); return true;
+ case "signalEnabledChannels":
getOrCreateConfiguration((DebeziumMySqlComponent)
component).setSignalEnabledChannels((java.lang.String) value); return true;
+ case "signalPollIntervalMs":
getOrCreateConfiguration((DebeziumMySqlComponent)
component).setSignalPollIntervalMs((long) value); return true;
case "skippedOperations":
getOrCreateConfiguration((DebeziumMySqlComponent)
component).setSkippedOperations((java.lang.String) value); return true;
case "snapshotDelayMs":
getOrCreateConfiguration((DebeziumMySqlComponent)
component).setSnapshotDelayMs((long) value); return true;
case "snapshotFetchSize":
getOrCreateConfiguration((DebeziumMySqlComponent)
component).setSnapshotFetchSize((int) value); return true;
@@ -1820,6 +1918,7 @@ public interface DebeziumMysqlComponentBuilderFactory {
case "snapshotNewTables":
getOrCreateConfiguration((DebeziumMySqlComponent)
component).setSnapshotNewTables((java.lang.String) value); return true;
case "snapshotSelectStatementOverrides":
getOrCreateConfiguration((DebeziumMySqlComponent)
component).setSnapshotSelectStatementOverrides((java.lang.String) value);
return true;
case "snapshotTablesOrderByRowCount":
getOrCreateConfiguration((DebeziumMySqlComponent)
component).setSnapshotTablesOrderByRowCount((java.lang.String) value); return
true;
+ case "sourceinfoStructMaker":
getOrCreateConfiguration((DebeziumMySqlComponent)
component).setSourceinfoStructMaker((java.lang.String) value); return true;
case "tableExcludeList":
getOrCreateConfiguration((DebeziumMySqlComponent)
component).setTableExcludeList((java.lang.String) value); return true;
case "tableIgnoreBuiltin":
getOrCreateConfiguration((DebeziumMySqlComponent)
component).setTableIgnoreBuiltin((boolean) value); return true;
case "tableIncludeList":
getOrCreateConfiguration((DebeziumMySqlComponent)
component).setTableIncludeList((java.lang.String) value); return true;
diff --git
a/dsl/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/DebeziumOracleComponentBuilderFactory.java
b/dsl/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/DebeziumOracleComponentBuilderFactory.java
index 5090434aa4f..8b4c5f3da6c 100644
---
a/dsl/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/DebeziumOracleComponentBuilderFactory.java
+++
b/dsl/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/DebeziumOracleComponentBuilderFactory.java
@@ -966,6 +966,65 @@ public interface DebeziumOracleComponentBuilderFactory {
doSetProperty("logMiningBufferType", logMiningBufferType);
return this;
}
+ /**
+ * The name of the flush table used by the connector, defaults to
+ * LOG_MINING_FLUSH.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Default: LOG_MINING_FLUSH
+ * Group: oracle
+ *
+ * @param logMiningFlushTableName the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleComponentBuilder logMiningFlushTableName(
+ java.lang.String logMiningFlushTableName) {
+ doSetProperty("logMiningFlushTableName", logMiningFlushTableName);
+ return this;
+ }
+ /**
+ * Specifies how the filter configuration is applied to the LogMiner
+ * database query. none - The query does not apply any schema or table
+ * filters, all filtering is at runtime by the connector. in - The
query
+ * uses SQL in-clause expressions to specify the schema or table
+ * filters. regex - The query uses Oracle REGEXP_LIKE expressions to
+ * specify the schema or table filters.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Default: none
+ * Group: oracle
+ *
+ * @param logMiningQueryFilterMode the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleComponentBuilder logMiningQueryFilterMode(
+ java.lang.String logMiningQueryFilterMode) {
+ doSetProperty("logMiningQueryFilterMode",
logMiningQueryFilterMode);
+ return this;
+ }
+ /**
+ * Debezium opens a database connection and keeps that connection open
+ * throughout the entire streaming phase. In some situations, this can
+ * lead to excessive SGA memory usage. By setting this option to 'true'
+ * (the default is 'false'), the connector will close and re-open a
+ * database connection after every detected log switch or if the
+ * log.mining.session.max.ms has been reached.
+ *
+ * The option is a: <code>boolean</code> type.
+ *
+ * Default: false
+ * Group: oracle
+ *
+ * @param logMiningRestartConnection the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleComponentBuilder logMiningRestartConnection(
+ boolean logMiningRestartConnection) {
+ doSetProperty("logMiningRestartConnection",
logMiningRestartConnection);
+ 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
@@ -1147,6 +1206,21 @@ public interface DebeziumOracleComponentBuilderFactory {
doSetProperty("logMiningUsernameExcludeList",
logMiningUsernameExcludeList);
return this;
}
+ /**
+ * Comma separated list of usernames to include from LogMiner query.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: oracle
+ *
+ * @param logMiningUsernameIncludeList the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleComponentBuilder logMiningUsernameIncludeList(
+ java.lang.String logMiningUsernameIncludeList) {
+ doSetProperty("logMiningUsernameIncludeList",
logMiningUsernameIncludeList);
+ return this;
+ }
/**
* Maximum size of each batch of source records. Defaults to 2048.
*
@@ -1220,6 +1294,37 @@ public interface DebeziumOracleComponentBuilderFactory {
doSetProperty("messageKeyColumns", messageKeyColumns);
return this;
}
+ /**
+ * List of notification channels names that are enabled.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: oracle
+ *
+ * @param notificationEnabledChannels the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleComponentBuilder notificationEnabledChannels(
+ java.lang.String notificationEnabledChannels) {
+ doSetProperty("notificationEnabledChannels",
notificationEnabledChannels);
+ return this;
+ }
+ /**
+ * The name of the topic for the notifications. This is required in
case
+ * 'sink' is in the list of enabled channels.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: oracle
+ *
+ * @param notificationSinkTopicName the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleComponentBuilder notificationSinkTopicName(
+ java.lang.String notificationSinkTopicName) {
+ doSetProperty("notificationSinkTopicName",
notificationSinkTopicName);
+ return this;
+ }
/**
* Time to wait for new change events to appear after receiving no
* events, given in milliseconds. Defaults to 500 ms.
@@ -1434,6 +1539,40 @@ public interface DebeziumOracleComponentBuilderFactory {
doSetProperty("signalDataCollection", signalDataCollection);
return this;
}
+ /**
+ * List of channels names that are enabled. Source channel is enabled
by
+ * default.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Default: source
+ * Group: oracle
+ *
+ * @param signalEnabledChannels the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleComponentBuilder signalEnabledChannels(
+ java.lang.String signalEnabledChannels) {
+ doSetProperty("signalEnabledChannels", signalEnabledChannels);
+ return this;
+ }
+ /**
+ * Interval for looking for new signals in registered channels, given
in
+ * milliseconds. Defaults to 5 seconds.
+ *
+ * The option is a: <code>long</code> type.
+ *
+ * Default: 5s
+ * Group: oracle
+ *
+ * @param signalPollIntervalMs the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleComponentBuilder signalPollIntervalMs(
+ long signalPollIntervalMs) {
+ doSetProperty("signalPollIntervalMs", signalPollIntervalMs);
+ return this;
+ }
/**
* The comma-separated list of operations to skip during streaming,
* defined as: 'c' for inserts/create; 'u' for updates; 'd' for
deletes,
@@ -1579,11 +1718,25 @@ public interface DebeziumOracleComponentBuilderFactory {
}
/**
* 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.
+ * Select one of the following snapshot options: 'always': The
connector
+ * runs a snapshot every time that it starts. After the snapshot
+ * completes, the connector begins to stream changes from the redo
+ * logs.; 'initial' (default): If the connector does not detect any
+ * offsets for the logical server name, it runs a snapshot that
captures
+ * the current full state of the configured tables. After the snapshot
+ * completes, the connector begins to stream changes from the redo
logs.
+ * 'initial_only': The connector performs a snapshot as it does for the
+ * 'initial' option, but after the connector completes the snapshot, it
+ * stops, and does not stream changes from the redo logs.;
+ * 'schema_only': If the connector does not detect any offsets for the
+ * logical server name, it runs a snapshot that captures only the
schema
+ * (table structures), but not any table data. After the snapshot
+ * completes, the connector begins to stream changes from the redo
+ * logs.; 'schema_only_recovery': The connector performs a snapshot
that
+ * captures only the database schema history. The connector then
+ * transitions to streaming from the redo logs. Use this setting to
+ * restore a corrupted or lost database schema history topic. Do not
use
+ * if the database schema was modified after the connector stopped.
*
* The option is a: <code>java.lang.String</code> type.
*
@@ -1644,6 +1797,23 @@ public interface DebeziumOracleComponentBuilderFactory {
doSetProperty("snapshotTablesOrderByRowCount",
snapshotTablesOrderByRowCount);
return this;
}
+ /**
+ * The name of the SourceInfoStructMaker class that returns SourceInfo
+ * schema and struct.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Default: io.debezium.connector.oracle.OracleSourceInfoStructMaker
+ * Group: oracle
+ *
+ * @param sourceinfoStructMaker the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleComponentBuilder sourceinfoStructMaker(
+ java.lang.String sourceinfoStructMaker) {
+ doSetProperty("sourceinfoStructMaker", sourceinfoStructMaker);
+ return this;
+ }
/**
* A comma-separated list of regular expressions that match the
* fully-qualified names of tables to be excluded from monitoring.
@@ -1850,6 +2020,9 @@ public interface DebeziumOracleComponentBuilderFactory {
case "logMiningBufferInfinispanCacheTransactions":
getOrCreateConfiguration((DebeziumOracleComponent)
component).setLogMiningBufferInfinispanCacheTransactions((java.lang.String)
value); return true;
case "logMiningBufferTransactionEventsThreshold":
getOrCreateConfiguration((DebeziumOracleComponent)
component).setLogMiningBufferTransactionEventsThreshold((long) value); return
true;
case "logMiningBufferType":
getOrCreateConfiguration((DebeziumOracleComponent)
component).setLogMiningBufferType((java.lang.String) value); return true;
+ case "logMiningFlushTableName":
getOrCreateConfiguration((DebeziumOracleComponent)
component).setLogMiningFlushTableName((java.lang.String) value); return true;
+ case "logMiningQueryFilterMode":
getOrCreateConfiguration((DebeziumOracleComponent)
component).setLogMiningQueryFilterMode((java.lang.String) value); return true;
+ case "logMiningRestartConnection":
getOrCreateConfiguration((DebeziumOracleComponent)
component).setLogMiningRestartConnection((boolean) value); return true;
case "logMiningScnGapDetectionGapSizeMin":
getOrCreateConfiguration((DebeziumOracleComponent)
component).setLogMiningScnGapDetectionGapSizeMin((long) value); return true;
case "logMiningScnGapDetectionTimeIntervalMaxMs":
getOrCreateConfiguration((DebeziumOracleComponent)
component).setLogMiningScnGapDetectionTimeIntervalMaxMs((long) value); return
true;
case "logMiningSessionMaxMs":
getOrCreateConfiguration((DebeziumOracleComponent)
component).setLogMiningSessionMaxMs((long) value); return true;
@@ -1860,10 +2033,13 @@ public interface DebeziumOracleComponentBuilderFactory {
case "logMiningStrategy":
getOrCreateConfiguration((DebeziumOracleComponent)
component).setLogMiningStrategy((java.lang.String) value); return true;
case "logMiningTransactionRetentionMs":
getOrCreateConfiguration((DebeziumOracleComponent)
component).setLogMiningTransactionRetentionMs((long) value); return true;
case "logMiningUsernameExcludeList":
getOrCreateConfiguration((DebeziumOracleComponent)
component).setLogMiningUsernameExcludeList((java.lang.String) value); return
true;
+ case "logMiningUsernameIncludeList":
getOrCreateConfiguration((DebeziumOracleComponent)
component).setLogMiningUsernameIncludeList((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 "notificationEnabledChannels":
getOrCreateConfiguration((DebeziumOracleComponent)
component).setNotificationEnabledChannels((java.lang.String) value); return
true;
+ case "notificationSinkTopicName":
getOrCreateConfiguration((DebeziumOracleComponent)
component).setNotificationSinkTopicName((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;
@@ -1876,6 +2052,8 @@ public interface DebeziumOracleComponentBuilderFactory {
case "schemaHistoryInternalStoreOnlyCapturedTablesDdl":
getOrCreateConfiguration((DebeziumOracleComponent)
component).setSchemaHistoryInternalStoreOnlyCapturedTablesDdl((boolean) value);
return true;
case "schemaNameAdjustmentMode":
getOrCreateConfiguration((DebeziumOracleComponent)
component).setSchemaNameAdjustmentMode((java.lang.String) value); return true;
case "signalDataCollection":
getOrCreateConfiguration((DebeziumOracleComponent)
component).setSignalDataCollection((java.lang.String) value); return true;
+ case "signalEnabledChannels":
getOrCreateConfiguration((DebeziumOracleComponent)
component).setSignalEnabledChannels((java.lang.String) value); return true;
+ case "signalPollIntervalMs":
getOrCreateConfiguration((DebeziumOracleComponent)
component).setSignalPollIntervalMs((long) 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;
@@ -1887,6 +2065,7 @@ public interface DebeziumOracleComponentBuilderFactory {
case "snapshotMode":
getOrCreateConfiguration((DebeziumOracleComponent)
component).setSnapshotMode((java.lang.String) value); return true;
case "snapshotSelectStatementOverrides":
getOrCreateConfiguration((DebeziumOracleComponent)
component).setSnapshotSelectStatementOverrides((java.lang.String) value);
return true;
case "snapshotTablesOrderByRowCount":
getOrCreateConfiguration((DebeziumOracleComponent)
component).setSnapshotTablesOrderByRowCount((java.lang.String) value); return
true;
+ case "sourceinfoStructMaker":
getOrCreateConfiguration((DebeziumOracleComponent)
component).setSourceinfoStructMaker((java.lang.String) value); return true;
case "tableExcludeList":
getOrCreateConfiguration((DebeziumOracleComponent)
component).setTableExcludeList((java.lang.String) value); return true;
case "tableIncludeList":
getOrCreateConfiguration((DebeziumOracleComponent)
component).setTableIncludeList((java.lang.String) value); return true;
case "timePrecisionMode":
getOrCreateConfiguration((DebeziumOracleComponent)
component).setTimePrecisionMode((java.lang.String) value); return true;
diff --git
a/dsl/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/DebeziumPostgresComponentBuilderFactory.java
b/dsl/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/DebeziumPostgresComponentBuilderFactory.java
index 2510499881e..6665c642ad1 100644
---
a/dsl/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/DebeziumPostgresComponentBuilderFactory.java
+++
b/dsl/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/DebeziumPostgresComponentBuilderFactory.java
@@ -518,18 +518,21 @@ public interface DebeziumPostgresComponentBuilderFactory {
}
/**
* Whether to use an encrypted connection to Postgres. Options include:
- * 'disable' (the default) to use an unencrypted connection; 'require'
- * to use a secure (encrypted) connection, and fail if one cannot be
- * established; 'verify-ca' like 'required' but additionally verify the
- * server TLS certificate against the configured Certificate Authority
- * (CA) certificates, or fail if no valid matching CA certificates are
- * found; or 'verify-full' like 'verify-ca' but additionally verify
that
- * the server certificate matches the host to which the connection is
- * attempted.
+ * 'disable' (the default) to use an unencrypted connection; 'allow' to
+ * try and use an unencrypted connection first and, failing that, a
+ * secure (encrypted) connection; 'prefer' (the default) to try and use
+ * a secure (encrypted) connection first and, failing that, an
+ * unencrypted connection; 'require' to use a secure (encrypted)
+ * connection, and fail if one cannot be established; 'verify-ca' like
+ * 'required' but additionally verify the server TLS certificate
against
+ * the configured Certificate Authority (CA) certificates, or fail if
no
+ * valid matching CA certificates are found; or 'verify-full' like
+ * 'verify-ca' but additionally verify that the server certificate
+ * matches the host to which the connection is attempted.
*
* The option is a: <code>java.lang.String</code> type.
*
- * Default: disable
+ * Default: prefer
* Group: postgres
*
* @param databaseSslmode the value to set
@@ -793,7 +796,8 @@ public interface DebeziumPostgresComponentBuilderFactory {
return this;
}
/**
- * The maximum size of chunk for incremental snapshotting.
+ * The maximum size of chunk (number of documents/rows) for incremental
+ * snapshotting.
*
* The option is a: <code>int</code> type.
*
@@ -933,6 +937,37 @@ public interface DebeziumPostgresComponentBuilderFactory {
doSetProperty("messagePrefixIncludeList",
messagePrefixIncludeList);
return this;
}
+ /**
+ * List of notification channels names that are enabled.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: postgres
+ *
+ * @param notificationEnabledChannels the value to set
+ * @return the dsl builder
+ */
+ default DebeziumPostgresComponentBuilder notificationEnabledChannels(
+ java.lang.String notificationEnabledChannels) {
+ doSetProperty("notificationEnabledChannels",
notificationEnabledChannels);
+ return this;
+ }
+ /**
+ * The name of the topic for the notifications. This is required in
case
+ * 'sink' is in the list of enabled channels.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: postgres
+ *
+ * @param notificationSinkTopicName the value to set
+ * @return the dsl builder
+ */
+ default DebeziumPostgresComponentBuilder notificationSinkTopicName(
+ java.lang.String notificationSinkTopicName) {
+ doSetProperty("notificationSinkTopicName",
notificationSinkTopicName);
+ return this;
+ }
/**
* The name of the Postgres logical decoding plugin installed on the
* server. Supported values are 'decoderbufs' and 'pgoutput'. Defaults
@@ -1047,6 +1082,35 @@ public interface DebeziumPostgresComponentBuilderFactory
{
doSetProperty("queryFetchSize", queryFetchSize);
return this;
}
+ /**
+ * Applies only when streaming changes using pgoutput.Determines the
+ * value for Replica Identity at table level. This option will
overwrite
+ * the existing value in databaseA comma-separated list of regular
+ * expressions that match fully-qualified tables and Replica Identity
+ * value to be used in the table. Each expression must match the
pattern
+ * ':', where the table names could be defined as
+ * (SCHEMA_NAME.TABLE_NAME), and the replica identity values are:
+ * DEFAULT - Records the old values of the columns of the primary key,
+ * if any. This is the default for non-system tables.INDEX index_name -
+ * Records the old values of the columns covered by the named index,
+ * that must be unique, not partial, not deferrable, and include only
+ * columns marked NOT NULL. If this index is dropped, the behavior is
+ * the same as NOTHING.FULL - Records the old values of all columns in
+ * the row.NOTHING - Records no information about the old row. This is
+ * the default for system tables.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: postgres
+ *
+ * @param replicaIdentityAutosetValues the value to set
+ * @return the dsl builder
+ */
+ default DebeziumPostgresComponentBuilder replicaIdentityAutosetValues(
+ java.lang.String replicaIdentityAutosetValues) {
+ doSetProperty("replicaIdentityAutosetValues",
replicaIdentityAutosetValues);
+ return this;
+ }
/**
* Time to wait before restarting connector after retriable exception
* occurs. Defaults to 10000ms.
@@ -1175,6 +1239,40 @@ public interface DebeziumPostgresComponentBuilderFactory
{
doSetProperty("signalDataCollection", signalDataCollection);
return this;
}
+ /**
+ * List of channels names that are enabled. Source channel is enabled
by
+ * default.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Default: source
+ * Group: postgres
+ *
+ * @param signalEnabledChannels the value to set
+ * @return the dsl builder
+ */
+ default DebeziumPostgresComponentBuilder signalEnabledChannels(
+ java.lang.String signalEnabledChannels) {
+ doSetProperty("signalEnabledChannels", signalEnabledChannels);
+ return this;
+ }
+ /**
+ * Interval for looking for new signals in registered channels, given
in
+ * milliseconds. Defaults to 5 seconds.
+ *
+ * The option is a: <code>long</code> type.
+ *
+ * Default: 5s
+ * Group: postgres
+ *
+ * @param signalPollIntervalMs the value to set
+ * @return the dsl builder
+ */
+ default DebeziumPostgresComponentBuilder signalPollIntervalMs(
+ long signalPollIntervalMs) {
+ doSetProperty("signalPollIntervalMs", signalPollIntervalMs);
+ return this;
+ }
/**
* The comma-separated list of operations to skip during streaming,
* defined as: 'c' for inserts/create; 'u' for updates; 'd' for
deletes,
@@ -1386,17 +1484,23 @@ public interface
DebeziumPostgresComponentBuilderFactory {
}
/**
* The criteria for running a snapshot upon startup of the connector.
- * Options include: 'always' to specify that the connector run a
- * snapshot each time it starts up; 'initial' (the default) to specify
- * the connector can run a snapshot only when no offsets are available
- * for the logical server name; 'initial_only' same as 'initial' except
- * the connector should stop after completing the snapshot and before
it
- * would normally start emitting changes;'never' to specify the
- * connector should never run a snapshot and that upon first startup
the
- * connector should read from the last position (LSN) recorded by the
- * server; and'exported' deprecated, use 'initial' instead; 'custom' to
- * specify a custom class with 'snapshot.custom_class' which will be
- * loaded and used to determine the snapshot, see docs for more
details.
+ * Select one of the following snapshot options: 'always': The
connector
+ * runs a snapshot every time that it starts. After the snapshot
+ * completes, the connector begins to stream changes from the
+ * transaction log.; 'initial' (default): If the connector does not
+ * detect any offsets for the logical server name, it runs a snapshot
+ * that captures the current full state of the configured tables. After
+ * the snapshot completes, the connector begins to stream changes from
+ * the transaction log. 'initial_only': The connector performs a
+ * snapshot as it does for the 'initial' option, but after the
connector
+ * completes the snapshot, it stops, and does not stream changes from
+ * the transaction log.; 'never': The connector does not run a
snapshot.
+ * Upon first startup, the connector immediately begins reading from
the
+ * beginning of the transaction log. 'exported': This option is
+ * deprecated; use 'initial' instead.; 'custom': The connector loads a
+ * custom class to specify how the connector performs snapshots. For
+ * more information, see Custom snapshotter SPI in the PostgreSQL
+ * connector documentation.
*
* The option is a: <code>java.lang.String</code> type.
*
@@ -1457,6 +1561,24 @@ public interface DebeziumPostgresComponentBuilderFactory
{
doSetProperty("snapshotTablesOrderByRowCount",
snapshotTablesOrderByRowCount);
return this;
}
+ /**
+ * The name of the SourceInfoStructMaker class that returns SourceInfo
+ * schema and struct.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Default:
+ * io.debezium.connector.postgresql.PostgresSourceInfoStructMaker
+ * Group: postgres
+ *
+ * @param sourceinfoStructMaker the value to set
+ * @return the dsl builder
+ */
+ default DebeziumPostgresComponentBuilder sourceinfoStructMaker(
+ java.lang.String sourceinfoStructMaker) {
+ doSetProperty("sourceinfoStructMaker", sourceinfoStructMaker);
+ return this;
+ }
/**
* Frequency for sending replication connection status updates to the
* server, given in milliseconds. Defaults to 10 seconds (10,000 ms).
@@ -1718,12 +1840,15 @@ public interface
DebeziumPostgresComponentBuilderFactory {
case "messageKeyColumns":
getOrCreateConfiguration((DebeziumPostgresComponent)
component).setMessageKeyColumns((java.lang.String) value); return true;
case "messagePrefixExcludeList":
getOrCreateConfiguration((DebeziumPostgresComponent)
component).setMessagePrefixExcludeList((java.lang.String) value); return true;
case "messagePrefixIncludeList":
getOrCreateConfiguration((DebeziumPostgresComponent)
component).setMessagePrefixIncludeList((java.lang.String) value); return true;
+ case "notificationEnabledChannels":
getOrCreateConfiguration((DebeziumPostgresComponent)
component).setNotificationEnabledChannels((java.lang.String) value); return
true;
+ case "notificationSinkTopicName":
getOrCreateConfiguration((DebeziumPostgresComponent)
component).setNotificationSinkTopicName((java.lang.String) value); return true;
case "pluginName":
getOrCreateConfiguration((DebeziumPostgresComponent)
component).setPluginName((java.lang.String) value); return true;
case "pollIntervalMs":
getOrCreateConfiguration((DebeziumPostgresComponent)
component).setPollIntervalMs((long) value); return true;
case "provideTransactionMetadata":
getOrCreateConfiguration((DebeziumPostgresComponent)
component).setProvideTransactionMetadata((boolean) value); return true;
case "publicationAutocreateMode":
getOrCreateConfiguration((DebeziumPostgresComponent)
component).setPublicationAutocreateMode((java.lang.String) value); return true;
case "publicationName":
getOrCreateConfiguration((DebeziumPostgresComponent)
component).setPublicationName((java.lang.String) value); return true;
case "queryFetchSize":
getOrCreateConfiguration((DebeziumPostgresComponent)
component).setQueryFetchSize((int) value); return true;
+ case "replicaIdentityAutosetValues":
getOrCreateConfiguration((DebeziumPostgresComponent)
component).setReplicaIdentityAutosetValues((java.lang.String) value); return
true;
case "retriableRestartConnectorWaitMs":
getOrCreateConfiguration((DebeziumPostgresComponent)
component).setRetriableRestartConnectorWaitMs((long) value); return true;
case "schemaExcludeList":
getOrCreateConfiguration((DebeziumPostgresComponent)
component).setSchemaExcludeList((java.lang.String) value); return true;
case "schemaHistoryInternalFileFilename":
getOrCreateConfiguration((DebeziumPostgresComponent)
component).setSchemaHistoryInternalFileFilename((java.lang.String) value);
return true;
@@ -1731,6 +1856,8 @@ public interface DebeziumPostgresComponentBuilderFactory {
case "schemaNameAdjustmentMode":
getOrCreateConfiguration((DebeziumPostgresComponent)
component).setSchemaNameAdjustmentMode((java.lang.String) value); return true;
case "schemaRefreshMode":
getOrCreateConfiguration((DebeziumPostgresComponent)
component).setSchemaRefreshMode((java.lang.String) value); return true;
case "signalDataCollection":
getOrCreateConfiguration((DebeziumPostgresComponent)
component).setSignalDataCollection((java.lang.String) value); return true;
+ case "signalEnabledChannels":
getOrCreateConfiguration((DebeziumPostgresComponent)
component).setSignalEnabledChannels((java.lang.String) value); return true;
+ case "signalPollIntervalMs":
getOrCreateConfiguration((DebeziumPostgresComponent)
component).setSignalPollIntervalMs((long) value); return true;
case "skippedOperations":
getOrCreateConfiguration((DebeziumPostgresComponent)
component).setSkippedOperations((java.lang.String) value); return true;
case "slotDropOnStop":
getOrCreateConfiguration((DebeziumPostgresComponent)
component).setSlotDropOnStop((boolean) value); return true;
case "slotMaxRetries":
getOrCreateConfiguration((DebeziumPostgresComponent)
component).setSlotMaxRetries((int) value); return true;
@@ -1746,6 +1873,7 @@ public interface DebeziumPostgresComponentBuilderFactory {
case "snapshotMode":
getOrCreateConfiguration((DebeziumPostgresComponent)
component).setSnapshotMode((java.lang.String) value); return true;
case "snapshotSelectStatementOverrides":
getOrCreateConfiguration((DebeziumPostgresComponent)
component).setSnapshotSelectStatementOverrides((java.lang.String) value);
return true;
case "snapshotTablesOrderByRowCount":
getOrCreateConfiguration((DebeziumPostgresComponent)
component).setSnapshotTablesOrderByRowCount((java.lang.String) value); return
true;
+ case "sourceinfoStructMaker":
getOrCreateConfiguration((DebeziumPostgresComponent)
component).setSourceinfoStructMaker((java.lang.String) value); return true;
case "statusUpdateIntervalMs":
getOrCreateConfiguration((DebeziumPostgresComponent)
component).setStatusUpdateIntervalMs((int) value); return true;
case "tableExcludeList":
getOrCreateConfiguration((DebeziumPostgresComponent)
component).setTableExcludeList((java.lang.String) value); return true;
case "tableIgnoreBuiltin":
getOrCreateConfiguration((DebeziumPostgresComponent)
component).setTableIgnoreBuiltin((boolean) value); return true;
diff --git
a/dsl/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/DebeziumSqlserverComponentBuilderFactory.java
b/dsl/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/DebeziumSqlserverComponentBuilderFactory.java
index cbce3ac1c2f..6286d426b29 100644
---
a/dsl/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/DebeziumSqlserverComponentBuilderFactory.java
+++
b/dsl/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/DebeziumSqlserverComponentBuilderFactory.java
@@ -673,7 +673,8 @@ public interface DebeziumSqlserverComponentBuilderFactory {
return this;
}
/**
- * The maximum size of chunk for incremental snapshotting.
+ * The maximum size of chunk (number of documents/rows) for incremental
+ * snapshotting.
*
* The option is a: <code>int</code> type.
*
@@ -797,6 +798,37 @@ public interface DebeziumSqlserverComponentBuilderFactory {
doSetProperty("messageKeyColumns", messageKeyColumns);
return this;
}
+ /**
+ * List of notification channels names that are enabled.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: sqlserver
+ *
+ * @param notificationEnabledChannels the value to set
+ * @return the dsl builder
+ */
+ default DebeziumSqlserverComponentBuilder notificationEnabledChannels(
+ java.lang.String notificationEnabledChannels) {
+ doSetProperty("notificationEnabledChannels",
notificationEnabledChannels);
+ return this;
+ }
+ /**
+ * The name of the topic for the notifications. This is required in
case
+ * 'sink' is in the list of enabled channels.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: sqlserver
+ *
+ * @param notificationSinkTopicName the value to set
+ * @return the dsl builder
+ */
+ default DebeziumSqlserverComponentBuilder notificationSinkTopicName(
+ java.lang.String notificationSinkTopicName) {
+ doSetProperty("notificationSinkTopicName",
notificationSinkTopicName);
+ return this;
+ }
/**
* Time to wait for new change events to appear after receiving no
* events, given in milliseconds. Defaults to 500 ms.
@@ -996,6 +1028,40 @@ public interface DebeziumSqlserverComponentBuilderFactory
{
doSetProperty("signalDataCollection", signalDataCollection);
return this;
}
+ /**
+ * List of channels names that are enabled. Source channel is enabled
by
+ * default.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Default: source
+ * Group: sqlserver
+ *
+ * @param signalEnabledChannels the value to set
+ * @return the dsl builder
+ */
+ default DebeziumSqlserverComponentBuilder signalEnabledChannels(
+ java.lang.String signalEnabledChannels) {
+ doSetProperty("signalEnabledChannels", signalEnabledChannels);
+ return this;
+ }
+ /**
+ * Interval for looking for new signals in registered channels, given
in
+ * milliseconds. Defaults to 5 seconds.
+ *
+ * The option is a: <code>long</code> type.
+ *
+ * Default: 5s
+ * Group: sqlserver
+ *
+ * @param signalPollIntervalMs the value to set
+ * @return the dsl builder
+ */
+ default DebeziumSqlserverComponentBuilder signalPollIntervalMs(
+ long signalPollIntervalMs) {
+ doSetProperty("signalPollIntervalMs", signalPollIntervalMs);
+ return this;
+ }
/**
* The comma-separated list of operations to skip during streaming,
* defined as: 'c' for inserts/create; 'u' for updates; 'd' for
deletes,
@@ -1132,11 +1198,18 @@ public interface
DebeziumSqlserverComponentBuilderFactory {
}
/**
* 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.
+ * Select one of the following snapshot options: 'initial' (default):
If
+ * the connector does not detect any offsets for the logical server
+ * name, it runs a snapshot that captures the current full state of the
+ * configured tables. After the snapshot completes, the connector
begins
+ * to stream changes from the transaction log.; 'initial_only': The
+ * connector performs a snapshot as it does for the 'initial' option,
+ * but after the connector completes the snapshot, it stops, and does
+ * not stream changes from the transaction log.; 'schema_only': If the
+ * connector does not detect any offsets for the logical server name,
it
+ * runs a snapshot that captures only the schema (table structures),
but
+ * not any table data. After the snapshot completes, the connector
+ * begins to stream changes from the transaction log.
*
* The option is a: <code>java.lang.String</code> type.
*
@@ -1197,6 +1270,24 @@ public interface
DebeziumSqlserverComponentBuilderFactory {
doSetProperty("snapshotTablesOrderByRowCount",
snapshotTablesOrderByRowCount);
return this;
}
+ /**
+ * The name of the SourceInfoStructMaker class that returns SourceInfo
+ * schema and struct.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Default:
+ * io.debezium.connector.sqlserver.SqlServerSourceInfoStructMaker
+ * Group: sqlserver
+ *
+ * @param sourceinfoStructMaker the value to set
+ * @return the dsl builder
+ */
+ default DebeziumSqlserverComponentBuilder sourceinfoStructMaker(
+ java.lang.String sourceinfoStructMaker) {
+ doSetProperty("sourceinfoStructMaker", sourceinfoStructMaker);
+ return this;
+ }
/**
* A comma-separated list of regular expressions that match the
* fully-qualified names of tables to be excluded from monitoring.
@@ -1391,6 +1482,8 @@ public interface DebeziumSqlserverComponentBuilderFactory
{
case "maxQueueSize":
getOrCreateConfiguration((DebeziumSqlserverComponent)
component).setMaxQueueSize((int) value); return true;
case "maxQueueSizeInBytes":
getOrCreateConfiguration((DebeziumSqlserverComponent)
component).setMaxQueueSizeInBytes((long) value); return true;
case "messageKeyColumns":
getOrCreateConfiguration((DebeziumSqlserverComponent)
component).setMessageKeyColumns((java.lang.String) value); return true;
+ case "notificationEnabledChannels":
getOrCreateConfiguration((DebeziumSqlserverComponent)
component).setNotificationEnabledChannels((java.lang.String) value); return
true;
+ case "notificationSinkTopicName":
getOrCreateConfiguration((DebeziumSqlserverComponent)
component).setNotificationSinkTopicName((java.lang.String) value); return true;
case "pollIntervalMs":
getOrCreateConfiguration((DebeziumSqlserverComponent)
component).setPollIntervalMs((long) value); return true;
case "provideTransactionMetadata":
getOrCreateConfiguration((DebeziumSqlserverComponent)
component).setProvideTransactionMetadata((boolean) value); return true;
case "queryFetchSize":
getOrCreateConfiguration((DebeziumSqlserverComponent)
component).setQueryFetchSize((int) value); return true;
@@ -1402,6 +1495,8 @@ public interface DebeziumSqlserverComponentBuilderFactory
{
case "schemaHistoryInternalStoreOnlyCapturedTablesDdl":
getOrCreateConfiguration((DebeziumSqlserverComponent)
component).setSchemaHistoryInternalStoreOnlyCapturedTablesDdl((boolean) value);
return true;
case "schemaNameAdjustmentMode":
getOrCreateConfiguration((DebeziumSqlserverComponent)
component).setSchemaNameAdjustmentMode((java.lang.String) value); return true;
case "signalDataCollection":
getOrCreateConfiguration((DebeziumSqlserverComponent)
component).setSignalDataCollection((java.lang.String) value); return true;
+ case "signalEnabledChannels":
getOrCreateConfiguration((DebeziumSqlserverComponent)
component).setSignalEnabledChannels((java.lang.String) value); return true;
+ case "signalPollIntervalMs":
getOrCreateConfiguration((DebeziumSqlserverComponent)
component).setSignalPollIntervalMs((long) value); return true;
case "skippedOperations":
getOrCreateConfiguration((DebeziumSqlserverComponent)
component).setSkippedOperations((java.lang.String) value); return true;
case "snapshotDelayMs":
getOrCreateConfiguration((DebeziumSqlserverComponent)
component).setSnapshotDelayMs((long) value); return true;
case "snapshotFetchSize":
getOrCreateConfiguration((DebeziumSqlserverComponent)
component).setSnapshotFetchSize((int) value); return true;
@@ -1412,6 +1507,7 @@ public interface DebeziumSqlserverComponentBuilderFactory
{
case "snapshotMode":
getOrCreateConfiguration((DebeziumSqlserverComponent)
component).setSnapshotMode((java.lang.String) value); return true;
case "snapshotSelectStatementOverrides":
getOrCreateConfiguration((DebeziumSqlserverComponent)
component).setSnapshotSelectStatementOverrides((java.lang.String) value);
return true;
case "snapshotTablesOrderByRowCount":
getOrCreateConfiguration((DebeziumSqlserverComponent)
component).setSnapshotTablesOrderByRowCount((java.lang.String) value); return
true;
+ case "sourceinfoStructMaker":
getOrCreateConfiguration((DebeziumSqlserverComponent)
component).setSourceinfoStructMaker((java.lang.String) value); return true;
case "tableExcludeList":
getOrCreateConfiguration((DebeziumSqlserverComponent)
component).setTableExcludeList((java.lang.String) value); return true;
case "tableIgnoreBuiltin":
getOrCreateConfiguration((DebeziumSqlserverComponent)
component).setTableIgnoreBuiltin((boolean) value); return true;
case "tableIncludeList":
getOrCreateConfiguration((DebeziumSqlserverComponent)
component).setTableIncludeList((java.lang.String) value); return true;
diff --git
a/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/DebeziumDb2EndpointBuilderFactory.java
b/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/DebeziumDb2EndpointBuilderFactory.java
index d81f59be233..0de7fd67529 100644
---
a/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/DebeziumDb2EndpointBuilderFactory.java
+++
b/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/DebeziumDb2EndpointBuilderFactory.java
@@ -644,7 +644,8 @@ public interface DebeziumDb2EndpointBuilderFactory {
return this;
}
/**
- * The maximum size of chunk for incremental snapshotting.
+ * The maximum size of chunk (number of documents/rows) for incremental
+ * snapshotting.
*
* The option is a: <code>int</code> type.
*
@@ -660,7 +661,8 @@ public interface DebeziumDb2EndpointBuilderFactory {
return this;
}
/**
- * The maximum size of chunk for incremental snapshotting.
+ * The maximum size of chunk (number of documents/rows) for incremental
+ * snapshotting.
*
* The option will be converted to a <code>int</code> type.
*
@@ -798,6 +800,37 @@ public interface DebeziumDb2EndpointBuilderFactory {
doSetProperty("messageKeyColumns", messageKeyColumns);
return this;
}
+ /**
+ * List of notification channels names that are enabled.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: db2
+ *
+ * @param notificationEnabledChannels the value to set
+ * @return the dsl builder
+ */
+ default DebeziumDb2EndpointBuilder notificationEnabledChannels(
+ String notificationEnabledChannels) {
+ doSetProperty("notificationEnabledChannels",
notificationEnabledChannels);
+ return this;
+ }
+ /**
+ * The name of the topic for the notifications. This is required in
case
+ * 'sink' is in the list of enabled channels.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: db2
+ *
+ * @param notificationSinkTopicName the value to set
+ * @return the dsl builder
+ */
+ default DebeziumDb2EndpointBuilder notificationSinkTopicName(
+ String notificationSinkTopicName) {
+ doSetProperty("notificationSinkTopicName",
notificationSinkTopicName);
+ return this;
+ }
/**
* Time to wait for new change events to appear after receiving no
* events, given in milliseconds. Defaults to 500 ms.
@@ -1126,6 +1159,57 @@ public interface DebeziumDb2EndpointBuilderFactory {
doSetProperty("signalDataCollection", signalDataCollection);
return this;
}
+ /**
+ * List of channels names that are enabled. Source channel is enabled
by
+ * default.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Default: source
+ * Group: db2
+ *
+ * @param signalEnabledChannels the value to set
+ * @return the dsl builder
+ */
+ default DebeziumDb2EndpointBuilder signalEnabledChannels(
+ String signalEnabledChannels) {
+ doSetProperty("signalEnabledChannels", signalEnabledChannels);
+ return this;
+ }
+ /**
+ * Interval for looking for new signals in registered channels, given
in
+ * milliseconds. Defaults to 5 seconds.
+ *
+ * The option is a: <code>long</code> type.
+ *
+ * Default: 5s
+ * Group: db2
+ *
+ * @param signalPollIntervalMs the value to set
+ * @return the dsl builder
+ */
+ default DebeziumDb2EndpointBuilder signalPollIntervalMs(
+ long signalPollIntervalMs) {
+ doSetProperty("signalPollIntervalMs", signalPollIntervalMs);
+ return this;
+ }
+ /**
+ * Interval for looking for new signals in registered channels, given
in
+ * milliseconds. Defaults to 5 seconds.
+ *
+ * The option will be converted to a <code>long</code>
type.
+ *
+ * Default: 5s
+ * Group: db2
+ *
+ * @param signalPollIntervalMs the value to set
+ * @return the dsl builder
+ */
+ default DebeziumDb2EndpointBuilder signalPollIntervalMs(
+ String signalPollIntervalMs) {
+ doSetProperty("signalPollIntervalMs", signalPollIntervalMs);
+ return this;
+ }
/**
* The comma-separated list of operations to skip during streaming,
* defined as: 'c' for inserts/create; 'u' for updates; 'd' for
deletes,
@@ -1328,6 +1412,23 @@ public interface DebeziumDb2EndpointBuilderFactory {
doSetProperty("snapshotTablesOrderByRowCount",
snapshotTablesOrderByRowCount);
return this;
}
+ /**
+ * The name of the SourceInfoStructMaker class that returns SourceInfo
+ * schema and struct.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Default: io.debezium.connector.db2.Db2SourceInfoStructMaker
+ * Group: db2
+ *
+ * @param sourceinfoStructMaker the value to set
+ * @return the dsl builder
+ */
+ default DebeziumDb2EndpointBuilder sourceinfoStructMaker(
+ String sourceinfoStructMaker) {
+ doSetProperty("sourceinfoStructMaker", sourceinfoStructMaker);
+ return this;
+ }
/**
* A comma-separated list of regular expressions that match the
* fully-qualified names of tables to be excluded from monitoring.
diff --git
a/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/DebeziumMongodbEndpointBuilderFactory.java
b/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/DebeziumMongodbEndpointBuilderFactory.java
index 855801e5050..02c9e2e6c78 100644
---
a/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/DebeziumMongodbEndpointBuilderFactory.java
+++
b/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/DebeziumMongodbEndpointBuilderFactory.java
@@ -983,6 +983,37 @@ public interface DebeziumMongodbEndpointBuilderFactory {
doSetProperty("mongodbUser", mongodbUser);
return this;
}
+ /**
+ * List of notification channels names that are enabled.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: mongodb
+ *
+ * @param notificationEnabledChannels the value to set
+ * @return the dsl builder
+ */
+ default DebeziumMongodbEndpointBuilder notificationEnabledChannels(
+ String notificationEnabledChannels) {
+ doSetProperty("notificationEnabledChannels",
notificationEnabledChannels);
+ return this;
+ }
+ /**
+ * The name of the topic for the notifications. This is required in
case
+ * 'sink' is in the list of enabled channels.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: mongodb
+ *
+ * @param notificationSinkTopicName the value to set
+ * @return the dsl builder
+ */
+ default DebeziumMongodbEndpointBuilder notificationSinkTopicName(
+ String notificationSinkTopicName) {
+ doSetProperty("notificationSinkTopicName",
notificationSinkTopicName);
+ return this;
+ }
/**
* Time to wait for new change events to appear after receiving no
* events, given in milliseconds. Defaults to 500 ms.
@@ -1171,6 +1202,57 @@ public interface DebeziumMongodbEndpointBuilderFactory {
doSetProperty("signalDataCollection", signalDataCollection);
return this;
}
+ /**
+ * List of channels names that are enabled. Source channel is enabled
by
+ * default.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Default: source
+ * Group: mongodb
+ *
+ * @param signalEnabledChannels the value to set
+ * @return the dsl builder
+ */
+ default DebeziumMongodbEndpointBuilder signalEnabledChannels(
+ String signalEnabledChannels) {
+ doSetProperty("signalEnabledChannels", signalEnabledChannels);
+ return this;
+ }
+ /**
+ * Interval for looking for new signals in registered channels, given
in
+ * milliseconds. Defaults to 5 seconds.
+ *
+ * The option is a: <code>long</code> type.
+ *
+ * Default: 5s
+ * Group: mongodb
+ *
+ * @param signalPollIntervalMs the value to set
+ * @return the dsl builder
+ */
+ default DebeziumMongodbEndpointBuilder signalPollIntervalMs(
+ long signalPollIntervalMs) {
+ doSetProperty("signalPollIntervalMs", signalPollIntervalMs);
+ return this;
+ }
+ /**
+ * Interval for looking for new signals in registered channels, given
in
+ * milliseconds. Defaults to 5 seconds.
+ *
+ * The option will be converted to a <code>long</code>
type.
+ *
+ * Default: 5s
+ * Group: mongodb
+ *
+ * @param signalPollIntervalMs the value to set
+ * @return the dsl builder
+ */
+ default DebeziumMongodbEndpointBuilder signalPollIntervalMs(
+ String signalPollIntervalMs) {
+ doSetProperty("signalPollIntervalMs", signalPollIntervalMs);
+ return this;
+ }
/**
* The comma-separated list of operations to skip during streaming,
* defined as: 'c' for inserts/create; 'u' for updates; 'd' for
deletes,
@@ -1326,9 +1408,13 @@ public interface DebeziumMongodbEndpointBuilderFactory {
}
/**
* The criteria for running a snapshot upon startup of the connector.
- * Options include: 'initial' (the default) to specify the connector
- * should always perform an initial sync when required; 'never' to
- * specify the connector should never perform an initial sync.
+ * Select one of the following snapshot options: 'initial' (default):
If
+ * the connector does not detect any offsets for the logical server
+ * name, it runs a snapshot that captures the current full state of the
+ * configured tables. After the snapshot completes, the connector
begins
+ * to stream changes from the oplog. 'never': The connector does not
run
+ * a snapshot. Upon first startup, the connector immediately begins
+ * reading from the beginning of the oplog.
*
* The option is a: <code>java.lang.String</code> type.
*
@@ -1342,6 +1428,23 @@ public interface DebeziumMongodbEndpointBuilderFactory {
doSetProperty("snapshotMode", snapshotMode);
return this;
}
+ /**
+ * The name of the SourceInfoStructMaker class that returns SourceInfo
+ * schema and struct.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Default: io.debezium.connector.mongodb.MongoDbSourceInfoStructMaker
+ * Group: mongodb
+ *
+ * @param sourceinfoStructMaker the value to set
+ * @return the dsl builder
+ */
+ default DebeziumMongodbEndpointBuilder sourceinfoStructMaker(
+ String sourceinfoStructMaker) {
+ doSetProperty("sourceinfoStructMaker", sourceinfoStructMaker);
+ return this;
+ }
/**
* Whether delete operations should be represented by a delete event
and
* a subsequent tombstone event (true) or only by a delete event
diff --git
a/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/DebeziumMySqlEndpointBuilderFactory.java
b/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/DebeziumMySqlEndpointBuilderFactory.java
index fb367f98493..a606d389874 100644
---
a/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/DebeziumMySqlEndpointBuilderFactory.java
+++
b/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/DebeziumMySqlEndpointBuilderFactory.java
@@ -816,9 +816,9 @@ public interface DebeziumMySqlEndpointBuilderFactory {
}
/**
* Whether to use an encrypted connection to MySQL. Options include:
- * 'disabled' (the default) to use an unencrypted connection;
- * 'preferred' to establish a secure (encrypted) connection if the
- * server supports secure connections, but fall back to an unencrypted
+ * 'disabled' to use an unencrypted connection; 'preferred' (the
+ * default) to establish a secure (encrypted) connection if the server
+ * supports secure connections, but fall back to an unencrypted
* connection otherwise; 'required' to use a secure (encrypted)
* connection, and fail if one cannot be established; 'verify_ca' like
* 'required' but additionally verify the server TLS certificate
against
@@ -829,7 +829,7 @@ public interface DebeziumMySqlEndpointBuilderFactory {
*
* The option is a: <code>java.lang.String</code> type.
*
- * Default: disabled
+ * Default: preferred
* Group: mysql
*
* @param databaseSslMode the value to set
@@ -1349,7 +1349,8 @@ public interface DebeziumMySqlEndpointBuilderFactory {
return this;
}
/**
- * The maximum size of chunk for incremental snapshotting.
+ * The maximum size of chunk (number of documents/rows) for incremental
+ * snapshotting.
*
* The option is a: <code>int</code> type.
*
@@ -1365,7 +1366,8 @@ public interface DebeziumMySqlEndpointBuilderFactory {
return this;
}
/**
- * The maximum size of chunk for incremental snapshotting.
+ * The maximum size of chunk (number of documents/rows) for incremental
+ * snapshotting.
*
* The option will be converted to a <code>int</code> type.
*
@@ -1541,6 +1543,37 @@ public interface DebeziumMySqlEndpointBuilderFactory {
doSetProperty("minRowCountToStreamResults",
minRowCountToStreamResults);
return this;
}
+ /**
+ * List of notification channels names that are enabled.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: mysql
+ *
+ * @param notificationEnabledChannels the value to set
+ * @return the dsl builder
+ */
+ default DebeziumMySqlEndpointBuilder notificationEnabledChannels(
+ String notificationEnabledChannels) {
+ doSetProperty("notificationEnabledChannels",
notificationEnabledChannels);
+ return this;
+ }
+ /**
+ * The name of the topic for the notifications. This is required in
case
+ * 'sink' is in the list of enabled channels.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: mysql
+ *
+ * @param notificationSinkTopicName the value to set
+ * @return the dsl builder
+ */
+ default DebeziumMySqlEndpointBuilder notificationSinkTopicName(
+ String notificationSinkTopicName) {
+ doSetProperty("notificationSinkTopicName",
notificationSinkTopicName);
+ return this;
+ }
/**
* Time to wait for new change events to appear after receiving no
* events, given in milliseconds. Defaults to 500 ms.
@@ -1869,6 +1902,57 @@ public interface DebeziumMySqlEndpointBuilderFactory {
doSetProperty("signalDataCollection", signalDataCollection);
return this;
}
+ /**
+ * List of channels names that are enabled. Source channel is enabled
by
+ * default.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Default: source
+ * Group: mysql
+ *
+ * @param signalEnabledChannels the value to set
+ * @return the dsl builder
+ */
+ default DebeziumMySqlEndpointBuilder signalEnabledChannels(
+ String signalEnabledChannels) {
+ doSetProperty("signalEnabledChannels", signalEnabledChannels);
+ return this;
+ }
+ /**
+ * Interval for looking for new signals in registered channels, given
in
+ * milliseconds. Defaults to 5 seconds.
+ *
+ * The option is a: <code>long</code> type.
+ *
+ * Default: 5s
+ * Group: mysql
+ *
+ * @param signalPollIntervalMs the value to set
+ * @return the dsl builder
+ */
+ default DebeziumMySqlEndpointBuilder signalPollIntervalMs(
+ long signalPollIntervalMs) {
+ doSetProperty("signalPollIntervalMs", signalPollIntervalMs);
+ return this;
+ }
+ /**
+ * Interval for looking for new signals in registered channels, given
in
+ * milliseconds. Defaults to 5 seconds.
+ *
+ * The option will be converted to a <code>long</code>
type.
+ *
+ * Default: 5s
+ * Group: mysql
+ *
+ * @param signalPollIntervalMs the value to set
+ * @return the dsl builder
+ */
+ default DebeziumMySqlEndpointBuilder signalPollIntervalMs(
+ String signalPollIntervalMs) {
+ doSetProperty("signalPollIntervalMs", signalPollIntervalMs);
+ return this;
+ }
/**
* The comma-separated list of operations to skip during streaming,
* defined as: 'c' for inserts/create; 'u' for updates; 'd' for
deletes,
@@ -2073,17 +2157,28 @@ public interface DebeziumMySqlEndpointBuilderFactory {
}
/**
* The criteria for running a snapshot upon startup of the connector.
- * Options include: 'when_needed' to specify that the connector run a
- * snapshot upon startup whenever it deems it necessary; 'schema_only'
- * to only take a snapshot of the schema (table structures) but no
- * actual data; 'initial' (the default) to specify the connector can
run
- * a snapshot only when no offsets are available for the logical server
- * name; 'initial_only' same as 'initial' except the connector should
- * stop after completing the snapshot and before it would normally read
- * the binlog; and'never' to specify the connector should never run a
- * snapshot and that upon first startup the connector should read from
- * the beginning of the binlog. The 'never' mode should be used with
- * care, and only when the binlog is known to contain all history.
+ * Select one of the following snapshot options: 'when_needed': On
+ * startup, the connector runs a snapshot if one is needed.;
+ * 'schema_only': If the connector does not detect any offsets for the
+ * logical server name, it runs a snapshot that captures only the
schema
+ * (table structures), but not any table data. After the snapshot
+ * completes, the connector begins to stream changes from the binlog.;
+ * 'schema_only_recovery': The connector performs a snapshot that
+ * captures only the database schema history. The connector then
+ * transitions back to streaming. Use this setting to restore a
+ * corrupted or lost database schema history topic. Do not use if the
+ * database schema was modified after the connector stopped.; 'initial'
+ * (default): If the connector does not detect any offsets for the
+ * logical server name, it runs a snapshot that captures the current
+ * full state of the configured tables. After the snapshot completes,
+ * the connector begins to stream changes from the binlog.;
+ * 'initial_only': The connector performs a snapshot as it does for the
+ * 'initial' option, but after the connector completes the snapshot, it
+ * stops, and does not stream changes from the binlog.; 'never': The
+ * connector does not run a snapshot. Upon first startup, the connector
+ * immediately begins reading from the beginning of the binlog. The
+ * 'never' mode should be used with care, and only when the binlog is
+ * known to contain all history.
*
* The option is a: <code>java.lang.String</code> type.
*
@@ -2170,6 +2265,23 @@ public interface DebeziumMySqlEndpointBuilderFactory {
doSetProperty("snapshotTablesOrderByRowCount",
snapshotTablesOrderByRowCount);
return this;
}
+ /**
+ * The name of the SourceInfoStructMaker class that returns SourceInfo
+ * schema and struct.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Default: io.debezium.connector.mysql.MySqlSourceInfoStructMaker
+ * Group: mysql
+ *
+ * @param sourceinfoStructMaker the value to set
+ * @return the dsl builder
+ */
+ default DebeziumMySqlEndpointBuilder sourceinfoStructMaker(
+ String sourceinfoStructMaker) {
+ doSetProperty("sourceinfoStructMaker", sourceinfoStructMaker);
+ return this;
+ }
/**
* A comma-separated list of regular expressions that match the
* fully-qualified names of tables to be excluded from monitoring.
diff --git
a/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/DebeziumOracleEndpointBuilderFactory.java
b/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/DebeziumOracleEndpointBuilderFactory.java
index 0b97e5dda2c..d68944407eb 100644
---
a/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/DebeziumOracleEndpointBuilderFactory.java
+++
b/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/DebeziumOracleEndpointBuilderFactory.java
@@ -1236,6 +1236,87 @@ public interface DebeziumOracleEndpointBuilderFactory {
doSetProperty("logMiningBufferType", logMiningBufferType);
return this;
}
+ /**
+ * The name of the flush table used by the connector, defaults to
+ * LOG_MINING_FLUSH.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Default: LOG_MINING_FLUSH
+ * Group: oracle
+ *
+ * @param logMiningFlushTableName the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleEndpointBuilder logMiningFlushTableName(
+ String logMiningFlushTableName) {
+ doSetProperty("logMiningFlushTableName", logMiningFlushTableName);
+ return this;
+ }
+ /**
+ * Specifies how the filter configuration is applied to the LogMiner
+ * database query. none - The query does not apply any schema or table
+ * filters, all filtering is at runtime by the connector. in - The
query
+ * uses SQL in-clause expressions to specify the schema or table
+ * filters. regex - The query uses Oracle REGEXP_LIKE expressions to
+ * specify the schema or table filters.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Default: none
+ * Group: oracle
+ *
+ * @param logMiningQueryFilterMode the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleEndpointBuilder logMiningQueryFilterMode(
+ String logMiningQueryFilterMode) {
+ doSetProperty("logMiningQueryFilterMode",
logMiningQueryFilterMode);
+ return this;
+ }
+ /**
+ * Debezium opens a database connection and keeps that connection open
+ * throughout the entire streaming phase. In some situations, this can
+ * lead to excessive SGA memory usage. By setting this option to 'true'
+ * (the default is 'false'), the connector will close and re-open a
+ * database connection after every detected log switch or if the
+ * log.mining.session.max.ms has been reached.
+ *
+ * The option is a: <code>boolean</code> type.
+ *
+ * Default: false
+ * Group: oracle
+ *
+ * @param logMiningRestartConnection the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleEndpointBuilder logMiningRestartConnection(
+ boolean logMiningRestartConnection) {
+ doSetProperty("logMiningRestartConnection",
logMiningRestartConnection);
+ return this;
+ }
+ /**
+ * Debezium opens a database connection and keeps that connection open
+ * throughout the entire streaming phase. In some situations, this can
+ * lead to excessive SGA memory usage. By setting this option to 'true'
+ * (the default is 'false'), the connector will close and re-open a
+ * database connection after every detected log switch or if the
+ * log.mining.session.max.ms has been reached.
+ *
+ * The option will be converted to a <code>boolean</code>
+ * type.
+ *
+ * Default: false
+ * Group: oracle
+ *
+ * @param logMiningRestartConnection the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleEndpointBuilder logMiningRestartConnection(
+ String logMiningRestartConnection) {
+ doSetProperty("logMiningRestartConnection",
logMiningRestartConnection);
+ 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
@@ -1565,6 +1646,21 @@ public interface DebeziumOracleEndpointBuilderFactory {
doSetProperty("logMiningUsernameExcludeList",
logMiningUsernameExcludeList);
return this;
}
+ /**
+ * Comma separated list of usernames to include from LogMiner query.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: oracle
+ *
+ * @param logMiningUsernameIncludeList the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleEndpointBuilder logMiningUsernameIncludeList(
+ String logMiningUsernameIncludeList) {
+ doSetProperty("logMiningUsernameIncludeList",
logMiningUsernameIncludeList);
+ return this;
+ }
/**
* Maximum size of each batch of source records. Defaults to 2048.
*
@@ -1688,6 +1784,37 @@ public interface DebeziumOracleEndpointBuilderFactory {
doSetProperty("messageKeyColumns", messageKeyColumns);
return this;
}
+ /**
+ * List of notification channels names that are enabled.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: oracle
+ *
+ * @param notificationEnabledChannels the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleEndpointBuilder notificationEnabledChannels(
+ String notificationEnabledChannels) {
+ doSetProperty("notificationEnabledChannels",
notificationEnabledChannels);
+ return this;
+ }
+ /**
+ * The name of the topic for the notifications. This is required in
case
+ * 'sink' is in the list of enabled channels.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: oracle
+ *
+ * @param notificationSinkTopicName the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleEndpointBuilder notificationSinkTopicName(
+ String notificationSinkTopicName) {
+ doSetProperty("notificationSinkTopicName",
notificationSinkTopicName);
+ return this;
+ }
/**
* Time to wait for new change events to appear after receiving no
* events, given in milliseconds. Defaults to 500 ms.
@@ -2032,6 +2159,57 @@ public interface DebeziumOracleEndpointBuilderFactory {
doSetProperty("signalDataCollection", signalDataCollection);
return this;
}
+ /**
+ * List of channels names that are enabled. Source channel is enabled
by
+ * default.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Default: source
+ * Group: oracle
+ *
+ * @param signalEnabledChannels the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleEndpointBuilder signalEnabledChannels(
+ String signalEnabledChannels) {
+ doSetProperty("signalEnabledChannels", signalEnabledChannels);
+ return this;
+ }
+ /**
+ * Interval for looking for new signals in registered channels, given
in
+ * milliseconds. Defaults to 5 seconds.
+ *
+ * The option is a: <code>long</code> type.
+ *
+ * Default: 5s
+ * Group: oracle
+ *
+ * @param signalPollIntervalMs the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleEndpointBuilder signalPollIntervalMs(
+ long signalPollIntervalMs) {
+ doSetProperty("signalPollIntervalMs", signalPollIntervalMs);
+ return this;
+ }
+ /**
+ * Interval for looking for new signals in registered channels, given
in
+ * milliseconds. Defaults to 5 seconds.
+ *
+ * The option will be converted to a <code>long</code>
type.
+ *
+ * Default: 5s
+ * Group: oracle
+ *
+ * @param signalPollIntervalMs the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleEndpointBuilder signalPollIntervalMs(
+ String signalPollIntervalMs) {
+ doSetProperty("signalPollIntervalMs", signalPollIntervalMs);
+ return this;
+ }
/**
* The comma-separated list of operations to skip during streaming,
* defined as: 'c' for inserts/create; 'u' for updates; 'd' for
deletes,
@@ -2245,11 +2423,25 @@ public interface DebeziumOracleEndpointBuilderFactory {
}
/**
* 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.
+ * Select one of the following snapshot options: 'always': The
connector
+ * runs a snapshot every time that it starts. After the snapshot
+ * completes, the connector begins to stream changes from the redo
+ * logs.; 'initial' (default): If the connector does not detect any
+ * offsets for the logical server name, it runs a snapshot that
captures
+ * the current full state of the configured tables. After the snapshot
+ * completes, the connector begins to stream changes from the redo
logs.
+ * 'initial_only': The connector performs a snapshot as it does for the
+ * 'initial' option, but after the connector completes the snapshot, it
+ * stops, and does not stream changes from the redo logs.;
+ * 'schema_only': If the connector does not detect any offsets for the
+ * logical server name, it runs a snapshot that captures only the
schema
+ * (table structures), but not any table data. After the snapshot
+ * completes, the connector begins to stream changes from the redo
+ * logs.; 'schema_only_recovery': The connector performs a snapshot
that
+ * captures only the database schema history. The connector then
+ * transitions to streaming from the redo logs. Use this setting to
+ * restore a corrupted or lost database schema history topic. Do not
use
+ * if the database schema was modified after the connector stopped.
*
* The option is a: <code>java.lang.String</code> type.
*
@@ -2309,6 +2501,23 @@ public interface DebeziumOracleEndpointBuilderFactory {
doSetProperty("snapshotTablesOrderByRowCount",
snapshotTablesOrderByRowCount);
return this;
}
+ /**
+ * The name of the SourceInfoStructMaker class that returns SourceInfo
+ * schema and struct.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Default: io.debezium.connector.oracle.OracleSourceInfoStructMaker
+ * Group: oracle
+ *
+ * @param sourceinfoStructMaker the value to set
+ * @return the dsl builder
+ */
+ default DebeziumOracleEndpointBuilder sourceinfoStructMaker(
+ String sourceinfoStructMaker) {
+ doSetProperty("sourceinfoStructMaker", sourceinfoStructMaker);
+ return this;
+ }
/**
* A comma-separated list of regular expressions that match the
* fully-qualified names of tables to be excluded from monitoring.
diff --git
a/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/DebeziumPostgresEndpointBuilderFactory.java
b/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/DebeziumPostgresEndpointBuilderFactory.java
index 494f6a72e1c..75309d02f18 100644
---
a/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/DebeziumPostgresEndpointBuilderFactory.java
+++
b/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/DebeziumPostgresEndpointBuilderFactory.java
@@ -563,18 +563,21 @@ public interface DebeziumPostgresEndpointBuilderFactory {
}
/**
* Whether to use an encrypted connection to Postgres. Options include:
- * 'disable' (the default) to use an unencrypted connection; 'require'
- * to use a secure (encrypted) connection, and fail if one cannot be
- * established; 'verify-ca' like 'required' but additionally verify the
- * server TLS certificate against the configured Certificate Authority
- * (CA) certificates, or fail if no valid matching CA certificates are
- * found; or 'verify-full' like 'verify-ca' but additionally verify
that
- * the server certificate matches the host to which the connection is
- * attempted.
+ * 'disable' (the default) to use an unencrypted connection; 'allow' to
+ * try and use an unencrypted connection first and, failing that, a
+ * secure (encrypted) connection; 'prefer' (the default) to try and use
+ * a secure (encrypted) connection first and, failing that, an
+ * unencrypted connection; 'require' to use a secure (encrypted)
+ * connection, and fail if one cannot be established; 'verify-ca' like
+ * 'required' but additionally verify the server TLS certificate
against
+ * the configured Certificate Authority (CA) certificates, or fail if
no
+ * valid matching CA certificates are found; or 'verify-full' like
+ * 'verify-ca' but additionally verify that the server certificate
+ * matches the host to which the connection is attempted.
*
* The option is a: <code>java.lang.String</code> type.
*
- * Default: disable
+ * Default: prefer
* Group: postgres
*
* @param databaseSslmode the value to set
@@ -934,7 +937,8 @@ public interface DebeziumPostgresEndpointBuilderFactory {
return this;
}
/**
- * The maximum size of chunk for incremental snapshotting.
+ * The maximum size of chunk (number of documents/rows) for incremental
+ * snapshotting.
*
* The option is a: <code>int</code> type.
*
@@ -950,7 +954,8 @@ public interface DebeziumPostgresEndpointBuilderFactory {
return this;
}
/**
- * The maximum size of chunk for incremental snapshotting.
+ * The maximum size of chunk (number of documents/rows) for incremental
+ * snapshotting.
*
* The option will be converted to a <code>int</code> type.
*
@@ -1140,6 +1145,37 @@ public interface DebeziumPostgresEndpointBuilderFactory {
doSetProperty("messagePrefixIncludeList",
messagePrefixIncludeList);
return this;
}
+ /**
+ * List of notification channels names that are enabled.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: postgres
+ *
+ * @param notificationEnabledChannels the value to set
+ * @return the dsl builder
+ */
+ default DebeziumPostgresEndpointBuilder notificationEnabledChannels(
+ String notificationEnabledChannels) {
+ doSetProperty("notificationEnabledChannels",
notificationEnabledChannels);
+ return this;
+ }
+ /**
+ * The name of the topic for the notifications. This is required in
case
+ * 'sink' is in the list of enabled channels.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: postgres
+ *
+ * @param notificationSinkTopicName the value to set
+ * @return the dsl builder
+ */
+ default DebeziumPostgresEndpointBuilder notificationSinkTopicName(
+ String notificationSinkTopicName) {
+ doSetProperty("notificationSinkTopicName",
notificationSinkTopicName);
+ return this;
+ }
/**
* The name of the Postgres logical decoding plugin installed on the
* server. Supported values are 'decoderbufs' and 'pgoutput'. Defaults
@@ -1304,6 +1340,35 @@ public interface DebeziumPostgresEndpointBuilderFactory {
doSetProperty("queryFetchSize", queryFetchSize);
return this;
}
+ /**
+ * Applies only when streaming changes using pgoutput.Determines the
+ * value for Replica Identity at table level. This option will
overwrite
+ * the existing value in databaseA comma-separated list of regular
+ * expressions that match fully-qualified tables and Replica Identity
+ * value to be used in the table. Each expression must match the
pattern
+ * ':', where the table names could be defined as
+ * (SCHEMA_NAME.TABLE_NAME), and the replica identity values are:
+ * DEFAULT - Records the old values of the columns of the primary key,
+ * if any. This is the default for non-system tables.INDEX index_name -
+ * Records the old values of the columns covered by the named index,
+ * that must be unique, not partial, not deferrable, and include only
+ * columns marked NOT NULL. If this index is dropped, the behavior is
+ * the same as NOTHING.FULL - Records the old values of all columns in
+ * the row.NOTHING - Records no information about the old row. This is
+ * the default for system tables.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: postgres
+ *
+ * @param replicaIdentityAutosetValues the value to set
+ * @return the dsl builder
+ */
+ default DebeziumPostgresEndpointBuilder replicaIdentityAutosetValues(
+ String replicaIdentityAutosetValues) {
+ doSetProperty("replicaIdentityAutosetValues",
replicaIdentityAutosetValues);
+ return this;
+ }
/**
* Time to wait before restarting connector after retriable exception
* occurs. Defaults to 10000ms.
@@ -1449,6 +1514,57 @@ public interface DebeziumPostgresEndpointBuilderFactory {
doSetProperty("signalDataCollection", signalDataCollection);
return this;
}
+ /**
+ * List of channels names that are enabled. Source channel is enabled
by
+ * default.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Default: source
+ * Group: postgres
+ *
+ * @param signalEnabledChannels the value to set
+ * @return the dsl builder
+ */
+ default DebeziumPostgresEndpointBuilder signalEnabledChannels(
+ String signalEnabledChannels) {
+ doSetProperty("signalEnabledChannels", signalEnabledChannels);
+ return this;
+ }
+ /**
+ * Interval for looking for new signals in registered channels, given
in
+ * milliseconds. Defaults to 5 seconds.
+ *
+ * The option is a: <code>long</code> type.
+ *
+ * Default: 5s
+ * Group: postgres
+ *
+ * @param signalPollIntervalMs the value to set
+ * @return the dsl builder
+ */
+ default DebeziumPostgresEndpointBuilder signalPollIntervalMs(
+ long signalPollIntervalMs) {
+ doSetProperty("signalPollIntervalMs", signalPollIntervalMs);
+ return this;
+ }
+ /**
+ * Interval for looking for new signals in registered channels, given
in
+ * milliseconds. Defaults to 5 seconds.
+ *
+ * The option will be converted to a <code>long</code>
type.
+ *
+ * Default: 5s
+ * Group: postgres
+ *
+ * @param signalPollIntervalMs the value to set
+ * @return the dsl builder
+ */
+ default DebeziumPostgresEndpointBuilder signalPollIntervalMs(
+ String signalPollIntervalMs) {
+ doSetProperty("signalPollIntervalMs", signalPollIntervalMs);
+ return this;
+ }
/**
* The comma-separated list of operations to skip during streaming,
* defined as: 'c' for inserts/create; 'u' for updates; 'd' for
deletes,
@@ -1781,17 +1897,23 @@ public interface DebeziumPostgresEndpointBuilderFactory
{
}
/**
* The criteria for running a snapshot upon startup of the connector.
- * Options include: 'always' to specify that the connector run a
- * snapshot each time it starts up; 'initial' (the default) to specify
- * the connector can run a snapshot only when no offsets are available
- * for the logical server name; 'initial_only' same as 'initial' except
- * the connector should stop after completing the snapshot and before
it
- * would normally start emitting changes;'never' to specify the
- * connector should never run a snapshot and that upon first startup
the
- * connector should read from the last position (LSN) recorded by the
- * server; and'exported' deprecated, use 'initial' instead; 'custom' to
- * specify a custom class with 'snapshot.custom_class' which will be
- * loaded and used to determine the snapshot, see docs for more
details.
+ * Select one of the following snapshot options: 'always': The
connector
+ * runs a snapshot every time that it starts. After the snapshot
+ * completes, the connector begins to stream changes from the
+ * transaction log.; 'initial' (default): If the connector does not
+ * detect any offsets for the logical server name, it runs a snapshot
+ * that captures the current full state of the configured tables. After
+ * the snapshot completes, the connector begins to stream changes from
+ * the transaction log. 'initial_only': The connector performs a
+ * snapshot as it does for the 'initial' option, but after the
connector
+ * completes the snapshot, it stops, and does not stream changes from
+ * the transaction log.; 'never': The connector does not run a
snapshot.
+ * Upon first startup, the connector immediately begins reading from
the
+ * beginning of the transaction log. 'exported': This option is
+ * deprecated; use 'initial' instead.; 'custom': The connector loads a
+ * custom class to specify how the connector performs snapshots. For
+ * more information, see Custom snapshotter SPI in the PostgreSQL
+ * connector documentation.
*
* The option is a: <code>java.lang.String</code> type.
*
@@ -1851,6 +1973,24 @@ public interface DebeziumPostgresEndpointBuilderFactory {
doSetProperty("snapshotTablesOrderByRowCount",
snapshotTablesOrderByRowCount);
return this;
}
+ /**
+ * The name of the SourceInfoStructMaker class that returns SourceInfo
+ * schema and struct.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Default:
+ * io.debezium.connector.postgresql.PostgresSourceInfoStructMaker
+ * Group: postgres
+ *
+ * @param sourceinfoStructMaker the value to set
+ * @return the dsl builder
+ */
+ default DebeziumPostgresEndpointBuilder sourceinfoStructMaker(
+ String sourceinfoStructMaker) {
+ doSetProperty("sourceinfoStructMaker", sourceinfoStructMaker);
+ return this;
+ }
/**
* Frequency for sending replication connection status updates to the
* server, given in milliseconds. Defaults to 10 seconds (10,000 ms).
diff --git
a/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/DebeziumSqlserverEndpointBuilderFactory.java
b/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/DebeziumSqlserverEndpointBuilderFactory.java
index 2fe3c2f76cb..a4b83994cc8 100644
---
a/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/DebeziumSqlserverEndpointBuilderFactory.java
+++
b/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/DebeziumSqlserverEndpointBuilderFactory.java
@@ -823,7 +823,8 @@ public interface DebeziumSqlserverEndpointBuilderFactory {
return this;
}
/**
- * The maximum size of chunk for incremental snapshotting.
+ * The maximum size of chunk (number of documents/rows) for incremental
+ * snapshotting.
*
* The option is a: <code>int</code> type.
*
@@ -839,7 +840,8 @@ public interface DebeziumSqlserverEndpointBuilderFactory {
return this;
}
/**
- * The maximum size of chunk for incremental snapshotting.
+ * The maximum size of chunk (number of documents/rows) for incremental
+ * snapshotting.
*
* The option will be converted to a <code>int</code> type.
*
@@ -1052,6 +1054,37 @@ public interface DebeziumSqlserverEndpointBuilderFactory
{
doSetProperty("messageKeyColumns", messageKeyColumns);
return this;
}
+ /**
+ * List of notification channels names that are enabled.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: sqlserver
+ *
+ * @param notificationEnabledChannels the value to set
+ * @return the dsl builder
+ */
+ default DebeziumSqlserverEndpointBuilder notificationEnabledChannels(
+ String notificationEnabledChannels) {
+ doSetProperty("notificationEnabledChannels",
notificationEnabledChannels);
+ return this;
+ }
+ /**
+ * The name of the topic for the notifications. This is required in
case
+ * 'sink' is in the list of enabled channels.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: sqlserver
+ *
+ * @param notificationSinkTopicName the value to set
+ * @return the dsl builder
+ */
+ default DebeziumSqlserverEndpointBuilder notificationSinkTopicName(
+ String notificationSinkTopicName) {
+ doSetProperty("notificationSinkTopicName",
notificationSinkTopicName);
+ return this;
+ }
/**
* Time to wait for new change events to appear after receiving no
* events, given in milliseconds. Defaults to 500 ms.
@@ -1382,6 +1415,57 @@ public interface DebeziumSqlserverEndpointBuilderFactory
{
doSetProperty("signalDataCollection", signalDataCollection);
return this;
}
+ /**
+ * List of channels names that are enabled. Source channel is enabled
by
+ * default.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Default: source
+ * Group: sqlserver
+ *
+ * @param signalEnabledChannels the value to set
+ * @return the dsl builder
+ */
+ default DebeziumSqlserverEndpointBuilder signalEnabledChannels(
+ String signalEnabledChannels) {
+ doSetProperty("signalEnabledChannels", signalEnabledChannels);
+ return this;
+ }
+ /**
+ * Interval for looking for new signals in registered channels, given
in
+ * milliseconds. Defaults to 5 seconds.
+ *
+ * The option is a: <code>long</code> type.
+ *
+ * Default: 5s
+ * Group: sqlserver
+ *
+ * @param signalPollIntervalMs the value to set
+ * @return the dsl builder
+ */
+ default DebeziumSqlserverEndpointBuilder signalPollIntervalMs(
+ long signalPollIntervalMs) {
+ doSetProperty("signalPollIntervalMs", signalPollIntervalMs);
+ return this;
+ }
+ /**
+ * Interval for looking for new signals in registered channels, given
in
+ * milliseconds. Defaults to 5 seconds.
+ *
+ * The option will be converted to a <code>long</code>
type.
+ *
+ * Default: 5s
+ * Group: sqlserver
+ *
+ * @param signalPollIntervalMs the value to set
+ * @return the dsl builder
+ */
+ default DebeziumSqlserverEndpointBuilder signalPollIntervalMs(
+ String signalPollIntervalMs) {
+ doSetProperty("signalPollIntervalMs", signalPollIntervalMs);
+ return this;
+ }
/**
* The comma-separated list of operations to skip during streaming,
* defined as: 'c' for inserts/create; 'u' for updates; 'd' for
deletes,
@@ -1586,11 +1670,18 @@ public interface
DebeziumSqlserverEndpointBuilderFactory {
}
/**
* 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.
+ * Select one of the following snapshot options: 'initial' (default):
If
+ * the connector does not detect any offsets for the logical server
+ * name, it runs a snapshot that captures the current full state of the
+ * configured tables. After the snapshot completes, the connector
begins
+ * to stream changes from the transaction log.; 'initial_only': The
+ * connector performs a snapshot as it does for the 'initial' option,
+ * but after the connector completes the snapshot, it stops, and does
+ * not stream changes from the transaction log.; 'schema_only': If the
+ * connector does not detect any offsets for the logical server name,
it
+ * runs a snapshot that captures only the schema (table structures),
but
+ * not any table data. After the snapshot completes, the connector
+ * begins to stream changes from the transaction log.
*
* The option is a: <code>java.lang.String</code> type.
*
@@ -1651,6 +1742,24 @@ public interface DebeziumSqlserverEndpointBuilderFactory
{
doSetProperty("snapshotTablesOrderByRowCount",
snapshotTablesOrderByRowCount);
return this;
}
+ /**
+ * The name of the SourceInfoStructMaker class that returns SourceInfo
+ * schema and struct.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Default:
+ * io.debezium.connector.sqlserver.SqlServerSourceInfoStructMaker
+ * Group: sqlserver
+ *
+ * @param sourceinfoStructMaker the value to set
+ * @return the dsl builder
+ */
+ default DebeziumSqlserverEndpointBuilder sourceinfoStructMaker(
+ String sourceinfoStructMaker) {
+ doSetProperty("sourceinfoStructMaker", sourceinfoStructMaker);
+ return this;
+ }
/**
* A comma-separated list of regular expressions that match the
* fully-qualified names of tables to be excluded from monitoring.
diff --git a/parent/pom.xml b/parent/pom.xml
index 715abc51cc7..3372a318a77 100644
--- a/parent/pom.xml
+++ b/parent/pom.xml
@@ -124,7 +124,7 @@
<cxf-xjc-utils-version>4.0.0</cxf-xjc-utils-version>
<datasonnet-mapper-version>2.5.2-jakarta4</datasonnet-mapper-version>
<debezium-version>2.3.0.Final</debezium-version>
-
<debezium-mysql-connector-version>8.0.32</debezium-mysql-connector-version>
+
<debezium-mysql-connector-version>8.0.33</debezium-mysql-connector-version>
<depends-maven-plugin-version>1.4.0</depends-maven-plugin-version>
<derby-version>10.14.2.0</derby-version>
<digitalocean-api-client-version>2.17</digitalocean-api-client-version>
