This is an automated email from the ASF dual-hosted git repository.
oalsafi pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/camel.git
The following commit(s) were added to refs/heads/master by this push:
new deef374 CAMEL-16117: Upgrade to Debezium 1.4.1.Final
deef374 is described below
commit deef3746a04f3219de39e59ca357bfa8c1ac2722
Author: Omar Al-Safi <[email protected]>
AuthorDate: Mon Feb 1 10:22:53 2021 +0100
CAMEL-16117: Upgrade to Debezium 1.4.1.Final
---
.../catalog/docs/debezium-mongodb-component.adoc | 4 ++--
.../catalog/docs/debezium-mysql-component.adoc | 4 ++--
.../catalog/docs/debezium-postgres-component.adoc | 4 ++--
.../catalog/docs/debezium-sqlserver-component.adoc | 10 +++++----
...goDbConnectorEmbeddedDebeziumConfiguration.java | 4 ++--
.../camel/component/debezium/debezium-mongodb.json | 4 ++--
.../src/main/docs/debezium-mongodb-component.adoc | 4 ++--
...ySqlConnectorEmbeddedDebeziumConfiguration.java | 4 ++--
.../camel/component/debezium/debezium-mysql.json | 4 ++--
.../src/main/docs/debezium-mysql-component.adoc | 4 ++--
...gresConnectorEmbeddedDebeziumConfiguration.java | 4 ++--
.../component/debezium/debezium-postgres.json | 4 ++--
.../src/main/docs/debezium-postgres-component.adoc | 4 ++--
.../DebeziumSqlserverComponentConfigurer.java | 6 ++++++
.../DebeziumSqlserverEndpointConfigurer.java | 6 ++++++
.../DebeziumSqlserverEndpointUriFactory.java | 3 ++-
...rverConnectorEmbeddedDebeziumConfiguration.java | 21 +++++++++++++++++--
.../component/debezium/debezium-sqlserver.json | 6 ++++--
.../main/docs/debezium-sqlserver-component.adoc | 10 +++++----
.../DebeziumMongodbComponentBuilderFactory.java | 4 ++--
.../dsl/DebeziumMysqlComponentBuilderFactory.java | 4 ++--
.../DebeziumPostgresComponentBuilderFactory.java | 4 ++--
.../DebeziumSqlserverComponentBuilderFactory.java | 24 ++++++++++++++++++++--
.../dsl/DebeziumMongodbEndpointBuilderFactory.java | 4 ++--
.../dsl/DebeziumMySqlEndpointBuilderFactory.java | 4 ++--
.../DebeziumPostgresEndpointBuilderFactory.java | 4 ++--
.../DebeziumSqlserverEndpointBuilderFactory.java | 23 +++++++++++++++++++--
.../ROOT/pages/debezium-mongodb-component.adoc | 4 ++--
.../ROOT/pages/debezium-mysql-component.adoc | 4 ++--
.../ROOT/pages/debezium-postgres-component.adoc | 4 ++--
.../ROOT/pages/debezium-sqlserver-component.adoc | 10 +++++----
parent/pom.xml | 2 +-
32 files changed, 141 insertions(+), 64 deletions(-)
diff --git
a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/debezium-mongodb-component.adoc
b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/debezium-mongodb-component.adoc
index 9492e69..e74281a 100644
---
a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/debezium-mongodb-component.adoc
+++
b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/debezium-mongodb-component.adoc
@@ -102,7 +102,7 @@ The Debezium MongoDB Connector component supports 57
options, which are listed b
| *queryFetchSize* (mongodb) | The maximum number of records that should be
loaded into memory while streaming. A value of 0 uses the default JDBC fetch
size. | 0 | int
| *retriableRestartConnectorWait{zwsp}Ms* (mongodb) | Time to wait before
restarting connector after retriable exception occurs. Defaults to 10000ms. |
10s | long
| *sanitizeFieldNames* (mongodb) | Whether field names will be sanitized to
Avro naming conventions | false | boolean
-| *skippedOperations* (mongodb) | The comma-separated list of operations to
skip during streaming, defined as: 'i' for inserts; 'u' for updates; 'd' for
deletes. By default, no operations will be skipped. | | String
+| *skippedOperations* (mongodb) | The comma-separated list of operations to
skip during streaming, defined as: 'c' for inserts/create; 'u' for updates; 'd'
for deletes. By default, no operations will be skipped. | | String
| *snapshotCollectionFilter{zwsp}Overrides* (mongodb) | This property contains
a comma-separated list of ., for which the initial snapshot may be a subset of
data present in the data source. The subset would be defined by mongodb filter
query specified as value for property snapshot.collection.filter.override.. |
| String
| *snapshotDelayMs* (mongodb) | The number of milliseconds to delay before a
snapshot will begin. | 0ms | long
| *snapshotFetchSize* (mongodb) | The maximum number of records that should be
loaded into memory while performing a snapshot | | int
@@ -188,7 +188,7 @@ with the following path and query parameters:
| *queryFetchSize* (mongodb) | The maximum number of records that should be
loaded into memory while streaming. A value of 0 uses the default JDBC fetch
size. | 0 | int
| *retriableRestartConnectorWait{zwsp}Ms* (mongodb) | Time to wait before
restarting connector after retriable exception occurs. Defaults to 10000ms. |
10s | long
| *sanitizeFieldNames* (mongodb) | Whether field names will be sanitized to
Avro naming conventions | false | boolean
-| *skippedOperations* (mongodb) | The comma-separated list of operations to
skip during streaming, defined as: 'i' for inserts; 'u' for updates; 'd' for
deletes. By default, no operations will be skipped. | | String
+| *skippedOperations* (mongodb) | The comma-separated list of operations to
skip during streaming, defined as: 'c' for inserts/create; 'u' for updates; 'd'
for deletes. By default, no operations will be skipped. | | String
| *snapshotCollectionFilter{zwsp}Overrides* (mongodb) | This property contains
a comma-separated list of ., for which the initial snapshot may be a subset of
data present in the data source. The subset would be defined by mongodb filter
query specified as value for property snapshot.collection.filter.override.. |
| String
| *snapshotDelayMs* (mongodb) | The number of milliseconds to delay before a
snapshot will begin. | 0ms | long
| *snapshotFetchSize* (mongodb) | The maximum number of records that should be
loaded into memory while performing a snapshot | | int
diff --git
a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/debezium-mysql-component.adoc
b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/debezium-mysql-component.adoc
index 3a75099..765ca0f 100644
---
a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/debezium-mysql-component.adoc
+++
b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/debezium-mysql-component.adoc
@@ -125,7 +125,7 @@ The Debezium MySQL Connector component supports 80 options,
which are listed bel
| *maxQueueSize* (mysql) | Maximum size of the queue for change events read
from the database log but not yet recorded or forwarded. Defaults to 8192, and
should always be larger than the maximum batch size. | 8192 | int
| *messageKeyColumns* (mysql) | A semicolon-separated list of expressions that
match fully-qualified tables and column(s) to be used as message key. Each
expression must match the pattern ':',where the table names could be defined as
(DB_NAME.TABLE_NAME) or (SCHEMA_NAME.TABLE_NAME), depending on the specific
connector,and the key columns are a comma-separated list of columns
representing the custom key. For any table without an explicit key
configuration the table's primary key column(s) [...]
| *pollIntervalMs* (mysql) | Frequency in milliseconds to wait for new change
events to appear after receiving no events. Defaults to 500ms. | 500ms | long
-| *skippedOperations* (mysql) | The comma-separated list of operations to skip
during streaming, defined as: 'i' for inserts; 'u' for updates; 'd' for
deletes. By default, no operations will be skipped. | | String
+| *skippedOperations* (mysql) | The comma-separated list of operations to skip
during streaming, defined as: 'c' for inserts/create; 'u' for updates; 'd' for
deletes. By default, no operations will be skipped. | | String
| *snapshotDelayMs* (mysql) | The number of milliseconds to delay before a
snapshot will begin. | 0ms | long
| *snapshotEventsAsInserts* (mysql) | Whether or not to mark snapshot events
as normal inserts (op 'c'). If disabled, the standard functionality of emitting
these records as reads (op 'r') will be used. | true | boolean
| *snapshotFetchSize* (mysql) | The maximum number of records that should be
loaded into memory while performing a snapshot | | int
@@ -234,7 +234,7 @@ with the following path and query parameters:
| *maxQueueSize* (mysql) | Maximum size of the queue for change events read
from the database log but not yet recorded or forwarded. Defaults to 8192, and
should always be larger than the maximum batch size. | 8192 | int
| *messageKeyColumns* (mysql) | A semicolon-separated list of expressions that
match fully-qualified tables and column(s) to be used as message key. Each
expression must match the pattern ':',where the table names could be defined as
(DB_NAME.TABLE_NAME) or (SCHEMA_NAME.TABLE_NAME), depending on the specific
connector,and the key columns are a comma-separated list of columns
representing the custom key. For any table without an explicit key
configuration the table's primary key column(s) [...]
| *pollIntervalMs* (mysql) | Frequency in milliseconds to wait for new change
events to appear after receiving no events. Defaults to 500ms. | 500ms | long
-| *skippedOperations* (mysql) | The comma-separated list of operations to skip
during streaming, defined as: 'i' for inserts; 'u' for updates; 'd' for
deletes. By default, no operations will be skipped. | | String
+| *skippedOperations* (mysql) | The comma-separated list of operations to skip
during streaming, defined as: 'c' for inserts/create; 'u' for updates; 'd' for
deletes. By default, no operations will be skipped. | | String
| *snapshotDelayMs* (mysql) | The number of milliseconds to delay before a
snapshot will begin. | 0ms | long
| *snapshotEventsAsInserts* (mysql) | Whether or not to mark snapshot events
as normal inserts (op 'c'). If disabled, the standard functionality of emitting
these records as reads (op 'r') will be used. | true | boolean
| *snapshotFetchSize* (mysql) | The maximum number of records that should be
loaded into memory while performing a snapshot | | int
diff --git
a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/debezium-postgres-component.adoc
b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/debezium-postgres-component.adoc
index fe2897d..c262cd5 100644
---
a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/debezium-postgres-component.adoc
+++
b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/debezium-postgres-component.adoc
@@ -114,7 +114,7 @@ The Debezium PostgresSQL Connector component supports 87
options, which are list
| *schemaIncludeList* (postgres) | The schemas for which events should be
captured | | String
| *schemaRefreshMode* (postgres) | Specify the conditions that trigger a
refresh of the in-memory schema for a table. 'columns_diff' (the default) is
the safest mode, ensuring the in-memory schema stays in-sync with the database
table's schema at all times. 'columns_diff_exclude_unchanged_toast' instructs
the connector to refresh the in-memory schema cache if there is a discrepancy
between it and the schema derived from the incoming message, unless unchanged
TOASTable data fully accounts [...]
| *schemaWhitelist* (postgres) | The schemas for which events should be
captured (deprecated, use schema.include.list instead) | | String
-| *skippedOperations* (postgres) | The comma-separated list of operations to
skip during streaming, defined as: 'i' for inserts; 'u' for updates; 'd' for
deletes. By default, no operations will be skipped. | | String
+| *skippedOperations* (postgres) | The comma-separated list of operations to
skip during streaming, defined as: 'c' for inserts/create; 'u' for updates; 'd'
for deletes. By default, no operations will be skipped. | | String
| *slotDropOnStop* (postgres) | Whether or not to drop the logical replication
slot when the connector finishes orderlyBy default the replication is kept so
that on restart progress can resume from the last recorded location | false |
boolean
| *slotMaxRetries* (postgres) | How many times to retry connecting to a
replication slot when an attempt fails. | 6 | int
| *slotName* (postgres) | The name of the Postgres logical decoding slot
created for streaming changes from a plugin.Defaults to 'debezium | debezium |
String
@@ -230,7 +230,7 @@ with the following path and query parameters:
| *schemaIncludeList* (postgres) | The schemas for which events should be
captured | | String
| *schemaRefreshMode* (postgres) | Specify the conditions that trigger a
refresh of the in-memory schema for a table. 'columns_diff' (the default) is
the safest mode, ensuring the in-memory schema stays in-sync with the database
table's schema at all times. 'columns_diff_exclude_unchanged_toast' instructs
the connector to refresh the in-memory schema cache if there is a discrepancy
between it and the schema derived from the incoming message, unless unchanged
TOASTable data fully accounts [...]
| *schemaWhitelist* (postgres) | The schemas for which events should be
captured (deprecated, use schema.include.list instead) | | String
-| *skippedOperations* (postgres) | The comma-separated list of operations to
skip during streaming, defined as: 'i' for inserts; 'u' for updates; 'd' for
deletes. By default, no operations will be skipped. | | String
+| *skippedOperations* (postgres) | The comma-separated list of operations to
skip during streaming, defined as: 'c' for inserts/create; 'u' for updates; 'd'
for deletes. By default, no operations will be skipped. | | String
| *slotDropOnStop* (postgres) | Whether or not to drop the logical replication
slot when the connector finishes orderlyBy default the replication is kept so
that on restart progress can resume from the last recorded location | false |
boolean
| *slotMaxRetries* (postgres) | How many times to retry connecting to a
replication slot when an attempt fails. | 6 | int
| *slotName* (postgres) | The name of the Postgres logical decoding slot
created for streaming changes from a plugin.Defaults to 'debezium | debezium |
String
diff --git
a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/debezium-sqlserver-component.adoc
b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/debezium-sqlserver-component.adoc
index 021fa32..73c85f4 100644
---
a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/debezium-sqlserver-component.adoc
+++
b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/debezium-sqlserver-component.adoc
@@ -44,7 +44,7 @@ debezium-sqlserver:name[?options]
// component options: START
-The Debezium SQL Server Connector component supports 67 options, which are
listed below.
+The Debezium SQL Server Connector component supports 68 options, which are
listed below.
@@ -65,6 +65,7 @@ The Debezium SQL Server Connector component supports 67
options, which are liste
| *offsetStorageReplicationFactor* (consumer) | Replication factor used when
creating the offset storage topic. Required when offset.storage is set to the
KafkaOffsetBackingStore | | int
| *offsetStorageTopic* (consumer) | The name of the Kafka topic where offsets
are to be stored. Required when offset.storage is set to the
KafkaOffsetBackingStore. | | String
| *autowiredEnabled* (advanced) | Whether autowiring is enabled. This is used
for automatic autowiring options (the option must be marked as autowired) by
looking up in the registry to find if there is a single instance of matching
type, which then gets configured on the component. This can be used for
automatic configuring JDBC data sources, JMS connection factories, AWS Clients,
etc. | true | boolean
+| *binaryHandlingMode* (sqlserver) | Specify how binary (blob, binary, etc.)
columns should be represented in change events, including:'bytes' represents
binary data as byte array (default)'base64' represents binary data as
base64-encoded string'hex' represents binary data as hex-encoded (base16)
string | bytes | String
| *columnBlacklist* (sqlserver) | Regular expressions matching columns to
exclude from change events (deprecated, use column.exclude.list instead) | |
String
| *columnExcludeList* (sqlserver) | Regular expressions matching columns to
exclude from change events | | String
| *columnIncludeList* (sqlserver) | Regular expressions matching columns to
include in change events | | String
@@ -100,7 +101,7 @@ The Debezium SQL Server Connector component supports 67
options, which are liste
| *queryFetchSize* (sqlserver) | The maximum number of records that should be
loaded into memory while streaming. A value of 0 uses the default JDBC fetch
size. | 0 | int
| *retriableRestartConnectorWait{zwsp}Ms* (sqlserver) | Time to wait before
restarting connector after retriable exception occurs. Defaults to 10000ms. |
10s | long
| *sanitizeFieldNames* (sqlserver) | Whether field names will be sanitized to
Avro naming conventions | false | boolean
-| *skippedOperations* (sqlserver) | The comma-separated list of operations to
skip during streaming, defined as: 'i' for inserts; 'u' for updates; 'd' for
deletes. By default, no operations will be skipped. | | String
+| *skippedOperations* (sqlserver) | The comma-separated list of operations to
skip during streaming, defined as: 'c' for inserts/create; 'u' for updates; 'd'
for deletes. By default, no operations will be skipped. | | String
| *snapshotDelayMs* (sqlserver) | The number of milliseconds to delay before a
snapshot will begin. | 0ms | long
| *snapshotFetchSize* (sqlserver) | The maximum number of records that should
be loaded into memory while performing a snapshot | | int
| *snapshotIncludeCollectionList* (sqlserver) | this setting must be set to
specify a list of tables/collections whose snapshot must be taken on creating
or restarting the connector. | | String
@@ -141,7 +142,7 @@ with the following path and query parameters:
|===
-=== Query Parameters (67 parameters):
+=== Query Parameters (68 parameters):
[width="100%",cols="2,5,^1,2",options="header"]
@@ -161,6 +162,7 @@ with the following path and query parameters:
| *offsetStorageTopic* (consumer) | The name of the Kafka topic where offsets
are to be stored. Required when offset.storage is set to the
KafkaOffsetBackingStore. | | String
| *exceptionHandler* (consumer) | To let the consumer use a custom
ExceptionHandler. Notice if the option bridgeErrorHandler is enabled then this
option is not in use. By default the consumer will deal with exceptions, that
will be logged at WARN or ERROR level and ignored. | | ExceptionHandler
| *exchangePattern* (consumer) | Sets the exchange pattern when the consumer
creates an exchange. There are 3 enums and the value can be one of: InOnly,
InOut, InOptionalOut | | ExchangePattern
+| *binaryHandlingMode* (sqlserver) | Specify how binary (blob, binary, etc.)
columns should be represented in change events, including:'bytes' represents
binary data as byte array (default)'base64' represents binary data as
base64-encoded string'hex' represents binary data as hex-encoded (base16)
string | bytes | String
| *columnBlacklist* (sqlserver) | Regular expressions matching columns to
exclude from change events (deprecated, use column.exclude.list instead) | |
String
| *columnExcludeList* (sqlserver) | Regular expressions matching columns to
exclude from change events | | String
| *columnIncludeList* (sqlserver) | Regular expressions matching columns to
include in change events | | String
@@ -196,7 +198,7 @@ with the following path and query parameters:
| *queryFetchSize* (sqlserver) | The maximum number of records that should be
loaded into memory while streaming. A value of 0 uses the default JDBC fetch
size. | 0 | int
| *retriableRestartConnectorWait{zwsp}Ms* (sqlserver) | Time to wait before
restarting connector after retriable exception occurs. Defaults to 10000ms. |
10s | long
| *sanitizeFieldNames* (sqlserver) | Whether field names will be sanitized to
Avro naming conventions | false | boolean
-| *skippedOperations* (sqlserver) | The comma-separated list of operations to
skip during streaming, defined as: 'i' for inserts; 'u' for updates; 'd' for
deletes. By default, no operations will be skipped. | | String
+| *skippedOperations* (sqlserver) | The comma-separated list of operations to
skip during streaming, defined as: 'c' for inserts/create; 'u' for updates; 'd'
for deletes. By default, no operations will be skipped. | | String
| *snapshotDelayMs* (sqlserver) | The number of milliseconds to delay before a
snapshot will begin. | 0ms | long
| *snapshotFetchSize* (sqlserver) | The maximum number of records that should
be loaded into memory while performing a snapshot | | int
| *snapshotIncludeCollectionList* (sqlserver) | this setting must be set to
specify a list of tables/collections whose snapshot must be taken on creating
or restarting the connector. | | String
diff --git
a/components/camel-debezium-mongodb/src/generated/java/org/apache/camel/component/debezium/configuration/MongoDbConnectorEmbeddedDebeziumConfiguration.java
b/components/camel-debezium-mongodb/src/generated/java/org/apache/camel/component/debezium/configuration/MongoDbConnectorEmbeddedDebeziumConfiguration.java
index 0664147..264356f 100644
---
a/components/camel-debezium-mongodb/src/generated/java/org/apache/camel/component/debezium/configuration/MongoDbConnectorEmbeddedDebeziumConfiguration.java
+++
b/components/camel-debezium-mongodb/src/generated/java/org/apache/camel/component/debezium/configuration/MongoDbConnectorEmbeddedDebeziumConfiguration.java
@@ -357,8 +357,8 @@ public class MongoDbConnectorEmbeddedDebeziumConfiguration
/**
* The comma-separated list of operations to skip during streaming, defined
- * as: 'i' for inserts; 'u' for updates; 'd' for deletes. By default, no
- * operations will be skipped.
+ * as: 'c' for inserts/create; 'u' for updates; 'd' for deletes. By
default,
+ * no operations will be skipped.
*/
public void setSkippedOperations(String skippedOperations) {
this.skippedOperations = skippedOperations;
diff --git
a/components/camel-debezium-mongodb/src/generated/resources/org/apache/camel/component/debezium/debezium-mongodb.json
b/components/camel-debezium-mongodb/src/generated/resources/org/apache/camel/component/debezium/debezium-mongodb.json
index a50fa98..44fce11 100644
---
a/components/camel-debezium-mongodb/src/generated/resources/org/apache/camel/component/debezium/debezium-mongodb.json
+++
b/components/camel-debezium-mongodb/src/generated/resources/org/apache/camel/component/debezium/debezium-mongodb.json
@@ -70,7 +70,7 @@
"queryFetchSize": { "kind": "property", "displayName": "Query Fetch Size",
"group": "mongodb", "label": "consumer,mongodb", "required": false, "type":
"integer", "javaType": "int", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": 0, "configurationClass":
"org.apache.camel.component.debezium.configuration.MongoDbConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "The maximum number of
records that should be loaded in [...]
"retriableRestartConnectorWaitMs": { "kind": "property", "displayName":
"Retriable Restart Connector Wait Ms", "group": "mongodb", "label":
"consumer,mongodb", "required": false, "type": "duration", "javaType": "long",
"deprecated": false, "autowired": false, "secret": false, "defaultValue":
"10s", "configurationClass":
"org.apache.camel.component.debezium.configuration.MongoDbConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "Time to wait [...]
"sanitizeFieldNames": { "kind": "property", "displayName": "Sanitize Field
Names", "group": "mongodb", "label": "consumer,mongodb", "required": false,
"type": "boolean", "javaType": "boolean", "deprecated": false, "autowired":
false, "secret": false, "defaultValue": false, "configurationClass":
"org.apache.camel.component.debezium.configuration.MongoDbConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "Whether field names
will be sanitized [...]
- "skippedOperations": { "kind": "property", "displayName": "Skipped
Operations", "group": "mongodb", "label": "consumer,mongodb", "required":
false, "type": "string", "javaType": "java.lang.String", "deprecated": false,
"autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.debezium.configuration.MongoDbConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "The comma-separated
list of operations to skip during st [...]
+ "skippedOperations": { "kind": "property", "displayName": "Skipped
Operations", "group": "mongodb", "label": "consumer,mongodb", "required":
false, "type": "string", "javaType": "java.lang.String", "deprecated": false,
"autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.debezium.configuration.MongoDbConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "The comma-separated
list of operations to skip during st [...]
"snapshotCollectionFilterOverrides": { "kind": "property", "displayName":
"Snapshot Collection Filter Overrides", "group": "mongodb", "label":
"consumer,mongodb", "required": false, "type": "string", "javaType":
"java.lang.String", "deprecated": false, "autowired": false, "secret": false,
"configurationClass":
"org.apache.camel.component.debezium.configuration.MongoDbConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "This property contains
[...]
"snapshotDelayMs": { "kind": "property", "displayName": "Snapshot Delay
Ms", "group": "mongodb", "label": "consumer,mongodb", "required": false,
"type": "duration", "javaType": "long", "deprecated": false, "autowired":
false, "secret": false, "defaultValue": "0ms", "configurationClass":
"org.apache.camel.component.debezium.configuration.MongoDbConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "The number of
milliseconds to delay before a s [...]
"snapshotFetchSize": { "kind": "property", "displayName": "Snapshot Fetch
Size", "group": "mongodb", "label": "consumer,mongodb", "required": false,
"type": "integer", "javaType": "int", "deprecated": false, "autowired": false,
"secret": false, "configurationClass":
"org.apache.camel.component.debezium.configuration.MongoDbConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "The maximum number of
records that should be loaded into memory whi [...]
@@ -130,7 +130,7 @@
"queryFetchSize": { "kind": "parameter", "displayName": "Query Fetch
Size", "group": "mongodb", "label": "consumer,mongodb", "required": false,
"type": "integer", "javaType": "int", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": 0, "configurationClass":
"org.apache.camel.component.debezium.configuration.MongoDbConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "The maximum number of
records that should be loaded i [...]
"retriableRestartConnectorWaitMs": { "kind": "parameter", "displayName":
"Retriable Restart Connector Wait Ms", "group": "mongodb", "label":
"consumer,mongodb", "required": false, "type": "duration", "javaType": "long",
"deprecated": false, "autowired": false, "secret": false, "defaultValue":
"10s", "configurationClass":
"org.apache.camel.component.debezium.configuration.MongoDbConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "Time to wai [...]
"sanitizeFieldNames": { "kind": "parameter", "displayName": "Sanitize
Field Names", "group": "mongodb", "label": "consumer,mongodb", "required":
false, "type": "boolean", "javaType": "boolean", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": false,
"configurationClass":
"org.apache.camel.component.debezium.configuration.MongoDbConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "Whether field names
will be sanitized [...]
- "skippedOperations": { "kind": "parameter", "displayName": "Skipped
Operations", "group": "mongodb", "label": "consumer,mongodb", "required":
false, "type": "string", "javaType": "java.lang.String", "deprecated": false,
"autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.debezium.configuration.MongoDbConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "The comma-separated
list of operations to skip during s [...]
+ "skippedOperations": { "kind": "parameter", "displayName": "Skipped
Operations", "group": "mongodb", "label": "consumer,mongodb", "required":
false, "type": "string", "javaType": "java.lang.String", "deprecated": false,
"autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.debezium.configuration.MongoDbConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "The comma-separated
list of operations to skip during s [...]
"snapshotCollectionFilterOverrides": { "kind": "parameter", "displayName":
"Snapshot Collection Filter Overrides", "group": "mongodb", "label":
"consumer,mongodb", "required": false, "type": "string", "javaType":
"java.lang.String", "deprecated": false, "autowired": false, "secret": false,
"configurationClass":
"org.apache.camel.component.debezium.configuration.MongoDbConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "This property contain
[...]
"snapshotDelayMs": { "kind": "parameter", "displayName": "Snapshot Delay
Ms", "group": "mongodb", "label": "consumer,mongodb", "required": false,
"type": "duration", "javaType": "long", "deprecated": false, "autowired":
false, "secret": false, "defaultValue": "0ms", "configurationClass":
"org.apache.camel.component.debezium.configuration.MongoDbConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "The number of
milliseconds to delay before a [...]
"snapshotFetchSize": { "kind": "parameter", "displayName": "Snapshot Fetch
Size", "group": "mongodb", "label": "consumer,mongodb", "required": false,
"type": "integer", "javaType": "int", "deprecated": false, "autowired": false,
"secret": false, "configurationClass":
"org.apache.camel.component.debezium.configuration.MongoDbConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "The maximum number of
records that should be loaded into memory wh [...]
diff --git
a/components/camel-debezium-mongodb/src/main/docs/debezium-mongodb-component.adoc
b/components/camel-debezium-mongodb/src/main/docs/debezium-mongodb-component.adoc
index 9492e69..e74281a 100644
---
a/components/camel-debezium-mongodb/src/main/docs/debezium-mongodb-component.adoc
+++
b/components/camel-debezium-mongodb/src/main/docs/debezium-mongodb-component.adoc
@@ -102,7 +102,7 @@ The Debezium MongoDB Connector component supports 57
options, which are listed b
| *queryFetchSize* (mongodb) | The maximum number of records that should be
loaded into memory while streaming. A value of 0 uses the default JDBC fetch
size. | 0 | int
| *retriableRestartConnectorWait{zwsp}Ms* (mongodb) | Time to wait before
restarting connector after retriable exception occurs. Defaults to 10000ms. |
10s | long
| *sanitizeFieldNames* (mongodb) | Whether field names will be sanitized to
Avro naming conventions | false | boolean
-| *skippedOperations* (mongodb) | The comma-separated list of operations to
skip during streaming, defined as: 'i' for inserts; 'u' for updates; 'd' for
deletes. By default, no operations will be skipped. | | String
+| *skippedOperations* (mongodb) | The comma-separated list of operations to
skip during streaming, defined as: 'c' for inserts/create; 'u' for updates; 'd'
for deletes. By default, no operations will be skipped. | | String
| *snapshotCollectionFilter{zwsp}Overrides* (mongodb) | This property contains
a comma-separated list of ., for which the initial snapshot may be a subset of
data present in the data source. The subset would be defined by mongodb filter
query specified as value for property snapshot.collection.filter.override.. |
| String
| *snapshotDelayMs* (mongodb) | The number of milliseconds to delay before a
snapshot will begin. | 0ms | long
| *snapshotFetchSize* (mongodb) | The maximum number of records that should be
loaded into memory while performing a snapshot | | int
@@ -188,7 +188,7 @@ with the following path and query parameters:
| *queryFetchSize* (mongodb) | The maximum number of records that should be
loaded into memory while streaming. A value of 0 uses the default JDBC fetch
size. | 0 | int
| *retriableRestartConnectorWait{zwsp}Ms* (mongodb) | Time to wait before
restarting connector after retriable exception occurs. Defaults to 10000ms. |
10s | long
| *sanitizeFieldNames* (mongodb) | Whether field names will be sanitized to
Avro naming conventions | false | boolean
-| *skippedOperations* (mongodb) | The comma-separated list of operations to
skip during streaming, defined as: 'i' for inserts; 'u' for updates; 'd' for
deletes. By default, no operations will be skipped. | | String
+| *skippedOperations* (mongodb) | The comma-separated list of operations to
skip during streaming, defined as: 'c' for inserts/create; 'u' for updates; 'd'
for deletes. By default, no operations will be skipped. | | String
| *snapshotCollectionFilter{zwsp}Overrides* (mongodb) | This property contains
a comma-separated list of ., for which the initial snapshot may be a subset of
data present in the data source. The subset would be defined by mongodb filter
query specified as value for property snapshot.collection.filter.override.. |
| String
| *snapshotDelayMs* (mongodb) | The number of milliseconds to delay before a
snapshot will begin. | 0ms | long
| *snapshotFetchSize* (mongodb) | The maximum number of records that should be
loaded into memory while performing a snapshot | | int
diff --git
a/components/camel-debezium-mysql/src/generated/java/org/apache/camel/component/debezium/configuration/MySqlConnectorEmbeddedDebeziumConfiguration.java
b/components/camel-debezium-mysql/src/generated/java/org/apache/camel/component/debezium/configuration/MySqlConnectorEmbeddedDebeziumConfiguration.java
index 5ebacaf..ca75903 100644
---
a/components/camel-debezium-mysql/src/generated/java/org/apache/camel/component/debezium/configuration/MySqlConnectorEmbeddedDebeziumConfiguration.java
+++
b/components/camel-debezium-mysql/src/generated/java/org/apache/camel/component/debezium/configuration/MySqlConnectorEmbeddedDebeziumConfiguration.java
@@ -571,8 +571,8 @@ public class MySqlConnectorEmbeddedDebeziumConfiguration
/**
* The comma-separated list of operations to skip during streaming, defined
- * as: 'i' for inserts; 'u' for updates; 'd' for deletes. By default, no
- * operations will be skipped.
+ * as: 'c' for inserts/create; 'u' for updates; 'd' for deletes. By
default,
+ * no operations will be skipped.
*/
public void setSkippedOperations(String skippedOperations) {
this.skippedOperations = skippedOperations;
diff --git
a/components/camel-debezium-mysql/src/generated/resources/org/apache/camel/component/debezium/debezium-mysql.json
b/components/camel-debezium-mysql/src/generated/resources/org/apache/camel/component/debezium/debezium-mysql.json
index d9099d7..8ae5850 100644
---
a/components/camel-debezium-mysql/src/generated/resources/org/apache/camel/component/debezium/debezium-mysql.json
+++
b/components/camel-debezium-mysql/src/generated/resources/org/apache/camel/component/debezium/debezium-mysql.json
@@ -86,7 +86,7 @@
"maxQueueSize": { "kind": "property", "displayName": "Max Queue Size",
"group": "mysql", "label": "consumer,mysql", "required": false, "type":
"integer", "javaType": "int", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": 8192, "configurationClass":
"org.apache.camel.component.debezium.configuration.MySqlConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "Maximum size of the
queue for change events read from the dat [...]
"messageKeyColumns": { "kind": "property", "displayName": "Message Key
Columns", "group": "mysql", "label": "consumer,mysql", "required": false,
"type": "string", "javaType": "java.lang.String", "deprecated": false,
"autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.debezium.configuration.MySqlConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "A semicolon-separated
list of expressions that match fully-qu [...]
"pollIntervalMs": { "kind": "property", "displayName": "Poll Interval Ms",
"group": "mysql", "label": "consumer,mysql", "required": false, "type":
"duration", "javaType": "long", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": "500ms", "configurationClass":
"org.apache.camel.component.debezium.configuration.MySqlConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "Frequency in
milliseconds to wait for new change eve [...]
- "skippedOperations": { "kind": "property", "displayName": "Skipped
Operations", "group": "mysql", "label": "consumer,mysql", "required": false,
"type": "string", "javaType": "java.lang.String", "deprecated": false,
"autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.debezium.configuration.MySqlConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "The comma-separated
list of operations to skip during streamin [...]
+ "skippedOperations": { "kind": "property", "displayName": "Skipped
Operations", "group": "mysql", "label": "consumer,mysql", "required": false,
"type": "string", "javaType": "java.lang.String", "deprecated": false,
"autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.debezium.configuration.MySqlConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "The comma-separated
list of operations to skip during streamin [...]
"snapshotDelayMs": { "kind": "property", "displayName": "Snapshot Delay
Ms", "group": "mysql", "label": "consumer,mysql", "required": false, "type":
"duration", "javaType": "long", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": "0ms", "configurationClass":
"org.apache.camel.component.debezium.configuration.MySqlConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "The number of
milliseconds to delay before a snapsho [...]
"snapshotEventsAsInserts": { "kind": "property", "displayName": "Snapshot
Events As Inserts", "group": "mysql", "label": "consumer,mysql", "required":
false, "type": "boolean", "javaType": "boolean", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": true,
"configurationClass":
"org.apache.camel.component.debezium.configuration.MySqlConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "Whether or not to mark
snapshot ev [...]
"snapshotFetchSize": { "kind": "property", "displayName": "Snapshot Fetch
Size", "group": "mysql", "label": "consumer,mysql", "required": false, "type":
"integer", "javaType": "int", "deprecated": false, "autowired": false,
"secret": false, "configurationClass":
"org.apache.camel.component.debezium.configuration.MySqlConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "The maximum number of
records that should be loaded into memory while per [...]
@@ -169,7 +169,7 @@
"maxQueueSize": { "kind": "parameter", "displayName": "Max Queue Size",
"group": "mysql", "label": "consumer,mysql", "required": false, "type":
"integer", "javaType": "int", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": 8192, "configurationClass":
"org.apache.camel.component.debezium.configuration.MySqlConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "Maximum size of the
queue for change events read from the da [...]
"messageKeyColumns": { "kind": "parameter", "displayName": "Message Key
Columns", "group": "mysql", "label": "consumer,mysql", "required": false,
"type": "string", "javaType": "java.lang.String", "deprecated": false,
"autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.debezium.configuration.MySqlConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "A semicolon-separated
list of expressions that match fully-q [...]
"pollIntervalMs": { "kind": "parameter", "displayName": "Poll Interval
Ms", "group": "mysql", "label": "consumer,mysql", "required": false, "type":
"duration", "javaType": "long", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": "500ms", "configurationClass":
"org.apache.camel.component.debezium.configuration.MySqlConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "Frequency in
milliseconds to wait for new change ev [...]
- "skippedOperations": { "kind": "parameter", "displayName": "Skipped
Operations", "group": "mysql", "label": "consumer,mysql", "required": false,
"type": "string", "javaType": "java.lang.String", "deprecated": false,
"autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.debezium.configuration.MySqlConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "The comma-separated
list of operations to skip during streami [...]
+ "skippedOperations": { "kind": "parameter", "displayName": "Skipped
Operations", "group": "mysql", "label": "consumer,mysql", "required": false,
"type": "string", "javaType": "java.lang.String", "deprecated": false,
"autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.debezium.configuration.MySqlConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "The comma-separated
list of operations to skip during streami [...]
"snapshotDelayMs": { "kind": "parameter", "displayName": "Snapshot Delay
Ms", "group": "mysql", "label": "consumer,mysql", "required": false, "type":
"duration", "javaType": "long", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": "0ms", "configurationClass":
"org.apache.camel.component.debezium.configuration.MySqlConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "The number of
milliseconds to delay before a snapsh [...]
"snapshotEventsAsInserts": { "kind": "parameter", "displayName": "Snapshot
Events As Inserts", "group": "mysql", "label": "consumer,mysql", "required":
false, "type": "boolean", "javaType": "boolean", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": true,
"configurationClass":
"org.apache.camel.component.debezium.configuration.MySqlConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "Whether or not to mark
snapshot e [...]
"snapshotFetchSize": { "kind": "parameter", "displayName": "Snapshot Fetch
Size", "group": "mysql", "label": "consumer,mysql", "required": false, "type":
"integer", "javaType": "int", "deprecated": false, "autowired": false,
"secret": false, "configurationClass":
"org.apache.camel.component.debezium.configuration.MySqlConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "The maximum number of
records that should be loaded into memory while pe [...]
diff --git
a/components/camel-debezium-mysql/src/main/docs/debezium-mysql-component.adoc
b/components/camel-debezium-mysql/src/main/docs/debezium-mysql-component.adoc
index 3a75099..765ca0f 100644
---
a/components/camel-debezium-mysql/src/main/docs/debezium-mysql-component.adoc
+++
b/components/camel-debezium-mysql/src/main/docs/debezium-mysql-component.adoc
@@ -125,7 +125,7 @@ The Debezium MySQL Connector component supports 80 options,
which are listed bel
| *maxQueueSize* (mysql) | Maximum size of the queue for change events read
from the database log but not yet recorded or forwarded. Defaults to 8192, and
should always be larger than the maximum batch size. | 8192 | int
| *messageKeyColumns* (mysql) | A semicolon-separated list of expressions that
match fully-qualified tables and column(s) to be used as message key. Each
expression must match the pattern ':',where the table names could be defined as
(DB_NAME.TABLE_NAME) or (SCHEMA_NAME.TABLE_NAME), depending on the specific
connector,and the key columns are a comma-separated list of columns
representing the custom key. For any table without an explicit key
configuration the table's primary key column(s) [...]
| *pollIntervalMs* (mysql) | Frequency in milliseconds to wait for new change
events to appear after receiving no events. Defaults to 500ms. | 500ms | long
-| *skippedOperations* (mysql) | The comma-separated list of operations to skip
during streaming, defined as: 'i' for inserts; 'u' for updates; 'd' for
deletes. By default, no operations will be skipped. | | String
+| *skippedOperations* (mysql) | The comma-separated list of operations to skip
during streaming, defined as: 'c' for inserts/create; 'u' for updates; 'd' for
deletes. By default, no operations will be skipped. | | String
| *snapshotDelayMs* (mysql) | The number of milliseconds to delay before a
snapshot will begin. | 0ms | long
| *snapshotEventsAsInserts* (mysql) | Whether or not to mark snapshot events
as normal inserts (op 'c'). If disabled, the standard functionality of emitting
these records as reads (op 'r') will be used. | true | boolean
| *snapshotFetchSize* (mysql) | The maximum number of records that should be
loaded into memory while performing a snapshot | | int
@@ -234,7 +234,7 @@ with the following path and query parameters:
| *maxQueueSize* (mysql) | Maximum size of the queue for change events read
from the database log but not yet recorded or forwarded. Defaults to 8192, and
should always be larger than the maximum batch size. | 8192 | int
| *messageKeyColumns* (mysql) | A semicolon-separated list of expressions that
match fully-qualified tables and column(s) to be used as message key. Each
expression must match the pattern ':',where the table names could be defined as
(DB_NAME.TABLE_NAME) or (SCHEMA_NAME.TABLE_NAME), depending on the specific
connector,and the key columns are a comma-separated list of columns
representing the custom key. For any table without an explicit key
configuration the table's primary key column(s) [...]
| *pollIntervalMs* (mysql) | Frequency in milliseconds to wait for new change
events to appear after receiving no events. Defaults to 500ms. | 500ms | long
-| *skippedOperations* (mysql) | The comma-separated list of operations to skip
during streaming, defined as: 'i' for inserts; 'u' for updates; 'd' for
deletes. By default, no operations will be skipped. | | String
+| *skippedOperations* (mysql) | The comma-separated list of operations to skip
during streaming, defined as: 'c' for inserts/create; 'u' for updates; 'd' for
deletes. By default, no operations will be skipped. | | String
| *snapshotDelayMs* (mysql) | The number of milliseconds to delay before a
snapshot will begin. | 0ms | long
| *snapshotEventsAsInserts* (mysql) | Whether or not to mark snapshot events
as normal inserts (op 'c'). If disabled, the standard functionality of emitting
these records as reads (op 'r') will be used. | true | boolean
| *snapshotFetchSize* (mysql) | The maximum number of records that should be
loaded into memory while performing a snapshot | | int
diff --git
a/components/camel-debezium-postgres/src/generated/java/org/apache/camel/component/debezium/configuration/PostgresConnectorEmbeddedDebeziumConfiguration.java
b/components/camel-debezium-postgres/src/generated/java/org/apache/camel/component/debezium/configuration/PostgresConnectorEmbeddedDebeziumConfiguration.java
index 2c14d1f..5d24288 100644
---
a/components/camel-debezium-postgres/src/generated/java/org/apache/camel/component/debezium/configuration/PostgresConnectorEmbeddedDebeziumConfiguration.java
+++
b/components/camel-debezium-postgres/src/generated/java/org/apache/camel/component/debezium/configuration/PostgresConnectorEmbeddedDebeziumConfiguration.java
@@ -690,8 +690,8 @@ public class PostgresConnectorEmbeddedDebeziumConfiguration
/**
* The comma-separated list of operations to skip during streaming, defined
- * as: 'i' for inserts; 'u' for updates; 'd' for deletes. By default, no
- * operations will be skipped.
+ * as: 'c' for inserts/create; 'u' for updates; 'd' for deletes. By
default,
+ * no operations will be skipped.
*/
public void setSkippedOperations(String skippedOperations) {
this.skippedOperations = skippedOperations;
diff --git
a/components/camel-debezium-postgres/src/generated/resources/org/apache/camel/component/debezium/debezium-postgres.json
b/components/camel-debezium-postgres/src/generated/resources/org/apache/camel/component/debezium/debezium-postgres.json
index f5c7f6c..8ce9810 100644
---
a/components/camel-debezium-postgres/src/generated/resources/org/apache/camel/component/debezium/debezium-postgres.json
+++
b/components/camel-debezium-postgres/src/generated/resources/org/apache/camel/component/debezium/debezium-postgres.json
@@ -84,7 +84,7 @@
"schemaIncludeList": { "kind": "property", "displayName": "Schema Include
List", "group": "postgres", "label": "consumer,postgres", "required": false,
"type": "string", "javaType": "java.lang.String", "deprecated": false,
"autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.debezium.configuration.PostgresConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "The schemas for which
events should be captured" },
"schemaRefreshMode": { "kind": "property", "displayName": "Schema Refresh
Mode", "group": "postgres", "label": "consumer,postgres", "required": false,
"type": "string", "javaType": "java.lang.String", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": "columns_diff",
"configurationClass":
"org.apache.camel.component.debezium.configuration.PostgresConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "Specify the conditio
[...]
"schemaWhitelist": { "kind": "property", "displayName": "Schema
Whitelist", "group": "postgres", "label": "consumer,postgres", "required":
false, "type": "string", "javaType": "java.lang.String", "deprecated": false,
"autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.debezium.configuration.PostgresConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "The schemas for which
events should be captured (deprecat [...]
- "skippedOperations": { "kind": "property", "displayName": "Skipped
Operations", "group": "postgres", "label": "consumer,postgres", "required":
false, "type": "string", "javaType": "java.lang.String", "deprecated": false,
"autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.debezium.configuration.PostgresConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "The comma-separated
list of operations to skip during [...]
+ "skippedOperations": { "kind": "property", "displayName": "Skipped
Operations", "group": "postgres", "label": "consumer,postgres", "required":
false, "type": "string", "javaType": "java.lang.String", "deprecated": false,
"autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.debezium.configuration.PostgresConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "The comma-separated
list of operations to skip during [...]
"slotDropOnStop": { "kind": "property", "displayName": "Slot Drop On
Stop", "group": "postgres", "label": "consumer,postgres", "required": false,
"type": "boolean", "javaType": "boolean", "deprecated": false, "autowired":
false, "secret": false, "defaultValue": false, "configurationClass":
"org.apache.camel.component.debezium.configuration.PostgresConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "Whether or not to drop
the logical replica [...]
"slotMaxRetries": { "kind": "property", "displayName": "Slot Max Retries",
"group": "postgres", "label": "consumer,postgres", "required": false, "type":
"integer", "javaType": "int", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": 6, "configurationClass":
"org.apache.camel.component.debezium.configuration.PostgresConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "How many times to retry
connecting to a replication [...]
"slotName": { "kind": "property", "displayName": "Slot Name", "group":
"postgres", "label": "consumer,postgres", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": "debezium", "configurationClass":
"org.apache.camel.component.debezium.configuration.PostgresConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "The name of the
Postgres logical decoding s [...]
@@ -174,7 +174,7 @@
"schemaIncludeList": { "kind": "parameter", "displayName": "Schema Include
List", "group": "postgres", "label": "consumer,postgres", "required": false,
"type": "string", "javaType": "java.lang.String", "deprecated": false,
"autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.debezium.configuration.PostgresConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "The schemas for which
events should be captured" },
"schemaRefreshMode": { "kind": "parameter", "displayName": "Schema Refresh
Mode", "group": "postgres", "label": "consumer,postgres", "required": false,
"type": "string", "javaType": "java.lang.String", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": "columns_diff",
"configurationClass":
"org.apache.camel.component.debezium.configuration.PostgresConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "Specify the conditi
[...]
"schemaWhitelist": { "kind": "parameter", "displayName": "Schema
Whitelist", "group": "postgres", "label": "consumer,postgres", "required":
false, "type": "string", "javaType": "java.lang.String", "deprecated": false,
"autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.debezium.configuration.PostgresConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "The schemas for which
events should be captured (depreca [...]
- "skippedOperations": { "kind": "parameter", "displayName": "Skipped
Operations", "group": "postgres", "label": "consumer,postgres", "required":
false, "type": "string", "javaType": "java.lang.String", "deprecated": false,
"autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.debezium.configuration.PostgresConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "The comma-separated
list of operations to skip durin [...]
+ "skippedOperations": { "kind": "parameter", "displayName": "Skipped
Operations", "group": "postgres", "label": "consumer,postgres", "required":
false, "type": "string", "javaType": "java.lang.String", "deprecated": false,
"autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.debezium.configuration.PostgresConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "The comma-separated
list of operations to skip durin [...]
"slotDropOnStop": { "kind": "parameter", "displayName": "Slot Drop On
Stop", "group": "postgres", "label": "consumer,postgres", "required": false,
"type": "boolean", "javaType": "boolean", "deprecated": false, "autowired":
false, "secret": false, "defaultValue": false, "configurationClass":
"org.apache.camel.component.debezium.configuration.PostgresConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "Whether or not to drop
the logical replic [...]
"slotMaxRetries": { "kind": "parameter", "displayName": "Slot Max
Retries", "group": "postgres", "label": "consumer,postgres", "required": false,
"type": "integer", "javaType": "int", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": 6, "configurationClass":
"org.apache.camel.component.debezium.configuration.PostgresConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "How many times to retry
connecting to a replicatio [...]
"slotName": { "kind": "parameter", "displayName": "Slot Name", "group":
"postgres", "label": "consumer,postgres", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": "debezium", "configurationClass":
"org.apache.camel.component.debezium.configuration.PostgresConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "The name of the
Postgres logical decoding [...]
diff --git
a/components/camel-debezium-postgres/src/main/docs/debezium-postgres-component.adoc
b/components/camel-debezium-postgres/src/main/docs/debezium-postgres-component.adoc
index fe2897d..c262cd5 100644
---
a/components/camel-debezium-postgres/src/main/docs/debezium-postgres-component.adoc
+++
b/components/camel-debezium-postgres/src/main/docs/debezium-postgres-component.adoc
@@ -114,7 +114,7 @@ The Debezium PostgresSQL Connector component supports 87
options, which are list
| *schemaIncludeList* (postgres) | The schemas for which events should be
captured | | String
| *schemaRefreshMode* (postgres) | Specify the conditions that trigger a
refresh of the in-memory schema for a table. 'columns_diff' (the default) is
the safest mode, ensuring the in-memory schema stays in-sync with the database
table's schema at all times. 'columns_diff_exclude_unchanged_toast' instructs
the connector to refresh the in-memory schema cache if there is a discrepancy
between it and the schema derived from the incoming message, unless unchanged
TOASTable data fully accounts [...]
| *schemaWhitelist* (postgres) | The schemas for which events should be
captured (deprecated, use schema.include.list instead) | | String
-| *skippedOperations* (postgres) | The comma-separated list of operations to
skip during streaming, defined as: 'i' for inserts; 'u' for updates; 'd' for
deletes. By default, no operations will be skipped. | | String
+| *skippedOperations* (postgres) | The comma-separated list of operations to
skip during streaming, defined as: 'c' for inserts/create; 'u' for updates; 'd'
for deletes. By default, no operations will be skipped. | | String
| *slotDropOnStop* (postgres) | Whether or not to drop the logical replication
slot when the connector finishes orderlyBy default the replication is kept so
that on restart progress can resume from the last recorded location | false |
boolean
| *slotMaxRetries* (postgres) | How many times to retry connecting to a
replication slot when an attempt fails. | 6 | int
| *slotName* (postgres) | The name of the Postgres logical decoding slot
created for streaming changes from a plugin.Defaults to 'debezium | debezium |
String
@@ -230,7 +230,7 @@ with the following path and query parameters:
| *schemaIncludeList* (postgres) | The schemas for which events should be
captured | | String
| *schemaRefreshMode* (postgres) | Specify the conditions that trigger a
refresh of the in-memory schema for a table. 'columns_diff' (the default) is
the safest mode, ensuring the in-memory schema stays in-sync with the database
table's schema at all times. 'columns_diff_exclude_unchanged_toast' instructs
the connector to refresh the in-memory schema cache if there is a discrepancy
between it and the schema derived from the incoming message, unless unchanged
TOASTable data fully accounts [...]
| *schemaWhitelist* (postgres) | The schemas for which events should be
captured (deprecated, use schema.include.list instead) | | String
-| *skippedOperations* (postgres) | The comma-separated list of operations to
skip during streaming, defined as: 'i' for inserts; 'u' for updates; 'd' for
deletes. By default, no operations will be skipped. | | String
+| *skippedOperations* (postgres) | The comma-separated list of operations to
skip during streaming, defined as: 'c' for inserts/create; 'u' for updates; 'd'
for deletes. By default, no operations will be skipped. | | String
| *slotDropOnStop* (postgres) | Whether or not to drop the logical replication
slot when the connector finishes orderlyBy default the replication is kept so
that on restart progress can resume from the last recorded location | false |
boolean
| *slotMaxRetries* (postgres) | How many times to retry connecting to a
replication slot when an attempt fails. | 6 | int
| *slotName* (postgres) | The name of the Postgres logical decoding slot
created for streaming changes from a plugin.Defaults to 'debezium | debezium |
String
diff --git
a/components/camel-debezium-sqlserver/src/generated/java/org/apache/camel/component/debezium/DebeziumSqlserverComponentConfigurer.java
b/components/camel-debezium-sqlserver/src/generated/java/org/apache/camel/component/debezium/DebeziumSqlserverComponentConfigurer.java
index 10bf12f..4301a79 100644
---
a/components/camel-debezium-sqlserver/src/generated/java/org/apache/camel/component/debezium/DebeziumSqlserverComponentConfigurer.java
+++
b/components/camel-debezium-sqlserver/src/generated/java/org/apache/camel/component/debezium/DebeziumSqlserverComponentConfigurer.java
@@ -32,6 +32,8 @@ public class DebeziumSqlserverComponentConfigurer extends
PropertyConfigurerSupp
case "additionalProperties":
getOrCreateConfiguration(target).setAdditionalProperties(property(camelContext,
java.util.Map.class, value)); return true;
case "autowiredenabled":
case "autowiredEnabled":
target.setAutowiredEnabled(property(camelContext, boolean.class, value));
return true;
+ case "binaryhandlingmode":
+ case "binaryHandlingMode":
getOrCreateConfiguration(target).setBinaryHandlingMode(property(camelContext,
java.lang.String.class, value)); return true;
case "bridgeerrorhandler":
case "bridgeErrorHandler":
target.setBridgeErrorHandler(property(camelContext, boolean.class, value));
return true;
case "columnblacklist":
@@ -171,6 +173,8 @@ public class DebeziumSqlserverComponentConfigurer extends
PropertyConfigurerSupp
case "additionalProperties": return java.util.Map.class;
case "autowiredenabled":
case "autowiredEnabled": return boolean.class;
+ case "binaryhandlingmode":
+ case "binaryHandlingMode": return java.lang.String.class;
case "bridgeerrorhandler":
case "bridgeErrorHandler": return boolean.class;
case "columnblacklist":
@@ -311,6 +315,8 @@ public class DebeziumSqlserverComponentConfigurer extends
PropertyConfigurerSupp
case "additionalProperties": return
getOrCreateConfiguration(target).getAdditionalProperties();
case "autowiredenabled":
case "autowiredEnabled": return target.isAutowiredEnabled();
+ case "binaryhandlingmode":
+ case "binaryHandlingMode": return
getOrCreateConfiguration(target).getBinaryHandlingMode();
case "bridgeerrorhandler":
case "bridgeErrorHandler": return target.isBridgeErrorHandler();
case "columnblacklist":
diff --git
a/components/camel-debezium-sqlserver/src/generated/java/org/apache/camel/component/debezium/DebeziumSqlserverEndpointConfigurer.java
b/components/camel-debezium-sqlserver/src/generated/java/org/apache/camel/component/debezium/DebeziumSqlserverEndpointConfigurer.java
index c8d0171..ac7df05 100644
---
a/components/camel-debezium-sqlserver/src/generated/java/org/apache/camel/component/debezium/DebeziumSqlserverEndpointConfigurer.java
+++
b/components/camel-debezium-sqlserver/src/generated/java/org/apache/camel/component/debezium/DebeziumSqlserverEndpointConfigurer.java
@@ -23,6 +23,8 @@ public class DebeziumSqlserverEndpointConfigurer extends
PropertyConfigurerSuppo
switch (ignoreCase ? name.toLowerCase() : name) {
case "additionalproperties":
case "additionalProperties":
target.getConfiguration().setAdditionalProperties(property(camelContext,
java.util.Map.class, value)); return true;
+ case "binaryhandlingmode":
+ case "binaryHandlingMode":
target.getConfiguration().setBinaryHandlingMode(property(camelContext,
java.lang.String.class, value)); return true;
case "bridgeerrorhandler":
case "bridgeErrorHandler":
target.setBridgeErrorHandler(property(camelContext, boolean.class, value));
return true;
case "columnblacklist":
@@ -163,6 +165,8 @@ public class DebeziumSqlserverEndpointConfigurer extends
PropertyConfigurerSuppo
switch (ignoreCase ? name.toLowerCase() : name) {
case "additionalproperties":
case "additionalProperties": return java.util.Map.class;
+ case "binaryhandlingmode":
+ case "binaryHandlingMode": return java.lang.String.class;
case "bridgeerrorhandler":
case "bridgeErrorHandler": return boolean.class;
case "columnblacklist":
@@ -304,6 +308,8 @@ public class DebeziumSqlserverEndpointConfigurer extends
PropertyConfigurerSuppo
switch (ignoreCase ? name.toLowerCase() : name) {
case "additionalproperties":
case "additionalProperties": return
target.getConfiguration().getAdditionalProperties();
+ case "binaryhandlingmode":
+ case "binaryHandlingMode": return
target.getConfiguration().getBinaryHandlingMode();
case "bridgeerrorhandler":
case "bridgeErrorHandler": return target.isBridgeErrorHandler();
case "columnblacklist":
diff --git
a/components/camel-debezium-sqlserver/src/generated/java/org/apache/camel/component/debezium/DebeziumSqlserverEndpointUriFactory.java
b/components/camel-debezium-sqlserver/src/generated/java/org/apache/camel/component/debezium/DebeziumSqlserverEndpointUriFactory.java
index 8f48a2f..e427446 100644
---
a/components/camel-debezium-sqlserver/src/generated/java/org/apache/camel/component/debezium/DebeziumSqlserverEndpointUriFactory.java
+++
b/components/camel-debezium-sqlserver/src/generated/java/org/apache/camel/component/debezium/DebeziumSqlserverEndpointUriFactory.java
@@ -20,7 +20,7 @@ public class DebeziumSqlserverEndpointUriFactory extends
org.apache.camel.suppor
private static final Set<String> PROPERTY_NAMES;
private static final Set<String> SECRET_PROPERTY_NAMES;
static {
- Set<String> props = new HashSet<>(68);
+ Set<String> props = new HashSet<>(69);
props.add("maxBatchSize");
props.add("internalKeyConverter");
props.add("snapshotDelayMs");
@@ -39,6 +39,7 @@ public class DebeziumSqlserverEndpointUriFactory extends
org.apache.camel.suppor
props.add("skippedOperations");
props.add("sourceStructVersion");
props.add("databaseServerTimezone");
+ props.add("binaryHandlingMode");
props.add("databaseHostname");
props.add("eventProcessingFailureHandlingMode");
props.add("offsetCommitTimeoutMs");
diff --git
a/components/camel-debezium-sqlserver/src/generated/java/org/apache/camel/component/debezium/configuration/SqlServerConnectorEmbeddedDebeziumConfiguration.java
b/components/camel-debezium-sqlserver/src/generated/java/org/apache/camel/component/debezium/configuration/SqlServerConnectorEmbeddedDebeziumConfiguration.java
index d8d7198..ae1df95 100644
---
a/components/camel-debezium-sqlserver/src/generated/java/org/apache/camel/component/debezium/configuration/SqlServerConnectorEmbeddedDebeziumConfiguration.java
+++
b/components/camel-debezium-sqlserver/src/generated/java/org/apache/camel/component/debezium/configuration/SqlServerConnectorEmbeddedDebeziumConfiguration.java
@@ -93,6 +93,8 @@ public class SqlServerConnectorEmbeddedDebeziumConfiguration
private boolean tombstonesOnDelete = false;
@UriParam(label = LABEL_NAME, defaultValue = "precise")
private String decimalHandlingMode = "precise";
+ @UriParam(label = LABEL_NAME, defaultValue = "bytes")
+ private String binaryHandlingMode = "bytes";
@UriParam(label = LABEL_NAME, defaultValue = "true")
private boolean tableIgnoreBuiltin = true;
@UriParam(label = LABEL_NAME)
@@ -481,8 +483,8 @@ public class SqlServerConnectorEmbeddedDebeziumConfiguration
/**
* The comma-separated list of operations to skip during streaming, defined
- * as: 'i' for inserts; 'u' for updates; 'd' for deletes. By default, no
- * operations will be skipped.
+ * as: 'c' for inserts/create; 'u' for updates; 'd' for deletes. By
default,
+ * no operations will be skipped.
*/
public void setSkippedOperations(String skippedOperations) {
this.skippedOperations = skippedOperations;
@@ -650,6 +652,20 @@ public class
SqlServerConnectorEmbeddedDebeziumConfiguration
}
/**
+ * Specify how binary (blob, binary, etc.) columns should be represented in
+ * change events, including:'bytes' represents binary data as byte array
+ * (default)'base64' represents binary data as base64-encoded string'hex'
+ * represents binary data as hex-encoded (base16) string
+ */
+ public void setBinaryHandlingMode(String binaryHandlingMode) {
+ this.binaryHandlingMode = binaryHandlingMode;
+ }
+
+ public String getBinaryHandlingMode() {
+ return binaryHandlingMode;
+ }
+
+ /**
* Flag specifying whether built-in tables should be ignored.
*/
public void setTableIgnoreBuiltin(boolean tableIgnoreBuiltin) {
@@ -872,6 +888,7 @@ public class SqlServerConnectorEmbeddedDebeziumConfiguration
addPropertyIfNotNull(configBuilder, "database.server.timezone",
databaseServerTimezone);
addPropertyIfNotNull(configBuilder, "tombstones.on.delete",
tombstonesOnDelete);
addPropertyIfNotNull(configBuilder, "decimal.handling.mode",
decimalHandlingMode);
+ addPropertyIfNotNull(configBuilder, "binary.handling.mode",
binaryHandlingMode);
addPropertyIfNotNull(configBuilder, "table.ignore.builtin",
tableIgnoreBuiltin);
addPropertyIfNotNull(configBuilder,
"snapshot.include.collection.list", snapshotIncludeCollectionList);
addPropertyIfNotNull(configBuilder, "database.history.file.filename",
databaseHistoryFileFilename);
diff --git
a/components/camel-debezium-sqlserver/src/generated/resources/org/apache/camel/component/debezium/debezium-sqlserver.json
b/components/camel-debezium-sqlserver/src/generated/resources/org/apache/camel/component/debezium/debezium-sqlserver.json
index 9989350..a0c0834 100644
---
a/components/camel-debezium-sqlserver/src/generated/resources/org/apache/camel/component/debezium/debezium-sqlserver.json
+++
b/components/camel-debezium-sqlserver/src/generated/resources/org/apache/camel/component/debezium/debezium-sqlserver.json
@@ -36,6 +36,7 @@
"offsetStorageReplicationFactor": { "kind": "property", "displayName":
"Offset Storage Replication Factor", "group": "consumer", "label": "consumer",
"required": false, "type": "integer", "javaType": "int", "deprecated": false,
"autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.debezium.configuration.SqlServerConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "Replication factor used
when creating the off [...]
"offsetStorageTopic": { "kind": "property", "displayName": "Offset Storage
Topic", "group": "consumer", "label": "consumer", "required": false, "type":
"string", "javaType": "java.lang.String", "deprecated": false, "autowired":
false, "secret": false, "configurationClass":
"org.apache.camel.component.debezium.configuration.SqlServerConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "The name of the Kafka
topic where offsets are to be stored [...]
"autowiredEnabled": { "kind": "property", "displayName": "Autowired
Enabled", "group": "advanced", "label": "advanced", "required": false, "type":
"boolean", "javaType": "boolean", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": true, "description": "Whether autowiring is
enabled. This is used for automatic autowiring options (the option must be
marked as autowired) by looking up in the registry to find if there is a single
instance of matching type, which t [...]
+ "binaryHandlingMode": { "kind": "property", "displayName": "Binary
Handling Mode", "group": "sqlserver", "label": "consumer,sqlserver",
"required": false, "type": "string", "javaType": "java.lang.String",
"deprecated": false, "autowired": false, "secret": false, "defaultValue":
"bytes", "configurationClass":
"org.apache.camel.component.debezium.configuration.SqlServerConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "Specify how binary (bl
[...]
"columnBlacklist": { "kind": "property", "displayName": "Column
Blacklist", "group": "sqlserver", "label": "consumer,sqlserver", "required":
false, "type": "string", "javaType": "java.lang.String", "deprecated": false,
"autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.debezium.configuration.SqlServerConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "Regular expressions
matching columns to exclude from c [...]
"columnExcludeList": { "kind": "property", "displayName": "Column Exclude
List", "group": "sqlserver", "label": "consumer,sqlserver", "required": false,
"type": "string", "javaType": "java.lang.String", "deprecated": false,
"autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.debezium.configuration.SqlServerConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "Regular expressions
matching columns to exclude f [...]
"columnIncludeList": { "kind": "property", "displayName": "Column Include
List", "group": "sqlserver", "label": "consumer,sqlserver", "required": false,
"type": "string", "javaType": "java.lang.String", "deprecated": false,
"autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.debezium.configuration.SqlServerConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "Regular expressions
matching columns to include i [...]
@@ -71,7 +72,7 @@
"queryFetchSize": { "kind": "property", "displayName": "Query Fetch Size",
"group": "sqlserver", "label": "consumer,sqlserver", "required": false, "type":
"integer", "javaType": "int", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": 0, "configurationClass":
"org.apache.camel.component.debezium.configuration.SqlServerConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "The maximum number of
records that should be loa [...]
"retriableRestartConnectorWaitMs": { "kind": "property", "displayName":
"Retriable Restart Connector Wait Ms", "group": "sqlserver", "label":
"consumer,sqlserver", "required": false, "type": "duration", "javaType":
"long", "deprecated": false, "autowired": false, "secret": false,
"defaultValue": "10s", "configurationClass":
"org.apache.camel.component.debezium.configuration.SqlServerConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "Time t [...]
"sanitizeFieldNames": { "kind": "property", "displayName": "Sanitize Field
Names", "group": "sqlserver", "label": "consumer,sqlserver", "required": false,
"type": "boolean", "javaType": "boolean", "deprecated": false, "autowired":
false, "secret": false, "defaultValue": false, "configurationClass":
"org.apache.camel.component.debezium.configuration.SqlServerConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "Whether field names
will be sani [...]
- "skippedOperations": { "kind": "property", "displayName": "Skipped
Operations", "group": "sqlserver", "label": "consumer,sqlserver", "required":
false, "type": "string", "javaType": "java.lang.String", "deprecated": false,
"autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.debezium.configuration.SqlServerConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "The comma-separated
list of operations to skip dur [...]
+ "skippedOperations": { "kind": "property", "displayName": "Skipped
Operations", "group": "sqlserver", "label": "consumer,sqlserver", "required":
false, "type": "string", "javaType": "java.lang.String", "deprecated": false,
"autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.debezium.configuration.SqlServerConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "The comma-separated
list of operations to skip dur [...]
"snapshotDelayMs": { "kind": "property", "displayName": "Snapshot Delay
Ms", "group": "sqlserver", "label": "consumer,sqlserver", "required": false,
"type": "duration", "javaType": "long", "deprecated": false, "autowired":
false, "secret": false, "defaultValue": "0ms", "configurationClass":
"org.apache.camel.component.debezium.configuration.SqlServerConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "The number of
milliseconds to delay befo [...]
"snapshotFetchSize": { "kind": "property", "displayName": "Snapshot Fetch
Size", "group": "sqlserver", "label": "consumer,sqlserver", "required": false,
"type": "integer", "javaType": "int", "deprecated": false, "autowired": false,
"secret": false, "configurationClass":
"org.apache.camel.component.debezium.configuration.SqlServerConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "The maximum number of
records that should be loaded into memo [...]
"snapshotIncludeCollectionList": { "kind": "property", "displayName":
"Snapshot Include Collection List", "group": "sqlserver", "label":
"consumer,sqlserver", "required": false, "type": "string", "javaType":
"java.lang.String", "deprecated": false, "autowired": false, "secret": false,
"configurationClass":
"org.apache.camel.component.debezium.configuration.SqlServerConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "this setting must be
set [...]
@@ -106,6 +107,7 @@
"offsetStorageTopic": { "kind": "parameter", "displayName": "Offset
Storage Topic", "group": "consumer", "label": "consumer", "required": false,
"type": "string", "javaType": "java.lang.String", "deprecated": false,
"autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.debezium.configuration.SqlServerConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "The name of the Kafka
topic where offsets are to be store [...]
"exceptionHandler": { "kind": "parameter", "displayName": "Exception
Handler", "group": "consumer (advanced)", "label": "consumer,advanced",
"required": false, "type": "object", "javaType":
"org.apache.camel.spi.ExceptionHandler", "optionalPrefix": "consumer.",
"deprecated": false, "autowired": false, "secret": false, "description": "To
let the consumer use a custom ExceptionHandler. Notice if the option
bridgeErrorHandler is enabled then this option is not in use. By default the
con [...]
"exchangePattern": { "kind": "parameter", "displayName": "Exchange
Pattern", "group": "consumer (advanced)", "label": "consumer,advanced",
"required": false, "type": "object", "javaType":
"org.apache.camel.ExchangePattern", "enum": [ "InOnly", "InOut",
"InOptionalOut" ], "deprecated": false, "autowired": false, "secret": false,
"description": "Sets the exchange pattern when the consumer creates an
exchange." },
+ "binaryHandlingMode": { "kind": "parameter", "displayName": "Binary
Handling Mode", "group": "sqlserver", "label": "consumer,sqlserver",
"required": false, "type": "string", "javaType": "java.lang.String",
"deprecated": false, "autowired": false, "secret": false, "defaultValue":
"bytes", "configurationClass":
"org.apache.camel.component.debezium.configuration.SqlServerConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "Specify how binary (b
[...]
"columnBlacklist": { "kind": "parameter", "displayName": "Column
Blacklist", "group": "sqlserver", "label": "consumer,sqlserver", "required":
false, "type": "string", "javaType": "java.lang.String", "deprecated": false,
"autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.debezium.configuration.SqlServerConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "Regular expressions
matching columns to exclude from [...]
"columnExcludeList": { "kind": "parameter", "displayName": "Column Exclude
List", "group": "sqlserver", "label": "consumer,sqlserver", "required": false,
"type": "string", "javaType": "java.lang.String", "deprecated": false,
"autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.debezium.configuration.SqlServerConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "Regular expressions
matching columns to exclude [...]
"columnIncludeList": { "kind": "parameter", "displayName": "Column Include
List", "group": "sqlserver", "label": "consumer,sqlserver", "required": false,
"type": "string", "javaType": "java.lang.String", "deprecated": false,
"autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.debezium.configuration.SqlServerConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "Regular expressions
matching columns to include [...]
@@ -141,7 +143,7 @@
"queryFetchSize": { "kind": "parameter", "displayName": "Query Fetch
Size", "group": "sqlserver", "label": "consumer,sqlserver", "required": false,
"type": "integer", "javaType": "int", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": 0, "configurationClass":
"org.apache.camel.component.debezium.configuration.SqlServerConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "The maximum number of
records that should be lo [...]
"retriableRestartConnectorWaitMs": { "kind": "parameter", "displayName":
"Retriable Restart Connector Wait Ms", "group": "sqlserver", "label":
"consumer,sqlserver", "required": false, "type": "duration", "javaType":
"long", "deprecated": false, "autowired": false, "secret": false,
"defaultValue": "10s", "configurationClass":
"org.apache.camel.component.debezium.configuration.SqlServerConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "Time [...]
"sanitizeFieldNames": { "kind": "parameter", "displayName": "Sanitize
Field Names", "group": "sqlserver", "label": "consumer,sqlserver", "required":
false, "type": "boolean", "javaType": "boolean", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": false,
"configurationClass":
"org.apache.camel.component.debezium.configuration.SqlServerConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "Whether field names
will be san [...]
- "skippedOperations": { "kind": "parameter", "displayName": "Skipped
Operations", "group": "sqlserver", "label": "consumer,sqlserver", "required":
false, "type": "string", "javaType": "java.lang.String", "deprecated": false,
"autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.debezium.configuration.SqlServerConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "The comma-separated
list of operations to skip du [...]
+ "skippedOperations": { "kind": "parameter", "displayName": "Skipped
Operations", "group": "sqlserver", "label": "consumer,sqlserver", "required":
false, "type": "string", "javaType": "java.lang.String", "deprecated": false,
"autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.debezium.configuration.SqlServerConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "The comma-separated
list of operations to skip du [...]
"snapshotDelayMs": { "kind": "parameter", "displayName": "Snapshot Delay
Ms", "group": "sqlserver", "label": "consumer,sqlserver", "required": false,
"type": "duration", "javaType": "long", "deprecated": false, "autowired":
false, "secret": false, "defaultValue": "0ms", "configurationClass":
"org.apache.camel.component.debezium.configuration.SqlServerConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "The number of
milliseconds to delay bef [...]
"snapshotFetchSize": { "kind": "parameter", "displayName": "Snapshot Fetch
Size", "group": "sqlserver", "label": "consumer,sqlserver", "required": false,
"type": "integer", "javaType": "int", "deprecated": false, "autowired": false,
"secret": false, "configurationClass":
"org.apache.camel.component.debezium.configuration.SqlServerConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "The maximum number of
records that should be loaded into mem [...]
"snapshotIncludeCollectionList": { "kind": "parameter", "displayName":
"Snapshot Include Collection List", "group": "sqlserver", "label":
"consumer,sqlserver", "required": false, "type": "string", "javaType":
"java.lang.String", "deprecated": false, "autowired": false, "secret": false,
"configurationClass":
"org.apache.camel.component.debezium.configuration.SqlServerConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "this setting must be se
[...]
diff --git
a/components/camel-debezium-sqlserver/src/main/docs/debezium-sqlserver-component.adoc
b/components/camel-debezium-sqlserver/src/main/docs/debezium-sqlserver-component.adoc
index 021fa32..73c85f4 100644
---
a/components/camel-debezium-sqlserver/src/main/docs/debezium-sqlserver-component.adoc
+++
b/components/camel-debezium-sqlserver/src/main/docs/debezium-sqlserver-component.adoc
@@ -44,7 +44,7 @@ debezium-sqlserver:name[?options]
// component options: START
-The Debezium SQL Server Connector component supports 67 options, which are
listed below.
+The Debezium SQL Server Connector component supports 68 options, which are
listed below.
@@ -65,6 +65,7 @@ The Debezium SQL Server Connector component supports 67
options, which are liste
| *offsetStorageReplicationFactor* (consumer) | Replication factor used when
creating the offset storage topic. Required when offset.storage is set to the
KafkaOffsetBackingStore | | int
| *offsetStorageTopic* (consumer) | The name of the Kafka topic where offsets
are to be stored. Required when offset.storage is set to the
KafkaOffsetBackingStore. | | String
| *autowiredEnabled* (advanced) | Whether autowiring is enabled. This is used
for automatic autowiring options (the option must be marked as autowired) by
looking up in the registry to find if there is a single instance of matching
type, which then gets configured on the component. This can be used for
automatic configuring JDBC data sources, JMS connection factories, AWS Clients,
etc. | true | boolean
+| *binaryHandlingMode* (sqlserver) | Specify how binary (blob, binary, etc.)
columns should be represented in change events, including:'bytes' represents
binary data as byte array (default)'base64' represents binary data as
base64-encoded string'hex' represents binary data as hex-encoded (base16)
string | bytes | String
| *columnBlacklist* (sqlserver) | Regular expressions matching columns to
exclude from change events (deprecated, use column.exclude.list instead) | |
String
| *columnExcludeList* (sqlserver) | Regular expressions matching columns to
exclude from change events | | String
| *columnIncludeList* (sqlserver) | Regular expressions matching columns to
include in change events | | String
@@ -100,7 +101,7 @@ The Debezium SQL Server Connector component supports 67
options, which are liste
| *queryFetchSize* (sqlserver) | The maximum number of records that should be
loaded into memory while streaming. A value of 0 uses the default JDBC fetch
size. | 0 | int
| *retriableRestartConnectorWait{zwsp}Ms* (sqlserver) | Time to wait before
restarting connector after retriable exception occurs. Defaults to 10000ms. |
10s | long
| *sanitizeFieldNames* (sqlserver) | Whether field names will be sanitized to
Avro naming conventions | false | boolean
-| *skippedOperations* (sqlserver) | The comma-separated list of operations to
skip during streaming, defined as: 'i' for inserts; 'u' for updates; 'd' for
deletes. By default, no operations will be skipped. | | String
+| *skippedOperations* (sqlserver) | The comma-separated list of operations to
skip during streaming, defined as: 'c' for inserts/create; 'u' for updates; 'd'
for deletes. By default, no operations will be skipped. | | String
| *snapshotDelayMs* (sqlserver) | The number of milliseconds to delay before a
snapshot will begin. | 0ms | long
| *snapshotFetchSize* (sqlserver) | The maximum number of records that should
be loaded into memory while performing a snapshot | | int
| *snapshotIncludeCollectionList* (sqlserver) | this setting must be set to
specify a list of tables/collections whose snapshot must be taken on creating
or restarting the connector. | | String
@@ -141,7 +142,7 @@ with the following path and query parameters:
|===
-=== Query Parameters (67 parameters):
+=== Query Parameters (68 parameters):
[width="100%",cols="2,5,^1,2",options="header"]
@@ -161,6 +162,7 @@ with the following path and query parameters:
| *offsetStorageTopic* (consumer) | The name of the Kafka topic where offsets
are to be stored. Required when offset.storage is set to the
KafkaOffsetBackingStore. | | String
| *exceptionHandler* (consumer) | To let the consumer use a custom
ExceptionHandler. Notice if the option bridgeErrorHandler is enabled then this
option is not in use. By default the consumer will deal with exceptions, that
will be logged at WARN or ERROR level and ignored. | | ExceptionHandler
| *exchangePattern* (consumer) | Sets the exchange pattern when the consumer
creates an exchange. There are 3 enums and the value can be one of: InOnly,
InOut, InOptionalOut | | ExchangePattern
+| *binaryHandlingMode* (sqlserver) | Specify how binary (blob, binary, etc.)
columns should be represented in change events, including:'bytes' represents
binary data as byte array (default)'base64' represents binary data as
base64-encoded string'hex' represents binary data as hex-encoded (base16)
string | bytes | String
| *columnBlacklist* (sqlserver) | Regular expressions matching columns to
exclude from change events (deprecated, use column.exclude.list instead) | |
String
| *columnExcludeList* (sqlserver) | Regular expressions matching columns to
exclude from change events | | String
| *columnIncludeList* (sqlserver) | Regular expressions matching columns to
include in change events | | String
@@ -196,7 +198,7 @@ with the following path and query parameters:
| *queryFetchSize* (sqlserver) | The maximum number of records that should be
loaded into memory while streaming. A value of 0 uses the default JDBC fetch
size. | 0 | int
| *retriableRestartConnectorWait{zwsp}Ms* (sqlserver) | Time to wait before
restarting connector after retriable exception occurs. Defaults to 10000ms. |
10s | long
| *sanitizeFieldNames* (sqlserver) | Whether field names will be sanitized to
Avro naming conventions | false | boolean
-| *skippedOperations* (sqlserver) | The comma-separated list of operations to
skip during streaming, defined as: 'i' for inserts; 'u' for updates; 'd' for
deletes. By default, no operations will be skipped. | | String
+| *skippedOperations* (sqlserver) | The comma-separated list of operations to
skip during streaming, defined as: 'c' for inserts/create; 'u' for updates; 'd'
for deletes. By default, no operations will be skipped. | | String
| *snapshotDelayMs* (sqlserver) | The number of milliseconds to delay before a
snapshot will begin. | 0ms | long
| *snapshotFetchSize* (sqlserver) | The maximum number of records that should
be loaded into memory while performing a snapshot | | int
| *snapshotIncludeCollectionList* (sqlserver) | this setting must be set to
specify a list of tables/collections whose snapshot must be taken on creating
or restarting the connector. | | String
diff --git
a/core/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/DebeziumMongodbComponentBuilderFactory.java
b/core/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/DebeziumMongodbComponentBuilderFactory.java
index 4dfef52..25e5153 100644
---
a/core/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/DebeziumMongodbComponentBuilderFactory.java
+++
b/core/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/DebeziumMongodbComponentBuilderFactory.java
@@ -874,8 +874,8 @@ public interface DebeziumMongodbComponentBuilderFactory {
}
/**
* The comma-separated list of operations to skip during streaming,
- * defined as: 'i' for inserts; 'u' for updates; 'd' for deletes. By
- * default, no operations will be skipped.
+ * defined as: 'c' for inserts/create; 'u' for updates; 'd' for
deletes.
+ * By default, no operations will be skipped.
*
* The option is a: <code>java.lang.String</code> type.
*
diff --git
a/core/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/DebeziumMysqlComponentBuilderFactory.java
b/core/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/DebeziumMysqlComponentBuilderFactory.java
index 6b0b0a6..8557552 100644
---
a/core/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/DebeziumMysqlComponentBuilderFactory.java
+++
b/core/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/DebeziumMysqlComponentBuilderFactory.java
@@ -1207,8 +1207,8 @@ public interface DebeziumMysqlComponentBuilderFactory {
}
/**
* The comma-separated list of operations to skip during streaming,
- * defined as: 'i' for inserts; 'u' for updates; 'd' for deletes. By
- * default, no operations will be skipped.
+ * defined as: 'c' for inserts/create; 'u' for updates; 'd' for
deletes.
+ * By default, no operations will be skipped.
*
* The option is a: <code>java.lang.String</code> type.
*
diff --git
a/core/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/DebeziumPostgresComponentBuilderFactory.java
b/core/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/DebeziumPostgresComponentBuilderFactory.java
index 6c633e2..5f222e8 100644
---
a/core/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/DebeziumPostgresComponentBuilderFactory.java
+++
b/core/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/DebeziumPostgresComponentBuilderFactory.java
@@ -1150,8 +1150,8 @@ public interface DebeziumPostgresComponentBuilderFactory {
}
/**
* The comma-separated list of operations to skip during streaming,
- * defined as: 'i' for inserts; 'u' for updates; 'd' for deletes. By
- * default, no operations will be skipped.
+ * defined as: 'c' for inserts/create; 'u' for updates; 'd' for
deletes.
+ * By default, no operations will be skipped.
*
* The option is a: <code>java.lang.String</code> type.
*
diff --git
a/core/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/DebeziumSqlserverComponentBuilderFactory.java
b/core/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/DebeziumSqlserverComponentBuilderFactory.java
index 300e81c..9eb6dcc 100644
---
a/core/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/DebeziumSqlserverComponentBuilderFactory.java
+++
b/core/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/DebeziumSqlserverComponentBuilderFactory.java
@@ -302,6 +302,25 @@ public interface DebeziumSqlserverComponentBuilderFactory {
return this;
}
/**
+ * Specify how binary (blob, binary, etc.) columns should be
represented
+ * in change events, including:'bytes' represents binary data as byte
+ * array (default)'base64' represents binary data as base64-encoded
+ * string'hex' represents binary data as hex-encoded (base16) string.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Default: bytes
+ * Group: sqlserver
+ *
+ * @param binaryHandlingMode the value to set
+ * @return the dsl builder
+ */
+ default DebeziumSqlserverComponentBuilder binaryHandlingMode(
+ java.lang.String binaryHandlingMode) {
+ doSetProperty("binaryHandlingMode", binaryHandlingMode);
+ return this;
+ }
+ /**
* Regular expressions matching columns to exclude from change events
* (deprecated, use column.exclude.list instead).
*
@@ -906,8 +925,8 @@ public interface DebeziumSqlserverComponentBuilderFactory {
}
/**
* The comma-separated list of operations to skip during streaming,
- * defined as: 'i' for inserts; 'u' for updates; 'd' for deletes. By
- * default, no operations will be skipped.
+ * defined as: 'c' for inserts/create; 'u' for updates; 'd' for
deletes.
+ * By default, no operations will be skipped.
*
* The option is a: <code>java.lang.String</code> type.
*
@@ -1280,6 +1299,7 @@ public interface DebeziumSqlserverComponentBuilderFactory
{
case "offsetStorageReplicationFactor":
getOrCreateConfiguration((DebeziumSqlserverComponent)
component).setOffsetStorageReplicationFactor((int) value); return true;
case "offsetStorageTopic":
getOrCreateConfiguration((DebeziumSqlserverComponent)
component).setOffsetStorageTopic((java.lang.String) value); return true;
case "autowiredEnabled": ((DebeziumSqlserverComponent)
component).setAutowiredEnabled((boolean) value); return true;
+ case "binaryHandlingMode":
getOrCreateConfiguration((DebeziumSqlserverComponent)
component).setBinaryHandlingMode((java.lang.String) value); return true;
case "columnBlacklist":
getOrCreateConfiguration((DebeziumSqlserverComponent)
component).setColumnBlacklist((java.lang.String) value); return true;
case "columnExcludeList":
getOrCreateConfiguration((DebeziumSqlserverComponent)
component).setColumnExcludeList((java.lang.String) value); return true;
case "columnIncludeList":
getOrCreateConfiguration((DebeziumSqlserverComponent)
component).setColumnIncludeList((java.lang.String) value); return true;
diff --git
a/core/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/DebeziumMongodbEndpointBuilderFactory.java
b/core/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/DebeziumMongodbEndpointBuilderFactory.java
index 74a5e31..ed65059 100644
---
a/core/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/DebeziumMongodbEndpointBuilderFactory.java
+++
b/core/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/DebeziumMongodbEndpointBuilderFactory.java
@@ -1272,8 +1272,8 @@ public interface DebeziumMongodbEndpointBuilderFactory {
}
/**
* The comma-separated list of operations to skip during streaming,
- * defined as: 'i' for inserts; 'u' for updates; 'd' for deletes. By
- * default, no operations will be skipped.
+ * defined as: 'c' for inserts/create; 'u' for updates; 'd' for
deletes.
+ * By default, no operations will be skipped.
*
* The option is a: <code>java.lang.String</code> type.
*
diff --git
a/core/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/DebeziumMySqlEndpointBuilderFactory.java
b/core/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/DebeziumMySqlEndpointBuilderFactory.java
index fc8861d..f5f0a79 100644
---
a/core/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/DebeziumMySqlEndpointBuilderFactory.java
+++
b/core/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/DebeziumMySqlEndpointBuilderFactory.java
@@ -1631,8 +1631,8 @@ public interface DebeziumMySqlEndpointBuilderFactory {
}
/**
* The comma-separated list of operations to skip during streaming,
- * defined as: 'i' for inserts; 'u' for updates; 'd' for deletes. By
- * default, no operations will be skipped.
+ * defined as: 'c' for inserts/create; 'u' for updates; 'd' for
deletes.
+ * By default, no operations will be skipped.
*
* The option is a: <code>java.lang.String</code> type.
*
diff --git
a/core/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/DebeziumPostgresEndpointBuilderFactory.java
b/core/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/DebeziumPostgresEndpointBuilderFactory.java
index 66a9946..1618b53 100644
---
a/core/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/DebeziumPostgresEndpointBuilderFactory.java
+++
b/core/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/DebeziumPostgresEndpointBuilderFactory.java
@@ -1428,8 +1428,8 @@ public interface DebeziumPostgresEndpointBuilderFactory {
}
/**
* The comma-separated list of operations to skip during streaming,
- * defined as: 'i' for inserts; 'u' for updates; 'd' for deletes. By
- * default, no operations will be skipped.
+ * defined as: 'c' for inserts/create; 'u' for updates; 'd' for
deletes.
+ * By default, no operations will be skipped.
*
* The option is a: <code>java.lang.String</code> type.
*
diff --git
a/core/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/DebeziumSqlserverEndpointBuilderFactory.java
b/core/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/DebeziumSqlserverEndpointBuilderFactory.java
index d625da0..257fc89 100644
---
a/core/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/DebeziumSqlserverEndpointBuilderFactory.java
+++
b/core/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/DebeziumSqlserverEndpointBuilderFactory.java
@@ -375,6 +375,25 @@ public interface DebeziumSqlserverEndpointBuilderFactory {
return this;
}
/**
+ * Specify how binary (blob, binary, etc.) columns should be
represented
+ * in change events, including:'bytes' represents binary data as byte
+ * array (default)'base64' represents binary data as base64-encoded
+ * string'hex' represents binary data as hex-encoded (base16) string.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Default: bytes
+ * Group: sqlserver
+ *
+ * @param binaryHandlingMode the value to set
+ * @return the dsl builder
+ */
+ default DebeziumSqlserverEndpointBuilder binaryHandlingMode(
+ String binaryHandlingMode) {
+ doSetProperty("binaryHandlingMode", binaryHandlingMode);
+ return this;
+ }
+ /**
* Regular expressions matching columns to exclude from change events
* (deprecated, use column.exclude.list instead).
*
@@ -1209,8 +1228,8 @@ public interface DebeziumSqlserverEndpointBuilderFactory {
}
/**
* The comma-separated list of operations to skip during streaming,
- * defined as: 'i' for inserts; 'u' for updates; 'd' for deletes. By
- * default, no operations will be skipped.
+ * defined as: 'c' for inserts/create; 'u' for updates; 'd' for
deletes.
+ * By default, no operations will be skipped.
*
* The option is a: <code>java.lang.String</code> type.
*
diff --git a/docs/components/modules/ROOT/pages/debezium-mongodb-component.adoc
b/docs/components/modules/ROOT/pages/debezium-mongodb-component.adoc
index 8a95a76..5b7f363 100644
--- a/docs/components/modules/ROOT/pages/debezium-mongodb-component.adoc
+++ b/docs/components/modules/ROOT/pages/debezium-mongodb-component.adoc
@@ -104,7 +104,7 @@ The Debezium MongoDB Connector component supports 57
options, which are listed b
| *queryFetchSize* (mongodb) | The maximum number of records that should be
loaded into memory while streaming. A value of 0 uses the default JDBC fetch
size. | 0 | int
| *retriableRestartConnectorWait{zwsp}Ms* (mongodb) | Time to wait before
restarting connector after retriable exception occurs. Defaults to 10000ms. |
10s | long
| *sanitizeFieldNames* (mongodb) | Whether field names will be sanitized to
Avro naming conventions | false | boolean
-| *skippedOperations* (mongodb) | The comma-separated list of operations to
skip during streaming, defined as: 'i' for inserts; 'u' for updates; 'd' for
deletes. By default, no operations will be skipped. | | String
+| *skippedOperations* (mongodb) | The comma-separated list of operations to
skip during streaming, defined as: 'c' for inserts/create; 'u' for updates; 'd'
for deletes. By default, no operations will be skipped. | | String
| *snapshotCollectionFilter{zwsp}Overrides* (mongodb) | This property contains
a comma-separated list of ., for which the initial snapshot may be a subset of
data present in the data source. The subset would be defined by mongodb filter
query specified as value for property snapshot.collection.filter.override.. |
| String
| *snapshotDelayMs* (mongodb) | The number of milliseconds to delay before a
snapshot will begin. | 0ms | long
| *snapshotFetchSize* (mongodb) | The maximum number of records that should be
loaded into memory while performing a snapshot | | int
@@ -190,7 +190,7 @@ with the following path and query parameters:
| *queryFetchSize* (mongodb) | The maximum number of records that should be
loaded into memory while streaming. A value of 0 uses the default JDBC fetch
size. | 0 | int
| *retriableRestartConnectorWait{zwsp}Ms* (mongodb) | Time to wait before
restarting connector after retriable exception occurs. Defaults to 10000ms. |
10s | long
| *sanitizeFieldNames* (mongodb) | Whether field names will be sanitized to
Avro naming conventions | false | boolean
-| *skippedOperations* (mongodb) | The comma-separated list of operations to
skip during streaming, defined as: 'i' for inserts; 'u' for updates; 'd' for
deletes. By default, no operations will be skipped. | | String
+| *skippedOperations* (mongodb) | The comma-separated list of operations to
skip during streaming, defined as: 'c' for inserts/create; 'u' for updates; 'd'
for deletes. By default, no operations will be skipped. | | String
| *snapshotCollectionFilter{zwsp}Overrides* (mongodb) | This property contains
a comma-separated list of ., for which the initial snapshot may be a subset of
data present in the data source. The subset would be defined by mongodb filter
query specified as value for property snapshot.collection.filter.override.. |
| String
| *snapshotDelayMs* (mongodb) | The number of milliseconds to delay before a
snapshot will begin. | 0ms | long
| *snapshotFetchSize* (mongodb) | The maximum number of records that should be
loaded into memory while performing a snapshot | | int
diff --git a/docs/components/modules/ROOT/pages/debezium-mysql-component.adoc
b/docs/components/modules/ROOT/pages/debezium-mysql-component.adoc
index c49f649..2952a48 100644
--- a/docs/components/modules/ROOT/pages/debezium-mysql-component.adoc
+++ b/docs/components/modules/ROOT/pages/debezium-mysql-component.adoc
@@ -127,7 +127,7 @@ The Debezium MySQL Connector component supports 80 options,
which are listed bel
| *maxQueueSize* (mysql) | Maximum size of the queue for change events read
from the database log but not yet recorded or forwarded. Defaults to 8192, and
should always be larger than the maximum batch size. | 8192 | int
| *messageKeyColumns* (mysql) | A semicolon-separated list of expressions that
match fully-qualified tables and column(s) to be used as message key. Each
expression must match the pattern ':',where the table names could be defined as
(DB_NAME.TABLE_NAME) or (SCHEMA_NAME.TABLE_NAME), depending on the specific
connector,and the key columns are a comma-separated list of columns
representing the custom key. For any table without an explicit key
configuration the table's primary key column(s) [...]
| *pollIntervalMs* (mysql) | Frequency in milliseconds to wait for new change
events to appear after receiving no events. Defaults to 500ms. | 500ms | long
-| *skippedOperations* (mysql) | The comma-separated list of operations to skip
during streaming, defined as: 'i' for inserts; 'u' for updates; 'd' for
deletes. By default, no operations will be skipped. | | String
+| *skippedOperations* (mysql) | The comma-separated list of operations to skip
during streaming, defined as: 'c' for inserts/create; 'u' for updates; 'd' for
deletes. By default, no operations will be skipped. | | String
| *snapshotDelayMs* (mysql) | The number of milliseconds to delay before a
snapshot will begin. | 0ms | long
| *snapshotEventsAsInserts* (mysql) | Whether or not to mark snapshot events
as normal inserts (op 'c'). If disabled, the standard functionality of emitting
these records as reads (op 'r') will be used. | true | boolean
| *snapshotFetchSize* (mysql) | The maximum number of records that should be
loaded into memory while performing a snapshot | | int
@@ -236,7 +236,7 @@ with the following path and query parameters:
| *maxQueueSize* (mysql) | Maximum size of the queue for change events read
from the database log but not yet recorded or forwarded. Defaults to 8192, and
should always be larger than the maximum batch size. | 8192 | int
| *messageKeyColumns* (mysql) | A semicolon-separated list of expressions that
match fully-qualified tables and column(s) to be used as message key. Each
expression must match the pattern ':',where the table names could be defined as
(DB_NAME.TABLE_NAME) or (SCHEMA_NAME.TABLE_NAME), depending on the specific
connector,and the key columns are a comma-separated list of columns
representing the custom key. For any table without an explicit key
configuration the table's primary key column(s) [...]
| *pollIntervalMs* (mysql) | Frequency in milliseconds to wait for new change
events to appear after receiving no events. Defaults to 500ms. | 500ms | long
-| *skippedOperations* (mysql) | The comma-separated list of operations to skip
during streaming, defined as: 'i' for inserts; 'u' for updates; 'd' for
deletes. By default, no operations will be skipped. | | String
+| *skippedOperations* (mysql) | The comma-separated list of operations to skip
during streaming, defined as: 'c' for inserts/create; 'u' for updates; 'd' for
deletes. By default, no operations will be skipped. | | String
| *snapshotDelayMs* (mysql) | The number of milliseconds to delay before a
snapshot will begin. | 0ms | long
| *snapshotEventsAsInserts* (mysql) | Whether or not to mark snapshot events
as normal inserts (op 'c'). If disabled, the standard functionality of emitting
these records as reads (op 'r') will be used. | true | boolean
| *snapshotFetchSize* (mysql) | The maximum number of records that should be
loaded into memory while performing a snapshot | | int
diff --git
a/docs/components/modules/ROOT/pages/debezium-postgres-component.adoc
b/docs/components/modules/ROOT/pages/debezium-postgres-component.adoc
index b58a216..887718c 100644
--- a/docs/components/modules/ROOT/pages/debezium-postgres-component.adoc
+++ b/docs/components/modules/ROOT/pages/debezium-postgres-component.adoc
@@ -116,7 +116,7 @@ The Debezium PostgresSQL Connector component supports 87
options, which are list
| *schemaIncludeList* (postgres) | The schemas for which events should be
captured | | String
| *schemaRefreshMode* (postgres) | Specify the conditions that trigger a
refresh of the in-memory schema for a table. 'columns_diff' (the default) is
the safest mode, ensuring the in-memory schema stays in-sync with the database
table's schema at all times. 'columns_diff_exclude_unchanged_toast' instructs
the connector to refresh the in-memory schema cache if there is a discrepancy
between it and the schema derived from the incoming message, unless unchanged
TOASTable data fully accounts [...]
| *schemaWhitelist* (postgres) | The schemas for which events should be
captured (deprecated, use schema.include.list instead) | | String
-| *skippedOperations* (postgres) | The comma-separated list of operations to
skip during streaming, defined as: 'i' for inserts; 'u' for updates; 'd' for
deletes. By default, no operations will be skipped. | | String
+| *skippedOperations* (postgres) | The comma-separated list of operations to
skip during streaming, defined as: 'c' for inserts/create; 'u' for updates; 'd'
for deletes. By default, no operations will be skipped. | | String
| *slotDropOnStop* (postgres) | Whether or not to drop the logical replication
slot when the connector finishes orderlyBy default the replication is kept so
that on restart progress can resume from the last recorded location | false |
boolean
| *slotMaxRetries* (postgres) | How many times to retry connecting to a
replication slot when an attempt fails. | 6 | int
| *slotName* (postgres) | The name of the Postgres logical decoding slot
created for streaming changes from a plugin.Defaults to 'debezium | debezium |
String
@@ -232,7 +232,7 @@ with the following path and query parameters:
| *schemaIncludeList* (postgres) | The schemas for which events should be
captured | | String
| *schemaRefreshMode* (postgres) | Specify the conditions that trigger a
refresh of the in-memory schema for a table. 'columns_diff' (the default) is
the safest mode, ensuring the in-memory schema stays in-sync with the database
table's schema at all times. 'columns_diff_exclude_unchanged_toast' instructs
the connector to refresh the in-memory schema cache if there is a discrepancy
between it and the schema derived from the incoming message, unless unchanged
TOASTable data fully accounts [...]
| *schemaWhitelist* (postgres) | The schemas for which events should be
captured (deprecated, use schema.include.list instead) | | String
-| *skippedOperations* (postgres) | The comma-separated list of operations to
skip during streaming, defined as: 'i' for inserts; 'u' for updates; 'd' for
deletes. By default, no operations will be skipped. | | String
+| *skippedOperations* (postgres) | The comma-separated list of operations to
skip during streaming, defined as: 'c' for inserts/create; 'u' for updates; 'd'
for deletes. By default, no operations will be skipped. | | String
| *slotDropOnStop* (postgres) | Whether or not to drop the logical replication
slot when the connector finishes orderlyBy default the replication is kept so
that on restart progress can resume from the last recorded location | false |
boolean
| *slotMaxRetries* (postgres) | How many times to retry connecting to a
replication slot when an attempt fails. | 6 | int
| *slotName* (postgres) | The name of the Postgres logical decoding slot
created for streaming changes from a plugin.Defaults to 'debezium | debezium |
String
diff --git
a/docs/components/modules/ROOT/pages/debezium-sqlserver-component.adoc
b/docs/components/modules/ROOT/pages/debezium-sqlserver-component.adoc
index f2e86f5..8d8174d 100644
--- a/docs/components/modules/ROOT/pages/debezium-sqlserver-component.adoc
+++ b/docs/components/modules/ROOT/pages/debezium-sqlserver-component.adoc
@@ -46,7 +46,7 @@ debezium-sqlserver:name[?options]
// component options: START
-The Debezium SQL Server Connector component supports 67 options, which are
listed below.
+The Debezium SQL Server Connector component supports 68 options, which are
listed below.
@@ -67,6 +67,7 @@ The Debezium SQL Server Connector component supports 67
options, which are liste
| *offsetStorageReplicationFactor* (consumer) | Replication factor used when
creating the offset storage topic. Required when offset.storage is set to the
KafkaOffsetBackingStore | | int
| *offsetStorageTopic* (consumer) | The name of the Kafka topic where offsets
are to be stored. Required when offset.storage is set to the
KafkaOffsetBackingStore. | | String
| *autowiredEnabled* (advanced) | Whether autowiring is enabled. This is used
for automatic autowiring options (the option must be marked as autowired) by
looking up in the registry to find if there is a single instance of matching
type, which then gets configured on the component. This can be used for
automatic configuring JDBC data sources, JMS connection factories, AWS Clients,
etc. | true | boolean
+| *binaryHandlingMode* (sqlserver) | Specify how binary (blob, binary, etc.)
columns should be represented in change events, including:'bytes' represents
binary data as byte array (default)'base64' represents binary data as
base64-encoded string'hex' represents binary data as hex-encoded (base16)
string | bytes | String
| *columnBlacklist* (sqlserver) | Regular expressions matching columns to
exclude from change events (deprecated, use column.exclude.list instead) | |
String
| *columnExcludeList* (sqlserver) | Regular expressions matching columns to
exclude from change events | | String
| *columnIncludeList* (sqlserver) | Regular expressions matching columns to
include in change events | | String
@@ -102,7 +103,7 @@ The Debezium SQL Server Connector component supports 67
options, which are liste
| *queryFetchSize* (sqlserver) | The maximum number of records that should be
loaded into memory while streaming. A value of 0 uses the default JDBC fetch
size. | 0 | int
| *retriableRestartConnectorWait{zwsp}Ms* (sqlserver) | Time to wait before
restarting connector after retriable exception occurs. Defaults to 10000ms. |
10s | long
| *sanitizeFieldNames* (sqlserver) | Whether field names will be sanitized to
Avro naming conventions | false | boolean
-| *skippedOperations* (sqlserver) | The comma-separated list of operations to
skip during streaming, defined as: 'i' for inserts; 'u' for updates; 'd' for
deletes. By default, no operations will be skipped. | | String
+| *skippedOperations* (sqlserver) | The comma-separated list of operations to
skip during streaming, defined as: 'c' for inserts/create; 'u' for updates; 'd'
for deletes. By default, no operations will be skipped. | | String
| *snapshotDelayMs* (sqlserver) | The number of milliseconds to delay before a
snapshot will begin. | 0ms | long
| *snapshotFetchSize* (sqlserver) | The maximum number of records that should
be loaded into memory while performing a snapshot | | int
| *snapshotIncludeCollectionList* (sqlserver) | this setting must be set to
specify a list of tables/collections whose snapshot must be taken on creating
or restarting the connector. | | String
@@ -143,7 +144,7 @@ with the following path and query parameters:
|===
-=== Query Parameters (67 parameters):
+=== Query Parameters (68 parameters):
[width="100%",cols="2,5,^1,2",options="header"]
@@ -163,6 +164,7 @@ with the following path and query parameters:
| *offsetStorageTopic* (consumer) | The name of the Kafka topic where offsets
are to be stored. Required when offset.storage is set to the
KafkaOffsetBackingStore. | | String
| *exceptionHandler* (consumer) | To let the consumer use a custom
ExceptionHandler. Notice if the option bridgeErrorHandler is enabled then this
option is not in use. By default the consumer will deal with exceptions, that
will be logged at WARN or ERROR level and ignored. | | ExceptionHandler
| *exchangePattern* (consumer) | Sets the exchange pattern when the consumer
creates an exchange. There are 3 enums and the value can be one of: InOnly,
InOut, InOptionalOut | | ExchangePattern
+| *binaryHandlingMode* (sqlserver) | Specify how binary (blob, binary, etc.)
columns should be represented in change events, including:'bytes' represents
binary data as byte array (default)'base64' represents binary data as
base64-encoded string'hex' represents binary data as hex-encoded (base16)
string | bytes | String
| *columnBlacklist* (sqlserver) | Regular expressions matching columns to
exclude from change events (deprecated, use column.exclude.list instead) | |
String
| *columnExcludeList* (sqlserver) | Regular expressions matching columns to
exclude from change events | | String
| *columnIncludeList* (sqlserver) | Regular expressions matching columns to
include in change events | | String
@@ -198,7 +200,7 @@ with the following path and query parameters:
| *queryFetchSize* (sqlserver) | The maximum number of records that should be
loaded into memory while streaming. A value of 0 uses the default JDBC fetch
size. | 0 | int
| *retriableRestartConnectorWait{zwsp}Ms* (sqlserver) | Time to wait before
restarting connector after retriable exception occurs. Defaults to 10000ms. |
10s | long
| *sanitizeFieldNames* (sqlserver) | Whether field names will be sanitized to
Avro naming conventions | false | boolean
-| *skippedOperations* (sqlserver) | The comma-separated list of operations to
skip during streaming, defined as: 'i' for inserts; 'u' for updates; 'd' for
deletes. By default, no operations will be skipped. | | String
+| *skippedOperations* (sqlserver) | The comma-separated list of operations to
skip during streaming, defined as: 'c' for inserts/create; 'u' for updates; 'd'
for deletes. By default, no operations will be skipped. | | String
| *snapshotDelayMs* (sqlserver) | The number of milliseconds to delay before a
snapshot will begin. | 0ms | long
| *snapshotFetchSize* (sqlserver) | The maximum number of records that should
be loaded into memory while performing a snapshot | | int
| *snapshotIncludeCollectionList* (sqlserver) | this setting must be set to
specify a list of tables/collections whose snapshot must be taken on creating
or restarting the connector. | | String
diff --git a/parent/pom.xml b/parent/pom.xml
index 215c1b0..377e925 100644
--- a/parent/pom.xml
+++ b/parent/pom.xml
@@ -161,7 +161,7 @@
<dozer-version>6.5.0</dozer-version>
<drools-version>7.48.0.Final</drools-version>
<dropbox-version>3.1.5</dropbox-version>
- <debezium-version>1.4.0.Final</debezium-version>
+ <debezium-version>1.4.1.Final</debezium-version>
<debezium-mysql-connector-version>8.0.22</debezium-mysql-connector-version>
<egit-github-core-version>2.1.5</egit-github-core-version>
<ehcache3-version>3.9.0</ehcache3-version>
