This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/camel-spring-boot.git
The following commit(s) were added to refs/heads/master by this push:
new 86d5e99 [create-pull-request] automated change
86d5e99 is described below
commit 86d5e991a221c23e0820a41fd091db6648291604
Author: github-actions[bot]
<41898282+github-actions[bot]@users.noreply.github.com>
AuthorDate: Tue Feb 2 01:07:47 2021 +0000
[create-pull-request] automated change
---
.../catalog/components/debezium-mongodb.json | 4 ++--
.../springboot/catalog/components/debezium-mysql.json | 4 ++--
.../catalog/components/debezium-postgres.json | 4 ++--
.../catalog/components/debezium-sqlserver.json | 6 ++++--
.../src/main/docs/debezium-mongodb-starter.adoc | 2 +-
.../DebeziumMongodbComponentConfiguration.java | 4 ++--
.../src/main/docs/debezium-mysql-starter.adoc | 2 +-
.../DebeziumMySqlComponentConfiguration.java | 4 ++--
.../src/main/docs/debezium-postgres-starter.adoc | 2 +-
.../DebeziumPostgresComponentConfiguration.java | 4 ++--
.../src/main/docs/debezium-sqlserver-starter.adoc | 5 +++--
.../DebeziumSqlserverComponentConfiguration.java | 19 +++++++++++++++++--
docs/modules/ROOT/pages/debezium-mongodb-starter.adoc | 2 +-
docs/modules/ROOT/pages/debezium-mysql-starter.adoc | 2 +-
.../modules/ROOT/pages/debezium-postgres-starter.adoc | 2 +-
.../ROOT/pages/debezium-sqlserver-starter.adoc | 5 +++--
16 files changed, 45 insertions(+), 26 deletions(-)
diff --git
a/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/debezium-mongodb.json
b/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/debezium-mongodb.json
index 9d0d06f..7d24856 100644
---
a/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/debezium-mongodb.json
+++
b/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/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/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/debezium-mysql.json
b/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/debezium-mysql.json
index c7cd911..2fa390d 100644
---
a/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/debezium-mysql.json
+++
b/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/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/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/debezium-postgres.json
b/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/debezium-postgres.json
index 7792f2a..a42ef5f 100644
---
a/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/debezium-postgres.json
+++
b/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/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/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/debezium-sqlserver.json
b/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/debezium-sqlserver.json
index eeeb031..d134a56 100644
---
a/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/debezium-sqlserver.json
+++
b/catalog/camel-catalog-provider-springboot/src/main/resources/org/apache/camel/springboot/catalog/components/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-starter/camel-debezium-mongodb-starter/src/main/docs/debezium-mongodb-starter.adoc
b/components-starter/camel-debezium-mongodb-starter/src/main/docs/debezium-mongodb-starter.adoc
index 02f9e93..c0f2451 100644
---
a/components-starter/camel-debezium-mongodb-starter/src/main/docs/debezium-mongodb-starter.adoc
+++
b/components-starter/camel-debezium-mongodb-starter/src/main/docs/debezium-mongodb-starter.adoc
@@ -73,7 +73,7 @@ The component supports 58 options, which are listed below.
| *camel.component.debezium-mongodb.query-fetch-size* | The maximum number of
records that should be loaded into memory while streaming. A value of 0 uses
the default JDBC fetch size. | 0 | Integer
| *camel.component.debezium-mongodb.retriable-restart-connector-wait-ms* |
Time to wait before restarting connector after retriable exception occurs.
Defaults to 10000ms. The option is a long type. | 10000 | Long
| *camel.component.debezium-mongodb.sanitize-field-names* | Whether field
names will be sanitized to Avro naming conventions | false | Boolean
-| *camel.component.debezium-mongodb.skipped-operations* | 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
+| *camel.component.debezium-mongodb.skipped-operations* | 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
| *camel.component.debezium-mongodb.snapshot-collection-filter-overrides* |
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
| *camel.component.debezium-mongodb.snapshot-delay-ms* | The number of
milliseconds to delay before a snapshot will begin. The option is a long type.
| 0 | Long
| *camel.component.debezium-mongodb.snapshot-fetch-size* | The maximum number
of records that should be loaded into memory while performing a snapshot | |
Integer
diff --git
a/components-starter/camel-debezium-mongodb-starter/src/main/java/org/apache/camel/component/debezium/springboot/DebeziumMongodbComponentConfiguration.java
b/components-starter/camel-debezium-mongodb-starter/src/main/java/org/apache/camel/component/debezium/springboot/DebeziumMongodbComponentConfiguration.java
index 3b6b005..b0d49ce 100644
---
a/components-starter/camel-debezium-mongodb-starter/src/main/java/org/apache/camel/component/debezium/springboot/DebeziumMongodbComponentConfiguration.java
+++
b/components-starter/camel-debezium-mongodb-starter/src/main/java/org/apache/camel/component/debezium/springboot/DebeziumMongodbComponentConfiguration.java
@@ -304,8 +304,8 @@ public class DebeziumMongodbComponentConfiguration
private Boolean sanitizeFieldNames = false;
/**
* 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.
*/
private String skippedOperations;
/**
diff --git
a/components-starter/camel-debezium-mysql-starter/src/main/docs/debezium-mysql-starter.adoc
b/components-starter/camel-debezium-mysql-starter/src/main/docs/debezium-mysql-starter.adoc
index 09dac99..4f36778 100644
---
a/components-starter/camel-debezium-mysql-starter/src/main/docs/debezium-mysql-starter.adoc
+++
b/components-starter/camel-debezium-mysql-starter/src/main/docs/debezium-mysql-starter.adoc
@@ -89,7 +89,7 @@ The component supports 81 options, which are listed below.
| *camel.component.debezium-mysql.offset-storage-replication-factor* |
Replication factor used when creating the offset storage topic. Required when
offset.storage is set to the KafkaOffsetBackingStore | | Integer
| *camel.component.debezium-mysql.offset-storage-topic* | The name of the
Kafka topic where offsets are to be stored. Required when offset.storage is set
to the KafkaOffsetBackingStore. | | String
| *camel.component.debezium-mysql.poll-interval-ms* | Frequency in
milliseconds to wait for new change events to appear after receiving no events.
Defaults to 500ms. The option is a long type. | 500 | Long
-| *camel.component.debezium-mysql.skipped-operations* | 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
+| *camel.component.debezium-mysql.skipped-operations* | 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
| *camel.component.debezium-mysql.snapshot-delay-ms* | The number of
milliseconds to delay before a snapshot will begin. The option is a long type.
| 0 | Long
| *camel.component.debezium-mysql.snapshot-events-as-inserts* | 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
| *camel.component.debezium-mysql.snapshot-fetch-size* | The maximum number of
records that should be loaded into memory while performing a snapshot | |
Integer
diff --git
a/components-starter/camel-debezium-mysql-starter/src/main/java/org/apache/camel/component/debezium/springboot/DebeziumMySqlComponentConfiguration.java
b/components-starter/camel-debezium-mysql-starter/src/main/java/org/apache/camel/component/debezium/springboot/DebeziumMySqlComponentConfiguration.java
index 50100b4..0fac27c 100644
---
a/components-starter/camel-debezium-mysql-starter/src/main/java/org/apache/camel/component/debezium/springboot/DebeziumMySqlComponentConfiguration.java
+++
b/components-starter/camel-debezium-mysql-starter/src/main/java/org/apache/camel/component/debezium/springboot/DebeziumMySqlComponentConfiguration.java
@@ -452,8 +452,8 @@ public class DebeziumMySqlComponentConfiguration
private Long pollIntervalMs = 500L;
/**
* 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.
*/
private String skippedOperations;
/**
diff --git
a/components-starter/camel-debezium-postgres-starter/src/main/docs/debezium-postgres-starter.adoc
b/components-starter/camel-debezium-postgres-starter/src/main/docs/debezium-postgres-starter.adoc
index e868af2..88bf4ae 100644
---
a/components-starter/camel-debezium-postgres-starter/src/main/docs/debezium-postgres-starter.adoc
+++
b/components-starter/camel-debezium-postgres-starter/src/main/docs/debezium-postgres-starter.adoc
@@ -87,7 +87,7 @@ The component supports 88 options, which are listed below.
| *camel.component.debezium-postgres.schema-include-list* | The schemas for
which events should be captured | | String
| *camel.component.debezium-postgres.schema-refresh-mode* | 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 TOAS [...]
| *camel.component.debezium-postgres.schema-whitelist* | The schemas for which
events should be captured (deprecated, use schema.include.list instead) | |
String
-| *camel.component.debezium-postgres.skipped-operations* | 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
+| *camel.component.debezium-postgres.skipped-operations* | 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
| *camel.component.debezium-postgres.slot-drop-on-stop* | 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
| *camel.component.debezium-postgres.slot-max-retries* | How many times to
retry connecting to a replication slot when an attempt fails. | 6 | Integer
| *camel.component.debezium-postgres.slot-name* | The name of the Postgres
logical decoding slot created for streaming changes from a plugin.Defaults to
'debezium | debezium | String
diff --git
a/components-starter/camel-debezium-postgres-starter/src/main/java/org/apache/camel/component/debezium/springboot/DebeziumPostgresComponentConfiguration.java
b/components-starter/camel-debezium-postgres-starter/src/main/java/org/apache/camel/component/debezium/springboot/DebeziumPostgresComponentConfiguration.java
index 1961223..d72c631 100644
---
a/components-starter/camel-debezium-postgres-starter/src/main/java/org/apache/camel/component/debezium/springboot/DebeziumPostgresComponentConfiguration.java
+++
b/components-starter/camel-debezium-postgres-starter/src/main/java/org/apache/camel/component/debezium/springboot/DebeziumPostgresComponentConfiguration.java
@@ -420,8 +420,8 @@ public class DebeziumPostgresComponentConfiguration
private String schemaWhitelist;
/**
* 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.
*/
private String skippedOperations;
/**
diff --git
a/components-starter/camel-debezium-sqlserver-starter/src/main/docs/debezium-sqlserver-starter.adoc
b/components-starter/camel-debezium-sqlserver-starter/src/main/docs/debezium-sqlserver-starter.adoc
index 549a592..63c6035 100644
---
a/components-starter/camel-debezium-sqlserver-starter/src/main/docs/debezium-sqlserver-starter.adoc
+++
b/components-starter/camel-debezium-sqlserver-starter/src/main/docs/debezium-sqlserver-starter.adoc
@@ -17,7 +17,7 @@ When using debezium-sqlserver with Spring Boot make sure to
use the following Ma
----
-The component supports 68 options, which are listed below.
+The component supports 69 options, which are listed below.
@@ -26,6 +26,7 @@ The component supports 68 options, which are listed below.
| Name | Description | Default | Type
| *camel.component.debezium-sqlserver.additional-properties* | Additional
properties for debezium components in case they can't be set directly on the
camel configurations (e.g: setting Kafka Connect properties needed by Debezium
engine, for example setting KafkaOffsetBackingStore), the properties have to be
prefixed with additionalProperties.. E.g:
additionalProperties.transactional.id=12345&additionalProperties.schema.registry.url=\http://localhost:8811/avro
| | Map
| *camel.component.debezium-sqlserver.autowired-enabled* | 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
+| *camel.component.debezium-sqlserver.binary-handling-mode* | 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
| *camel.component.debezium-sqlserver.bridge-error-handler* | Allows for
bridging the consumer to the Camel routing Error Handler, which mean any
exceptions occurred while the consumer is trying to pickup incoming messages,
or the likes, will now be processed as a message and handled by the routing
Error Handler. By default the consumer will use the
org.apache.camel.spi.ExceptionHandler to deal with exceptions, that will be
logged at WARN or ERROR level and ignored. | false | Boolean
| *camel.component.debezium-sqlserver.column-blacklist* | Regular expressions
matching columns to exclude from change events (deprecated, use
column.exclude.list instead) | | String
| *camel.component.debezium-sqlserver.column-exclude-list* | Regular
expressions matching columns to exclude from change events | | String
@@ -74,7 +75,7 @@ The component supports 68 options, which are listed below.
| *camel.component.debezium-sqlserver.query-fetch-size* | The maximum number
of records that should be loaded into memory while streaming. A value of 0 uses
the default JDBC fetch size. | 0 | Integer
| *camel.component.debezium-sqlserver.retriable-restart-connector-wait-ms* |
Time to wait before restarting connector after retriable exception occurs.
Defaults to 10000ms. The option is a long type. | 10000 | Long
| *camel.component.debezium-sqlserver.sanitize-field-names* | Whether field
names will be sanitized to Avro naming conventions | false | Boolean
-| *camel.component.debezium-sqlserver.skipped-operations* | 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
+| *camel.component.debezium-sqlserver.skipped-operations* | 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
| *camel.component.debezium-sqlserver.snapshot-delay-ms* | The number of
milliseconds to delay before a snapshot will begin. The option is a long type.
| 0 | Long
| *camel.component.debezium-sqlserver.snapshot-fetch-size* | The maximum
number of records that should be loaded into memory while performing a snapshot
| | Integer
| *camel.component.debezium-sqlserver.snapshot-include-collection-list* | 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-starter/camel-debezium-sqlserver-starter/src/main/java/org/apache/camel/component/debezium/springboot/DebeziumSqlserverComponentConfiguration.java
b/components-starter/camel-debezium-sqlserver-starter/src/main/java/org/apache/camel/component/debezium/springboot/DebeziumSqlserverComponentConfiguration.java
index 1a835ae..6a205f0 100644
---
a/components-starter/camel-debezium-sqlserver-starter/src/main/java/org/apache/camel/component/debezium/springboot/DebeziumSqlserverComponentConfiguration.java
+++
b/components-starter/camel-debezium-sqlserver-starter/src/main/java/org/apache/camel/component/debezium/springboot/DebeziumSqlserverComponentConfiguration.java
@@ -126,6 +126,13 @@ public class DebeziumSqlserverComponentConfiguration
*/
private Boolean autowiredEnabled = true;
/**
+ * 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
+ */
+ private String binaryHandlingMode = "bytes";
+ /**
* Regular expressions matching columns to exclude from change events
* (deprecated, use column.exclude.list instead)
*/
@@ -327,8 +334,8 @@ public class DebeziumSqlserverComponentConfiguration
private Boolean sanitizeFieldNames = false;
/**
* 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.
*/
private String skippedOperations;
/**
@@ -569,6 +576,14 @@ public class DebeziumSqlserverComponentConfiguration
this.autowiredEnabled = autowiredEnabled;
}
+ public String getBinaryHandlingMode() {
+ return binaryHandlingMode;
+ }
+
+ public void setBinaryHandlingMode(String binaryHandlingMode) {
+ this.binaryHandlingMode = binaryHandlingMode;
+ }
+
public String getColumnBlacklist() {
return columnBlacklist;
}
diff --git a/docs/modules/ROOT/pages/debezium-mongodb-starter.adoc
b/docs/modules/ROOT/pages/debezium-mongodb-starter.adoc
index 02f9e93..c0f2451 100644
--- a/docs/modules/ROOT/pages/debezium-mongodb-starter.adoc
+++ b/docs/modules/ROOT/pages/debezium-mongodb-starter.adoc
@@ -73,7 +73,7 @@ The component supports 58 options, which are listed below.
| *camel.component.debezium-mongodb.query-fetch-size* | The maximum number of
records that should be loaded into memory while streaming. A value of 0 uses
the default JDBC fetch size. | 0 | Integer
| *camel.component.debezium-mongodb.retriable-restart-connector-wait-ms* |
Time to wait before restarting connector after retriable exception occurs.
Defaults to 10000ms. The option is a long type. | 10000 | Long
| *camel.component.debezium-mongodb.sanitize-field-names* | Whether field
names will be sanitized to Avro naming conventions | false | Boolean
-| *camel.component.debezium-mongodb.skipped-operations* | 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
+| *camel.component.debezium-mongodb.skipped-operations* | 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
| *camel.component.debezium-mongodb.snapshot-collection-filter-overrides* |
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
| *camel.component.debezium-mongodb.snapshot-delay-ms* | The number of
milliseconds to delay before a snapshot will begin. The option is a long type.
| 0 | Long
| *camel.component.debezium-mongodb.snapshot-fetch-size* | The maximum number
of records that should be loaded into memory while performing a snapshot | |
Integer
diff --git a/docs/modules/ROOT/pages/debezium-mysql-starter.adoc
b/docs/modules/ROOT/pages/debezium-mysql-starter.adoc
index 09dac99..4f36778 100644
--- a/docs/modules/ROOT/pages/debezium-mysql-starter.adoc
+++ b/docs/modules/ROOT/pages/debezium-mysql-starter.adoc
@@ -89,7 +89,7 @@ The component supports 81 options, which are listed below.
| *camel.component.debezium-mysql.offset-storage-replication-factor* |
Replication factor used when creating the offset storage topic. Required when
offset.storage is set to the KafkaOffsetBackingStore | | Integer
| *camel.component.debezium-mysql.offset-storage-topic* | The name of the
Kafka topic where offsets are to be stored. Required when offset.storage is set
to the KafkaOffsetBackingStore. | | String
| *camel.component.debezium-mysql.poll-interval-ms* | Frequency in
milliseconds to wait for new change events to appear after receiving no events.
Defaults to 500ms. The option is a long type. | 500 | Long
-| *camel.component.debezium-mysql.skipped-operations* | 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
+| *camel.component.debezium-mysql.skipped-operations* | 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
| *camel.component.debezium-mysql.snapshot-delay-ms* | The number of
milliseconds to delay before a snapshot will begin. The option is a long type.
| 0 | Long
| *camel.component.debezium-mysql.snapshot-events-as-inserts* | 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
| *camel.component.debezium-mysql.snapshot-fetch-size* | The maximum number of
records that should be loaded into memory while performing a snapshot | |
Integer
diff --git a/docs/modules/ROOT/pages/debezium-postgres-starter.adoc
b/docs/modules/ROOT/pages/debezium-postgres-starter.adoc
index e868af2..88bf4ae 100644
--- a/docs/modules/ROOT/pages/debezium-postgres-starter.adoc
+++ b/docs/modules/ROOT/pages/debezium-postgres-starter.adoc
@@ -87,7 +87,7 @@ The component supports 88 options, which are listed below.
| *camel.component.debezium-postgres.schema-include-list* | The schemas for
which events should be captured | | String
| *camel.component.debezium-postgres.schema-refresh-mode* | 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 TOAS [...]
| *camel.component.debezium-postgres.schema-whitelist* | The schemas for which
events should be captured (deprecated, use schema.include.list instead) | |
String
-| *camel.component.debezium-postgres.skipped-operations* | 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
+| *camel.component.debezium-postgres.skipped-operations* | 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
| *camel.component.debezium-postgres.slot-drop-on-stop* | 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
| *camel.component.debezium-postgres.slot-max-retries* | How many times to
retry connecting to a replication slot when an attempt fails. | 6 | Integer
| *camel.component.debezium-postgres.slot-name* | The name of the Postgres
logical decoding slot created for streaming changes from a plugin.Defaults to
'debezium | debezium | String
diff --git a/docs/modules/ROOT/pages/debezium-sqlserver-starter.adoc
b/docs/modules/ROOT/pages/debezium-sqlserver-starter.adoc
index 549a592..63c6035 100644
--- a/docs/modules/ROOT/pages/debezium-sqlserver-starter.adoc
+++ b/docs/modules/ROOT/pages/debezium-sqlserver-starter.adoc
@@ -17,7 +17,7 @@ When using debezium-sqlserver with Spring Boot make sure to
use the following Ma
----
-The component supports 68 options, which are listed below.
+The component supports 69 options, which are listed below.
@@ -26,6 +26,7 @@ The component supports 68 options, which are listed below.
| Name | Description | Default | Type
| *camel.component.debezium-sqlserver.additional-properties* | Additional
properties for debezium components in case they can't be set directly on the
camel configurations (e.g: setting Kafka Connect properties needed by Debezium
engine, for example setting KafkaOffsetBackingStore), the properties have to be
prefixed with additionalProperties.. E.g:
additionalProperties.transactional.id=12345&additionalProperties.schema.registry.url=\http://localhost:8811/avro
| | Map
| *camel.component.debezium-sqlserver.autowired-enabled* | 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
+| *camel.component.debezium-sqlserver.binary-handling-mode* | 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
| *camel.component.debezium-sqlserver.bridge-error-handler* | Allows for
bridging the consumer to the Camel routing Error Handler, which mean any
exceptions occurred while the consumer is trying to pickup incoming messages,
or the likes, will now be processed as a message and handled by the routing
Error Handler. By default the consumer will use the
org.apache.camel.spi.ExceptionHandler to deal with exceptions, that will be
logged at WARN or ERROR level and ignored. | false | Boolean
| *camel.component.debezium-sqlserver.column-blacklist* | Regular expressions
matching columns to exclude from change events (deprecated, use
column.exclude.list instead) | | String
| *camel.component.debezium-sqlserver.column-exclude-list* | Regular
expressions matching columns to exclude from change events | | String
@@ -74,7 +75,7 @@ The component supports 68 options, which are listed below.
| *camel.component.debezium-sqlserver.query-fetch-size* | The maximum number
of records that should be loaded into memory while streaming. A value of 0 uses
the default JDBC fetch size. | 0 | Integer
| *camel.component.debezium-sqlserver.retriable-restart-connector-wait-ms* |
Time to wait before restarting connector after retriable exception occurs.
Defaults to 10000ms. The option is a long type. | 10000 | Long
| *camel.component.debezium-sqlserver.sanitize-field-names* | Whether field
names will be sanitized to Avro naming conventions | false | Boolean
-| *camel.component.debezium-sqlserver.skipped-operations* | 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
+| *camel.component.debezium-sqlserver.skipped-operations* | 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
| *camel.component.debezium-sqlserver.snapshot-delay-ms* | The number of
milliseconds to delay before a snapshot will begin. The option is a long type.
| 0 | Long
| *camel.component.debezium-sqlserver.snapshot-fetch-size* | The maximum
number of records that should be loaded into memory while performing a snapshot
| | Integer
| *camel.component.debezium-sqlserver.snapshot-include-collection-list* | this
setting must be set to specify a list of tables/collections whose snapshot must
be taken on creating or restarting the connector. | | String
