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 41c1bd4 Regen after master updates
41c1bd4 is described below
commit 41c1bd45bf414f234abf48eb9b78c71e66189c6b
Author: Andrea Cosentino <[email protected]>
AuthorDate: Tue Mar 24 16:18:27 2020 +0100
Regen after master updates
---
.../catalog/components/debezium-mongodb.json | 6 ++-
.../catalog/components/debezium-mysql.json | 10 +++--
.../catalog/components/debezium-postgres.json | 10 ++++-
.../catalog/components/debezium-sqlserver.json | 4 ++
components-starter/camel-corda-starter/pom.xml | 12 ++++++
.../src/main/docs/debezium-mongodb-starter.adoc | 5 ++-
.../DebeziumMongodbComponentConfiguration.java | 16 +++++++-
.../src/main/docs/debezium-mysql-starter.adoc | 7 ++--
.../DebeziumMySqlComponentConfiguration.java | 26 ++++++++++--
.../src/main/docs/debezium-postgres-starter.adoc | 7 +++-
.../DebeziumPostgresComponentConfiguration.java | 46 +++++++++++++++++++++-
.../src/main/docs/debezium-sqlserver-starter.adoc | 4 +-
.../DebeziumSqlserverComponentConfiguration.java | 30 ++++++++++++++
.../ROOT/pages/debezium-mongodb-starter.adoc | 5 ++-
.../modules/ROOT/pages/debezium-mysql-starter.adoc | 7 ++--
.../ROOT/pages/debezium-postgres-starter.adoc | 7 +++-
.../ROOT/pages/debezium-sqlserver-starter.adoc | 4 +-
tooling/camel-spring-boot-dependencies/pom.xml | 5 +++
18 files changed, 180 insertions(+), 31 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 bd648c9..91586d5 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
@@ -45,7 +45,7 @@
"fieldRenames": { "kind": "property", "displayName": "Field Renames",
"group": "mongodb", "label": "consumer,mongodb", "required": false, "type":
"string", "javaType": "java.lang.String", "deprecated": false, "secret": false,
"configurationClass":
"org.apache.camel.component.debezium.configuration.MongoDbConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "Description is not
available here, please check Debezium website for corresponding key [...]
"heartbeatIntervalMs": { "kind": "property", "displayName": "Heartbeat
Interval Ms", "group": "mongodb", "label": "consumer,mongodb", "required":
false, "type": "integer", "javaType": "int", "deprecated": false, "secret":
false, "defaultValue": "0", "configurationClass":
"org.apache.camel.component.debezium.configuration.MongoDbConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "Length of an interval
in milli-seconds in in which the connect [...]
"heartbeatTopicsPrefix": { "kind": "property", "displayName": "Heartbeat
Topics Prefix", "group": "mongodb", "label": "consumer,mongodb", "required":
false, "type": "string", "javaType": "java.lang.String", "deprecated": false,
"secret": false, "defaultValue": "__debezium-heartbeat", "configurationClass":
"org.apache.camel.component.debezium.configuration.MongoDbConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "The prefix that is used
to [...]
- "initialSyncMaxThreads": { "kind": "property", "displayName": "Initial
Sync Max Threads", "group": "mongodb", "label": "consumer,mongodb", "required":
false, "type": "integer", "javaType": "int", "deprecated": false, "secret":
false, "defaultValue": "1", "configurationClass":
"org.apache.camel.component.debezium.configuration.MongoDbConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "Maximum number of
threads used to perform an intial sync [...]
+ "initialSyncMaxThreads": { "kind": "property", "displayName": "Initial
Sync Max Threads", "group": "mongodb", "label": "consumer,mongodb", "required":
false, "type": "integer", "javaType": "int", "deprecated": false, "secret":
false, "defaultValue": "1", "configurationClass":
"org.apache.camel.component.debezium.configuration.MongoDbConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "Maximum number of
threads used to perform an initial sync [...]
"maxBatchSize": { "kind": "property", "displayName": "Max Batch Size",
"group": "mongodb", "label": "consumer,mongodb", "required": false, "type":
"integer", "javaType": "int", "deprecated": false, "secret": false,
"defaultValue": "2048", "configurationClass":
"org.apache.camel.component.debezium.configuration.MongoDbConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "Maximum size of each
batch of source records. Defaults to 2048." },
"maxQueueSize": { "kind": "property", "displayName": "Max Queue Size",
"group": "mongodb", "label": "consumer,mongodb", "required": false, "type":
"integer", "javaType": "int", "deprecated": false, "secret": false,
"defaultValue": "8192", "configurationClass":
"org.apache.camel.component.debezium.configuration.MongoDbConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "Maximum size of the
queue for change events read from the database log bu [...]
"mongodbHosts": { "kind": "property", "displayName": "Mongodb Hosts",
"group": "mongodb", "label": "consumer,mongodb", "required": false, "type":
"string", "javaType": "java.lang.String", "deprecated": false, "secret": false,
"configurationClass":
"org.apache.camel.component.debezium.configuration.MongoDbConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "The hostname and port
pairs (in the form 'host' or 'host:port') of the MongoDB server( [...]
@@ -56,6 +56,7 @@
"mongodbSslInvalidHostnameAllowed": { "kind": "property", "displayName":
"Mongodb Ssl Invalid Hostname Allowed", "group": "mongodb", "label":
"consumer,mongodb", "required": false, "type": "boolean", "javaType":
"boolean", "deprecated": false, "secret": false, "defaultValue": "false",
"configurationClass":
"org.apache.camel.component.debezium.configuration.MongoDbConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "Whether invalid host
names [...]
"mongodbUser": { "kind": "property", "displayName": "Mongodb User",
"group": "mongodb", "label": "consumer,mongodb", "required": false, "type":
"string", "javaType": "java.lang.String", "deprecated": false, "secret": false,
"configurationClass":
"org.apache.camel.component.debezium.configuration.MongoDbConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "Database user for
connecting to MongoDB, if necessary." },
"pollIntervalMs": { "kind": "property", "displayName": "Poll Interval Ms",
"group": "mongodb", "label": "consumer,mongodb", "required": false, "type":
"integer", "javaType": "long", "deprecated": false, "secret": false,
"defaultValue": "500", "configurationClass":
"org.apache.camel.component.debezium.configuration.MongoDbConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "Frequency in
milliseconds to wait for new change events to appear aft [...]
+ "skippedOperations": { "kind": "property", "displayName": "Skipped
Operations", "group": "mongodb", "label": "consumer,mongodb", "required":
false, "type": "string", "javaType": "java.lang.String", "deprecated": false,
"secret": false, "configurationClass":
"org.apache.camel.component.debezium.configuration.MongoDbConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "The comma-separated
list of operations to skip during streaming, defined as: [...]
"snapshotDelayMs": { "kind": "property", "displayName": "Snapshot Delay
Ms", "group": "mongodb", "label": "consumer,mongodb", "required": false,
"type": "integer", "javaType": "long", "deprecated": false, "secret": false,
"defaultValue": "0", "configurationClass":
"org.apache.camel.component.debezium.configuration.MongoDbConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "The number of
milliseconds to delay before a snapshot will begin." },
"snapshotFetchSize": { "kind": "property", "displayName": "Snapshot Fetch
Size", "group": "mongodb", "label": "consumer,mongodb", "required": false,
"type": "integer", "javaType": "int", "deprecated": 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 while performing a snap [...]
"snapshotMode": { "kind": "property", "displayName": "Snapshot Mode",
"group": "mongodb", "label": "consumer,mongodb", "required": false, "type":
"string", "javaType": "java.lang.String", "deprecated": false, "secret": false,
"defaultValue": "initial", "configurationClass":
"org.apache.camel.component.debezium.configuration.MongoDbConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "The criteria for
running a snapshot upon startup of the con [...]
@@ -92,7 +93,7 @@
"fieldRenames": { "kind": "parameter", "displayName": "Field Renames",
"group": "mongodb", "label": "consumer,mongodb", "required": false, "type":
"string", "javaType": "java.lang.String", "deprecated": false, "secret": false,
"configurationClass":
"org.apache.camel.component.debezium.configuration.MongoDbConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "Description is not
available here, please check Debezium website for corresponding ke [...]
"heartbeatIntervalMs": { "kind": "parameter", "displayName": "Heartbeat
Interval Ms", "group": "mongodb", "label": "consumer,mongodb", "required":
false, "type": "integer", "javaType": "int", "deprecated": false, "secret":
false, "defaultValue": "0", "configurationClass":
"org.apache.camel.component.debezium.configuration.MongoDbConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "Length of an interval
in milli-seconds in in which the connec [...]
"heartbeatTopicsPrefix": { "kind": "parameter", "displayName": "Heartbeat
Topics Prefix", "group": "mongodb", "label": "consumer,mongodb", "required":
false, "type": "string", "javaType": "java.lang.String", "deprecated": false,
"secret": false, "defaultValue": "__debezium-heartbeat", "configurationClass":
"org.apache.camel.component.debezium.configuration.MongoDbConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "The prefix that is used
to [...]
- "initialSyncMaxThreads": { "kind": "parameter", "displayName": "Initial
Sync Max Threads", "group": "mongodb", "label": "consumer,mongodb", "required":
false, "type": "integer", "javaType": "int", "deprecated": false, "secret":
false, "defaultValue": "1", "configurationClass":
"org.apache.camel.component.debezium.configuration.MongoDbConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "Maximum number of
threads used to perform an intial sync [...]
+ "initialSyncMaxThreads": { "kind": "parameter", "displayName": "Initial
Sync Max Threads", "group": "mongodb", "label": "consumer,mongodb", "required":
false, "type": "integer", "javaType": "int", "deprecated": false, "secret":
false, "defaultValue": "1", "configurationClass":
"org.apache.camel.component.debezium.configuration.MongoDbConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "Maximum number of
threads used to perform an initial syn [...]
"maxBatchSize": { "kind": "parameter", "displayName": "Max Batch Size",
"group": "mongodb", "label": "consumer,mongodb", "required": false, "type":
"integer", "javaType": "int", "deprecated": false, "secret": false,
"defaultValue": "2048", "configurationClass":
"org.apache.camel.component.debezium.configuration.MongoDbConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "Maximum size of each
batch of source records. Defaults to 2048." },
"maxQueueSize": { "kind": "parameter", "displayName": "Max Queue Size",
"group": "mongodb", "label": "consumer,mongodb", "required": false, "type":
"integer", "javaType": "int", "deprecated": false, "secret": false,
"defaultValue": "8192", "configurationClass":
"org.apache.camel.component.debezium.configuration.MongoDbConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "Maximum size of the
queue for change events read from the database log b [...]
"mongodbHosts": { "kind": "parameter", "displayName": "Mongodb Hosts",
"group": "mongodb", "label": "consumer,mongodb", "required": false, "type":
"string", "javaType": "java.lang.String", "deprecated": false, "secret": false,
"configurationClass":
"org.apache.camel.component.debezium.configuration.MongoDbConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "The hostname and port
pairs (in the form 'host' or 'host:port') of the MongoDB server [...]
@@ -103,6 +104,7 @@
"mongodbSslInvalidHostnameAllowed": { "kind": "parameter", "displayName":
"Mongodb Ssl Invalid Hostname Allowed", "group": "mongodb", "label":
"consumer,mongodb", "required": false, "type": "boolean", "javaType":
"boolean", "deprecated": false, "secret": false, "defaultValue": "false",
"configurationClass":
"org.apache.camel.component.debezium.configuration.MongoDbConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "Whether invalid host
name [...]
"mongodbUser": { "kind": "parameter", "displayName": "Mongodb User",
"group": "mongodb", "label": "consumer,mongodb", "required": false, "type":
"string", "javaType": "java.lang.String", "deprecated": false, "secret": false,
"configurationClass":
"org.apache.camel.component.debezium.configuration.MongoDbConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "Database user for
connecting to MongoDB, if necessary." },
"pollIntervalMs": { "kind": "parameter", "displayName": "Poll Interval
Ms", "group": "mongodb", "label": "consumer,mongodb", "required": false,
"type": "integer", "javaType": "long", "deprecated": false, "secret": false,
"defaultValue": "500", "configurationClass":
"org.apache.camel.component.debezium.configuration.MongoDbConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "Frequency in
milliseconds to wait for new change events to appear af [...]
+ "skippedOperations": { "kind": "parameter", "displayName": "Skipped
Operations", "group": "mongodb", "label": "consumer,mongodb", "required":
false, "type": "string", "javaType": "java.lang.String", "deprecated": false,
"secret": false, "configurationClass":
"org.apache.camel.component.debezium.configuration.MongoDbConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "The comma-separated
list of operations to skip during streaming, defined as [...]
"snapshotDelayMs": { "kind": "parameter", "displayName": "Snapshot Delay
Ms", "group": "mongodb", "label": "consumer,mongodb", "required": false,
"type": "integer", "javaType": "long", "deprecated": false, "secret": false,
"defaultValue": "0", "configurationClass":
"org.apache.camel.component.debezium.configuration.MongoDbConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "The number of
milliseconds to delay before a snapshot will begin." },
"snapshotFetchSize": { "kind": "parameter", "displayName": "Snapshot Fetch
Size", "group": "mongodb", "label": "consumer,mongodb", "required": false,
"type": "integer", "javaType": "int", "deprecated": 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 while performing a sna [...]
"snapshotMode": { "kind": "parameter", "displayName": "Snapshot Mode",
"group": "mongodb", "label": "consumer,mongodb", "required": false, "type":
"string", "javaType": "java.lang.String", "deprecated": false, "secret": false,
"defaultValue": "initial", "configurationClass":
"org.apache.camel.component.debezium.configuration.MongoDbConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "The criteria for
running a snapshot upon startup of the co [...]
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 efa34fa..1ee39fb 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
@@ -66,7 +66,8 @@
"decimalHandlingMode": { "kind": "property", "displayName": "Decimal
Handling Mode", "group": "mysql", "label": "consumer,mysql", "required": false,
"type": "string", "javaType": "java.lang.String", "deprecated": false,
"secret": false, "defaultValue": "precise", "configurationClass":
"org.apache.camel.component.debezium.configuration.MySqlConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "Specify how DECIMAL and
NUMERIC columns should be [...]
"enableTimeAdjuster": { "kind": "property", "displayName": "Enable Time
Adjuster", "group": "mysql", "label": "consumer,mysql", "required": false,
"type": "boolean", "javaType": "boolean", "deprecated": false, "secret": false,
"defaultValue": "true", "configurationClass":
"org.apache.camel.component.debezium.configuration.MySqlConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "MySQL allows user to
insert year value as either 2-digit or 4-d [...]
"eventDeserializationFailureHandlingMode": { "kind": "property",
"displayName": "Event Deserialization Failure Handling Mode", "group": "mysql",
"label": "consumer,mysql", "required": false, "type": "string", "javaType":
"java.lang.String", "deprecated": false, "secret": false, "defaultValue":
"fail", "configurationClass":
"org.apache.camel.component.debezium.configuration.MySqlConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "Specify how [...]
- "gtidNewChannelPosition": { "kind": "property", "displayName": "Gtid New
Channel Position", "group": "mysql", "label": "consumer,mysql", "required":
false, "type": "string", "javaType": "java.lang.String", "deprecated": false,
"secret": false, "defaultValue": "latest", "configurationClass":
"org.apache.camel.component.debezium.configuration.MySqlConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "If set to 'latest',
when connector sees new [...]
+ "eventProcessingFailureHandlingMode": { "kind": "property", "displayName":
"Event Processing Failure Handling Mode", "group": "mysql", "label":
"consumer,mysql", "required": false, "type": "string", "javaType":
"java.lang.String", "deprecated": false, "secret": false, "defaultValue":
"fail", "configurationClass":
"org.apache.camel.component.debezium.configuration.MySqlConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "Specify how failures
[...]
+ "gtidNewChannelPosition": { "kind": "property", "displayName": "Gtid New
Channel Position", "group": "mysql", "label": "consumer,mysql", "required":
false, "type": "string", "javaType": "java.lang.String", "deprecated": false,
"secret": false, "defaultValue": "earliest", "configurationClass":
"org.apache.camel.component.debezium.configuration.MySqlConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "If set to 'latest',
when connector sees ne [...]
"gtidSourceExcludes": { "kind": "property", "displayName": "Gtid Source
Excludes", "group": "mysql", "label": "consumer,mysql", "required": false,
"type": "string", "javaType": "java.lang.String", "deprecated": false,
"secret": false, "configurationClass":
"org.apache.camel.component.debezium.configuration.MySqlConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "The source UUIDs used
to exclude GTID ranges when determine the starting positi [...]
"gtidSourceFilterDmlEvents": { "kind": "property", "displayName": "Gtid
Source Filter Dml Events", "group": "mysql", "label": "consumer,mysql",
"required": false, "type": "boolean", "javaType": "boolean", "deprecated":
false, "secret": false, "defaultValue": "true", "configurationClass":
"org.apache.camel.component.debezium.configuration.MySqlConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "If set to true, we will
only produce DML events [...]
"gtidSourceIncludes": { "kind": "property", "displayName": "Gtid Source
Includes", "group": "mysql", "label": "consumer,mysql", "required": false,
"type": "string", "javaType": "java.lang.String", "deprecated": false,
"secret": false, "configurationClass":
"org.apache.camel.component.debezium.configuration.MySqlConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "The source UUIDs used
to include GTID ranges when determine the starting positi [...]
@@ -74,7 +75,7 @@
"heartbeatTopicsPrefix": { "kind": "property", "displayName": "Heartbeat
Topics Prefix", "group": "mysql", "label": "consumer,mysql", "required": false,
"type": "string", "javaType": "java.lang.String", "deprecated": false,
"secret": false, "defaultValue": "__debezium-heartbeat", "configurationClass":
"org.apache.camel.component.debezium.configuration.MySqlConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "The prefix that is used
to name h [...]
"includeQuery": { "kind": "property", "displayName": "Include Query",
"group": "mysql", "label": "consumer,mysql", "required": false, "type":
"boolean", "javaType": "boolean", "deprecated": false, "secret": false,
"defaultValue": "false", "configurationClass":
"org.apache.camel.component.debezium.configuration.MySqlConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "Whether the connector
should include the original SQL query that generated [...]
"includeSchemaChanges": { "kind": "property", "displayName": "Include
Schema Changes", "group": "mysql", "label": "consumer,mysql", "required":
false, "type": "boolean", "javaType": "boolean", "deprecated": false, "secret":
false, "defaultValue": "true", "configurationClass":
"org.apache.camel.component.debezium.configuration.MySqlConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "Whether the connector
should publish changes in the databas [...]
- "inconsistentSchemaHandlingMode": { "kind": "property", "displayName":
"Inconsistent Schema Handling Mode", "group": "mysql", "label":
"consumer,mysql", "required": false, "type": "string", "javaType":
"java.lang.String", "deprecated": false, "secret": false, "defaultValue":
"fail", "configurationClass":
"org.apache.camel.component.debezium.configuration.MySqlConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "Specify how binlog
events that [...]
+ "inconsistentSchemaHandlingMode": { "kind": "property", "displayName":
"Inconsistent Schema Handling Mode", "group": "mysql", "label":
"consumer,mysql", "required": false, "type": "string", "javaType":
"java.lang.String", "deprecated": false, "secret": false, "defaultValue":
"fail", "configurationClass":
"org.apache.camel.component.debezium.configuration.MySqlConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "Specify how binlog
events that [...]
"maxBatchSize": { "kind": "property", "displayName": "Max Batch Size",
"group": "mysql", "label": "consumer,mysql", "required": false, "type":
"integer", "javaType": "int", "deprecated": false, "secret": false,
"defaultValue": "2048", "configurationClass":
"org.apache.camel.component.debezium.configuration.MySqlConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "Maximum size of each
batch of source records. Defaults to 2048." },
"maxQueueSize": { "kind": "property", "displayName": "Max Queue Size",
"group": "mysql", "label": "consumer,mysql", "required": false, "type":
"integer", "javaType": "int", "deprecated": 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 database log but not [...]
"messageKeyColumns": { "kind": "property", "displayName": "Message Key
Columns", "group": "mysql", "label": "consumer,mysql", "required": false,
"type": "string", "javaType": "java.lang.String", "deprecated": false,
"secret": false, "configurationClass":
"org.apache.camel.component.debezium.configuration.MySqlConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "A semicolon-separated
list of expressions that match fully-qualified tables and c [...]
@@ -143,7 +144,8 @@
"decimalHandlingMode": { "kind": "parameter", "displayName": "Decimal
Handling Mode", "group": "mysql", "label": "consumer,mysql", "required": false,
"type": "string", "javaType": "java.lang.String", "deprecated": false,
"secret": false, "defaultValue": "precise", "configurationClass":
"org.apache.camel.component.debezium.configuration.MySqlConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "Specify how DECIMAL and
NUMERIC columns should be [...]
"enableTimeAdjuster": { "kind": "parameter", "displayName": "Enable Time
Adjuster", "group": "mysql", "label": "consumer,mysql", "required": false,
"type": "boolean", "javaType": "boolean", "deprecated": false, "secret": false,
"defaultValue": "true", "configurationClass":
"org.apache.camel.component.debezium.configuration.MySqlConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "MySQL allows user to
insert year value as either 2-digit or 4- [...]
"eventDeserializationFailureHandlingMode": { "kind": "parameter",
"displayName": "Event Deserialization Failure Handling Mode", "group": "mysql",
"label": "consumer,mysql", "required": false, "type": "string", "javaType":
"java.lang.String", "deprecated": false, "secret": false, "defaultValue":
"fail", "configurationClass":
"org.apache.camel.component.debezium.configuration.MySqlConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "Specify ho [...]
- "gtidNewChannelPosition": { "kind": "parameter", "displayName": "Gtid New
Channel Position", "group": "mysql", "label": "consumer,mysql", "required":
false, "type": "string", "javaType": "java.lang.String", "deprecated": false,
"secret": false, "defaultValue": "latest", "configurationClass":
"org.apache.camel.component.debezium.configuration.MySqlConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "If set to 'latest',
when connector sees new [...]
+ "eventProcessingFailureHandlingMode": { "kind": "parameter",
"displayName": "Event Processing Failure Handling Mode", "group": "mysql",
"label": "consumer,mysql", "required": false, "type": "string", "javaType":
"java.lang.String", "deprecated": false, "secret": false, "defaultValue":
"fail", "configurationClass":
"org.apache.camel.component.debezium.configuration.MySqlConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "Specify how failures
[...]
+ "gtidNewChannelPosition": { "kind": "parameter", "displayName": "Gtid New
Channel Position", "group": "mysql", "label": "consumer,mysql", "required":
false, "type": "string", "javaType": "java.lang.String", "deprecated": false,
"secret": false, "defaultValue": "earliest", "configurationClass":
"org.apache.camel.component.debezium.configuration.MySqlConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "If set to 'latest',
when connector sees n [...]
"gtidSourceExcludes": { "kind": "parameter", "displayName": "Gtid Source
Excludes", "group": "mysql", "label": "consumer,mysql", "required": false,
"type": "string", "javaType": "java.lang.String", "deprecated": false,
"secret": false, "configurationClass":
"org.apache.camel.component.debezium.configuration.MySqlConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "The source UUIDs used
to exclude GTID ranges when determine the starting posit [...]
"gtidSourceFilterDmlEvents": { "kind": "parameter", "displayName": "Gtid
Source Filter Dml Events", "group": "mysql", "label": "consumer,mysql",
"required": false, "type": "boolean", "javaType": "boolean", "deprecated":
false, "secret": false, "defaultValue": "true", "configurationClass":
"org.apache.camel.component.debezium.configuration.MySqlConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "If set to true, we will
only produce DML event [...]
"gtidSourceIncludes": { "kind": "parameter", "displayName": "Gtid Source
Includes", "group": "mysql", "label": "consumer,mysql", "required": false,
"type": "string", "javaType": "java.lang.String", "deprecated": false,
"secret": false, "configurationClass":
"org.apache.camel.component.debezium.configuration.MySqlConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "The source UUIDs used
to include GTID ranges when determine the starting posit [...]
@@ -151,7 +153,7 @@
"heartbeatTopicsPrefix": { "kind": "parameter", "displayName": "Heartbeat
Topics Prefix", "group": "mysql", "label": "consumer,mysql", "required": false,
"type": "string", "javaType": "java.lang.String", "deprecated": false,
"secret": false, "defaultValue": "__debezium-heartbeat", "configurationClass":
"org.apache.camel.component.debezium.configuration.MySqlConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "The prefix that is used
to name [...]
"includeQuery": { "kind": "parameter", "displayName": "Include Query",
"group": "mysql", "label": "consumer,mysql", "required": false, "type":
"boolean", "javaType": "boolean", "deprecated": false, "secret": false,
"defaultValue": "false", "configurationClass":
"org.apache.camel.component.debezium.configuration.MySqlConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "Whether the connector
should include the original SQL query that generated [...]
"includeSchemaChanges": { "kind": "parameter", "displayName": "Include
Schema Changes", "group": "mysql", "label": "consumer,mysql", "required":
false, "type": "boolean", "javaType": "boolean", "deprecated": false, "secret":
false, "defaultValue": "true", "configurationClass":
"org.apache.camel.component.debezium.configuration.MySqlConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "Whether the connector
should publish changes in the databa [...]
- "inconsistentSchemaHandlingMode": { "kind": "parameter", "displayName":
"Inconsistent Schema Handling Mode", "group": "mysql", "label":
"consumer,mysql", "required": false, "type": "string", "javaType":
"java.lang.String", "deprecated": false, "secret": false, "defaultValue":
"fail", "configurationClass":
"org.apache.camel.component.debezium.configuration.MySqlConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "Specify how binlog
events tha [...]
+ "inconsistentSchemaHandlingMode": { "kind": "parameter", "displayName":
"Inconsistent Schema Handling Mode", "group": "mysql", "label":
"consumer,mysql", "required": false, "type": "string", "javaType":
"java.lang.String", "deprecated": false, "secret": false, "defaultValue":
"fail", "configurationClass":
"org.apache.camel.component.debezium.configuration.MySqlConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "Specify how binlog
events tha [...]
"maxBatchSize": { "kind": "parameter", "displayName": "Max Batch Size",
"group": "mysql", "label": "consumer,mysql", "required": false, "type":
"integer", "javaType": "int", "deprecated": false, "secret": false,
"defaultValue": "2048", "configurationClass":
"org.apache.camel.component.debezium.configuration.MySqlConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "Maximum size of each
batch of source records. Defaults to 2048." },
"maxQueueSize": { "kind": "parameter", "displayName": "Max Queue Size",
"group": "mysql", "label": "consumer,mysql", "required": false, "type":
"integer", "javaType": "int", "deprecated": 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 database log but not [...]
"messageKeyColumns": { "kind": "parameter", "displayName": "Message Key
Columns", "group": "mysql", "label": "consumer,mysql", "required": false,
"type": "string", "javaType": "java.lang.String", "deprecated": false,
"secret": false, "configurationClass":
"org.apache.camel.component.debezium.configuration.MySqlConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "A semicolon-separated
list of expressions that match fully-qualified tables and [...]
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 1156d6b..a0b37bc 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
@@ -50,9 +50,11 @@
"databaseTcpkeepalive": { "kind": "property", "displayName": "Database
Tcpkeepalive", "group": "postgres", "label": "consumer,postgres", "required":
false, "type": "boolean", "javaType": "boolean", "deprecated": false, "secret":
false, "defaultValue": "true", "configurationClass":
"org.apache.camel.component.debezium.configuration.PostgresConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "Enable or disable TCP
keep-alive probe to avoid dro [...]
"databaseUser": { "kind": "property", "displayName": "Database User",
"group": "postgres", "label": "consumer,postgres", "required": false, "type":
"string", "javaType": "java.lang.String", "deprecated": false, "secret": false,
"configurationClass":
"org.apache.camel.component.debezium.configuration.PostgresConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "Name of the Postgres
database user to be used when connecting to the database." },
"decimalHandlingMode": { "kind": "property", "displayName": "Decimal
Handling Mode", "group": "postgres", "label": "consumer,postgres", "required":
false, "type": "string", "javaType": "java.lang.String", "deprecated": false,
"secret": false, "defaultValue": "precise", "configurationClass":
"org.apache.camel.component.debezium.configuration.PostgresConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "Specify how DECIMAL and
NUMERIC columns s [...]
+ "eventProcessingFailureHandlingMode": { "kind": "property", "displayName":
"Event Processing Failure Handling Mode", "group": "postgres", "label":
"consumer,postgres", "required": false, "type": "string", "javaType":
"java.lang.String", "deprecated": false, "secret": false, "defaultValue":
"fail", "configurationClass":
"org.apache.camel.component.debezium.configuration.PostgresConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "Specify how [...]
+ "heartbeatActionQuery": { "kind": "property", "displayName": "Heartbeat
Action Query", "group": "postgres", "label": "consumer,postgres", "required":
false, "type": "string", "javaType": "java.lang.String", "deprecated": false,
"secret": false, "configurationClass":
"org.apache.camel.component.debezium.configuration.PostgresConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "The query executed with
every heartbeat. Defaults to an empty string." },
"heartbeatIntervalMs": { "kind": "property", "displayName": "Heartbeat
Interval Ms", "group": "postgres", "label": "consumer,postgres", "required":
false, "type": "integer", "javaType": "int", "deprecated": false, "secret":
false, "defaultValue": "0", "configurationClass":
"org.apache.camel.component.debezium.configuration.PostgresConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "Length of an interval
in milli-seconds in in which the conn [...]
"heartbeatTopicsPrefix": { "kind": "property", "displayName": "Heartbeat
Topics Prefix", "group": "postgres", "label": "consumer,postgres", "required":
false, "type": "string", "javaType": "java.lang.String", "deprecated": false,
"secret": false, "defaultValue": "__debezium-heartbeat", "configurationClass":
"org.apache.camel.component.debezium.configuration.PostgresConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "The prefix that is used
[...]
- "hstoreHandlingMode": { "kind": "property", "displayName": "Hstore
Handling Mode", "group": "postgres", "label": "consumer,postgres", "required":
false, "type": "string", "javaType": "java.lang.String", "deprecated": false,
"secret": false, "defaultValue": "json", "configurationClass":
"org.apache.camel.component.debezium.configuration.PostgresConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "Specify how HSTORE
columns should be represent [...]
+ "hstoreHandlingMode": { "kind": "property", "displayName": "Hstore
Handling Mode", "group": "postgres", "label": "consumer,postgres", "required":
false, "type": "string", "javaType": "java.lang.String", "deprecated": false,
"secret": false, "defaultValue": "json", "configurationClass":
"org.apache.camel.component.debezium.configuration.PostgresConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "Specify how HSTORE
columns should be represent [...]
"includeUnknownDatatypes": { "kind": "property", "displayName": "Include
Unknown Datatypes", "group": "postgres", "label": "consumer,postgres",
"required": false, "type": "boolean", "javaType": "boolean", "deprecated":
false, "secret": false, "defaultValue": "false", "configurationClass":
"org.apache.camel.component.debezium.configuration.PostgresConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "Specify whether the
fields of data type not [...]
"intervalHandlingMode": { "kind": "property", "displayName": "Interval
Handling Mode", "group": "postgres", "label": "consumer,postgres", "required":
false, "type": "string", "javaType": "java.lang.String", "deprecated": false,
"secret": false, "defaultValue": "numeric", "configurationClass":
"org.apache.camel.component.debezium.configuration.PostgresConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "Specify how INTERVAL
columns should be [...]
"maxBatchSize": { "kind": "property", "displayName": "Max Batch Size",
"group": "postgres", "label": "consumer,postgres", "required": false, "type":
"integer", "javaType": "int", "deprecated": false, "secret": false,
"defaultValue": "2048", "configurationClass":
"org.apache.camel.component.debezium.configuration.PostgresConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "Maximum size of each
batch of source records. Defaults to 2048." },
@@ -60,6 +62,7 @@
"messageKeyColumns": { "kind": "property", "displayName": "Message Key
Columns", "group": "postgres", "label": "consumer,postgres", "required": false,
"type": "string", "javaType": "java.lang.String", "deprecated": false,
"secret": false, "configurationClass":
"org.apache.camel.component.debezium.configuration.PostgresConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "A semicolon-separated
list of expressions that match fully-qualified tab [...]
"pluginName": { "kind": "property", "displayName": "Plugin Name", "group":
"postgres", "label": "consumer,postgres", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "secret": false,
"defaultValue": "decoderbufs", "configurationClass":
"org.apache.camel.component.debezium.configuration.PostgresConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "The name of the
Postgres logical decoding plugin install [...]
"pollIntervalMs": { "kind": "property", "displayName": "Poll Interval Ms",
"group": "postgres", "label": "consumer,postgres", "required": false, "type":
"integer", "javaType": "long", "deprecated": false, "secret": false,
"defaultValue": "500", "configurationClass":
"org.apache.camel.component.debezium.configuration.PostgresConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "Frequency in
milliseconds to wait for new change events to appear [...]
+ "provideTransactionMetadata": { "kind": "property", "displayName":
"Provide Transaction Metadata", "group": "postgres", "label":
"consumer,postgres", "required": false, "type": "boolean", "javaType":
"boolean", "deprecated": false, "secret": false, "defaultValue": "false",
"configurationClass":
"org.apache.camel.component.debezium.configuration.PostgresConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "Enables transaction
metadata extracti [...]
"publicationName": { "kind": "property", "displayName": "Publication
Name", "group": "postgres", "label": "consumer,postgres", "required": false,
"type": "string", "javaType": "java.lang.String", "deprecated": false,
"secret": false, "defaultValue": "dbz_publication", "configurationClass":
"org.apache.camel.component.debezium.configuration.PostgresConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "The name of the
Postgres 10 publication us [...]
"schemaBlacklist": { "kind": "property", "displayName": "Schema
Blacklist", "group": "postgres", "label": "consumer,postgres", "required":
false, "type": "string", "javaType": "java.lang.String", "deprecated": false,
"secret": false, "configurationClass":
"org.apache.camel.component.debezium.configuration.PostgresConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "The schemas for which
events must not be captured" },
"schemaRefreshMode": { "kind": "property", "displayName": "Schema Refresh
Mode", "group": "postgres", "label": "consumer,postgres", "required": false,
"type": "string", "javaType": "java.lang.String", "deprecated": false,
"secret": false, "defaultValue": "columns_diff", "configurationClass":
"org.apache.camel.component.debezium.configuration.PostgresConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "Specify the conditions
that trigger a re [...]
@@ -119,9 +122,11 @@
"databaseTcpkeepalive": { "kind": "parameter", "displayName": "Database
Tcpkeepalive", "group": "postgres", "label": "consumer,postgres", "required":
false, "type": "boolean", "javaType": "boolean", "deprecated": false, "secret":
false, "defaultValue": "true", "configurationClass":
"org.apache.camel.component.debezium.configuration.PostgresConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "Enable or disable TCP
keep-alive probe to avoid dr [...]
"databaseUser": { "kind": "parameter", "displayName": "Database User",
"group": "postgres", "label": "consumer,postgres", "required": false, "type":
"string", "javaType": "java.lang.String", "deprecated": false, "secret": false,
"configurationClass":
"org.apache.camel.component.debezium.configuration.PostgresConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "Name of the Postgres
database user to be used when connecting to the database." },
"decimalHandlingMode": { "kind": "parameter", "displayName": "Decimal
Handling Mode", "group": "postgres", "label": "consumer,postgres", "required":
false, "type": "string", "javaType": "java.lang.String", "deprecated": false,
"secret": false, "defaultValue": "precise", "configurationClass":
"org.apache.camel.component.debezium.configuration.PostgresConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "Specify how DECIMAL and
NUMERIC columns [...]
+ "eventProcessingFailureHandlingMode": { "kind": "parameter",
"displayName": "Event Processing Failure Handling Mode", "group": "postgres",
"label": "consumer,postgres", "required": false, "type": "string", "javaType":
"java.lang.String", "deprecated": false, "secret": false, "defaultValue":
"fail", "configurationClass":
"org.apache.camel.component.debezium.configuration.PostgresConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "Specify how [...]
+ "heartbeatActionQuery": { "kind": "parameter", "displayName": "Heartbeat
Action Query", "group": "postgres", "label": "consumer,postgres", "required":
false, "type": "string", "javaType": "java.lang.String", "deprecated": false,
"secret": false, "configurationClass":
"org.apache.camel.component.debezium.configuration.PostgresConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "The query executed with
every heartbeat. Defaults to an empty str [...]
"heartbeatIntervalMs": { "kind": "parameter", "displayName": "Heartbeat
Interval Ms", "group": "postgres", "label": "consumer,postgres", "required":
false, "type": "integer", "javaType": "int", "deprecated": false, "secret":
false, "defaultValue": "0", "configurationClass":
"org.apache.camel.component.debezium.configuration.PostgresConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "Length of an interval
in milli-seconds in in which the con [...]
"heartbeatTopicsPrefix": { "kind": "parameter", "displayName": "Heartbeat
Topics Prefix", "group": "postgres", "label": "consumer,postgres", "required":
false, "type": "string", "javaType": "java.lang.String", "deprecated": false,
"secret": false, "defaultValue": "__debezium-heartbeat", "configurationClass":
"org.apache.camel.component.debezium.configuration.PostgresConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "The prefix that is used
[...]
- "hstoreHandlingMode": { "kind": "parameter", "displayName": "Hstore
Handling Mode", "group": "postgres", "label": "consumer,postgres", "required":
false, "type": "string", "javaType": "java.lang.String", "deprecated": false,
"secret": false, "defaultValue": "json", "configurationClass":
"org.apache.camel.component.debezium.configuration.PostgresConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "Specify how HSTORE
columns should be represen [...]
+ "hstoreHandlingMode": { "kind": "parameter", "displayName": "Hstore
Handling Mode", "group": "postgres", "label": "consumer,postgres", "required":
false, "type": "string", "javaType": "java.lang.String", "deprecated": false,
"secret": false, "defaultValue": "json", "configurationClass":
"org.apache.camel.component.debezium.configuration.PostgresConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "Specify how HSTORE
columns should be represen [...]
"includeUnknownDatatypes": { "kind": "parameter", "displayName": "Include
Unknown Datatypes", "group": "postgres", "label": "consumer,postgres",
"required": false, "type": "boolean", "javaType": "boolean", "deprecated":
false, "secret": false, "defaultValue": "false", "configurationClass":
"org.apache.camel.component.debezium.configuration.PostgresConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "Specify whether the
fields of data type no [...]
"intervalHandlingMode": { "kind": "parameter", "displayName": "Interval
Handling Mode", "group": "postgres", "label": "consumer,postgres", "required":
false, "type": "string", "javaType": "java.lang.String", "deprecated": false,
"secret": false, "defaultValue": "numeric", "configurationClass":
"org.apache.camel.component.debezium.configuration.PostgresConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "Specify how INTERVAL
columns should be [...]
"maxBatchSize": { "kind": "parameter", "displayName": "Max Batch Size",
"group": "postgres", "label": "consumer,postgres", "required": false, "type":
"integer", "javaType": "int", "deprecated": false, "secret": false,
"defaultValue": "2048", "configurationClass":
"org.apache.camel.component.debezium.configuration.PostgresConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "Maximum size of each
batch of source records. Defaults to 2048." },
@@ -129,6 +134,7 @@
"messageKeyColumns": { "kind": "parameter", "displayName": "Message Key
Columns", "group": "postgres", "label": "consumer,postgres", "required": false,
"type": "string", "javaType": "java.lang.String", "deprecated": false,
"secret": false, "configurationClass":
"org.apache.camel.component.debezium.configuration.PostgresConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "A semicolon-separated
list of expressions that match fully-qualified ta [...]
"pluginName": { "kind": "parameter", "displayName": "Plugin Name",
"group": "postgres", "label": "consumer,postgres", "required": false, "type":
"string", "javaType": "java.lang.String", "deprecated": false, "secret": false,
"defaultValue": "decoderbufs", "configurationClass":
"org.apache.camel.component.debezium.configuration.PostgresConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "The name of the
Postgres logical decoding plugin instal [...]
"pollIntervalMs": { "kind": "parameter", "displayName": "Poll Interval
Ms", "group": "postgres", "label": "consumer,postgres", "required": false,
"type": "integer", "javaType": "long", "deprecated": false, "secret": false,
"defaultValue": "500", "configurationClass":
"org.apache.camel.component.debezium.configuration.PostgresConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "Frequency in
milliseconds to wait for new change events to appear [...]
+ "provideTransactionMetadata": { "kind": "parameter", "displayName":
"Provide Transaction Metadata", "group": "postgres", "label":
"consumer,postgres", "required": false, "type": "boolean", "javaType":
"boolean", "deprecated": false, "secret": false, "defaultValue": "false",
"configurationClass":
"org.apache.camel.component.debezium.configuration.PostgresConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "Enables transaction
metadata extract [...]
"publicationName": { "kind": "parameter", "displayName": "Publication
Name", "group": "postgres", "label": "consumer,postgres", "required": false,
"type": "string", "javaType": "java.lang.String", "deprecated": false,
"secret": false, "defaultValue": "dbz_publication", "configurationClass":
"org.apache.camel.component.debezium.configuration.PostgresConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "The name of the
Postgres 10 publication u [...]
"schemaBlacklist": { "kind": "parameter", "displayName": "Schema
Blacklist", "group": "postgres", "label": "consumer,postgres", "required":
false, "type": "string", "javaType": "java.lang.String", "deprecated": false,
"secret": false, "configurationClass":
"org.apache.camel.component.debezium.configuration.PostgresConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "The schemas for which
events must not be captured" },
"schemaRefreshMode": { "kind": "parameter", "displayName": "Schema Refresh
Mode", "group": "postgres", "label": "consumer,postgres", "required": false,
"type": "string", "javaType": "java.lang.String", "deprecated": false,
"secret": false, "defaultValue": "columns_diff", "configurationClass":
"org.apache.camel.component.debezium.configuration.PostgresConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "Specify the conditions
that trigger a r [...]
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 9ba9eca..bddb077 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
@@ -48,12 +48,14 @@
"databaseServerTimezone": { "kind": "property", "displayName": "Database
Server Timezone", "group": "sqlserver", "label": "consumer,sqlserver",
"required": false, "type": "string", "javaType": "java.lang.String",
"deprecated": false, "secret": false, "configurationClass":
"org.apache.camel.component.debezium.configuration.SqlServerConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "The timezone of the
server used to correctly shift the comm [...]
"databaseUser": { "kind": "property", "displayName": "Database User",
"group": "sqlserver", "label": "consumer,sqlserver", "required": false, "type":
"string", "javaType": "java.lang.String", "deprecated": false, "secret": false,
"configurationClass":
"org.apache.camel.component.debezium.configuration.SqlServerConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "Name of the SQL Server
database user to be used when connecting to the database." },
"decimalHandlingMode": { "kind": "property", "displayName": "Decimal
Handling Mode", "group": "sqlserver", "label": "consumer,sqlserver",
"required": false, "type": "string", "javaType": "java.lang.String",
"deprecated": false, "secret": false, "defaultValue": "precise",
"configurationClass":
"org.apache.camel.component.debezium.configuration.SqlServerConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "Specify how DECIMAL and
NUMERIC column [...]
+ "eventProcessingFailureHandlingMode": { "kind": "property", "displayName":
"Event Processing Failure Handling Mode", "group": "sqlserver", "label":
"consumer,sqlserver", "required": false, "type": "string", "javaType":
"java.lang.String", "deprecated": false, "secret": false, "defaultValue":
"fail", "configurationClass":
"org.apache.camel.component.debezium.configuration.SqlServerConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "Specify h [...]
"heartbeatIntervalMs": { "kind": "property", "displayName": "Heartbeat
Interval Ms", "group": "sqlserver", "label": "consumer,sqlserver", "required":
false, "type": "integer", "javaType": "int", "deprecated": false, "secret":
false, "defaultValue": "0", "configurationClass":
"org.apache.camel.component.debezium.configuration.SqlServerConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "Length of an interval
in milli-seconds in in which the c [...]
"heartbeatTopicsPrefix": { "kind": "property", "displayName": "Heartbeat
Topics Prefix", "group": "sqlserver", "label": "consumer,sqlserver",
"required": false, "type": "string", "javaType": "java.lang.String",
"deprecated": false, "secret": false, "defaultValue": "__debezium-heartbeat",
"configurationClass":
"org.apache.camel.component.debezium.configuration.SqlServerConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "The prefix that is us
[...]
"maxBatchSize": { "kind": "property", "displayName": "Max Batch Size",
"group": "sqlserver", "label": "consumer,sqlserver", "required": false, "type":
"integer", "javaType": "int", "deprecated": false, "secret": false,
"defaultValue": "2048", "configurationClass":
"org.apache.camel.component.debezium.configuration.SqlServerConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "Maximum size of each
batch of source records. Defaults to 2048." },
"maxQueueSize": { "kind": "property", "displayName": "Max Queue Size",
"group": "sqlserver", "label": "consumer,sqlserver", "required": false, "type":
"integer", "javaType": "int", "deprecated": false, "secret": false,
"defaultValue": "8192", "configurationClass":
"org.apache.camel.component.debezium.configuration.SqlServerConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "Maximum size of the
queue for change events read from the database [...]
"messageKeyColumns": { "kind": "property", "displayName": "Message Key
Columns", "group": "sqlserver", "label": "consumer,sqlserver", "required":
false, "type": "string", "javaType": "java.lang.String", "deprecated": false,
"secret": false, "configurationClass":
"org.apache.camel.component.debezium.configuration.SqlServerConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "A semicolon-separated
list of expressions that match fully-qualified [...]
"pollIntervalMs": { "kind": "property", "displayName": "Poll Interval Ms",
"group": "sqlserver", "label": "consumer,sqlserver", "required": false, "type":
"integer", "javaType": "long", "deprecated": false, "secret": false,
"defaultValue": "500", "configurationClass":
"org.apache.camel.component.debezium.configuration.SqlServerConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "Frequency in
milliseconds to wait for new change events to appe [...]
+ "provideTransactionMetadata": { "kind": "property", "displayName":
"Provide Transaction Metadata", "group": "sqlserver", "label":
"consumer,sqlserver", "required": false, "type": "boolean", "javaType":
"boolean", "deprecated": false, "secret": false, "defaultValue": "false",
"configurationClass":
"org.apache.camel.component.debezium.configuration.SqlServerConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "Enables transaction
metadata extra [...]
"snapshotDelayMs": { "kind": "property", "displayName": "Snapshot Delay
Ms", "group": "sqlserver", "label": "consumer,sqlserver", "required": false,
"type": "integer", "javaType": "long", "deprecated": false, "secret": false,
"defaultValue": "0", "configurationClass":
"org.apache.camel.component.debezium.configuration.SqlServerConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "The number of
milliseconds to delay before a snapshot will begin." },
"snapshotFetchSize": { "kind": "property", "displayName": "Snapshot Fetch
Size", "group": "sqlserver", "label": "consumer,sqlserver", "required": false,
"type": "integer", "javaType": "int", "deprecated": false, "secret": false,
"configurationClass":
"org.apache.camel.component.debezium.configuration.SqlServerConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "The maximum number of
records that should be loaded into memory while performing [...]
"snapshotLockTimeoutMs": { "kind": "property", "displayName": "Snapshot
Lock Timeout Ms", "group": "sqlserver", "label": "consumer,sqlserver",
"required": false, "type": "integer", "javaType": "long", "deprecated": false,
"secret": false, "defaultValue": "10000", "configurationClass":
"org.apache.camel.component.debezium.configuration.SqlServerConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "The maximum number of
millis to wait for table [...]
@@ -99,12 +101,14 @@
"databaseServerTimezone": { "kind": "parameter", "displayName": "Database
Server Timezone", "group": "sqlserver", "label": "consumer,sqlserver",
"required": false, "type": "string", "javaType": "java.lang.String",
"deprecated": false, "secret": false, "configurationClass":
"org.apache.camel.component.debezium.configuration.SqlServerConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "The timezone of the
server used to correctly shift the com [...]
"databaseUser": { "kind": "parameter", "displayName": "Database User",
"group": "sqlserver", "label": "consumer,sqlserver", "required": false, "type":
"string", "javaType": "java.lang.String", "deprecated": false, "secret": false,
"configurationClass":
"org.apache.camel.component.debezium.configuration.SqlServerConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "Name of the SQL Server
database user to be used when connecting to the database." },
"decimalHandlingMode": { "kind": "parameter", "displayName": "Decimal
Handling Mode", "group": "sqlserver", "label": "consumer,sqlserver",
"required": false, "type": "string", "javaType": "java.lang.String",
"deprecated": false, "secret": false, "defaultValue": "precise",
"configurationClass":
"org.apache.camel.component.debezium.configuration.SqlServerConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "Specify how DECIMAL and
NUMERIC colum [...]
+ "eventProcessingFailureHandlingMode": { "kind": "parameter",
"displayName": "Event Processing Failure Handling Mode", "group": "sqlserver",
"label": "consumer,sqlserver", "required": false, "type": "string", "javaType":
"java.lang.String", "deprecated": false, "secret": false, "defaultValue":
"fail", "configurationClass":
"org.apache.camel.component.debezium.configuration.SqlServerConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "Specify [...]
"heartbeatIntervalMs": { "kind": "parameter", "displayName": "Heartbeat
Interval Ms", "group": "sqlserver", "label": "consumer,sqlserver", "required":
false, "type": "integer", "javaType": "int", "deprecated": false, "secret":
false, "defaultValue": "0", "configurationClass":
"org.apache.camel.component.debezium.configuration.SqlServerConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "Length of an interval
in milli-seconds in in which the [...]
"heartbeatTopicsPrefix": { "kind": "parameter", "displayName": "Heartbeat
Topics Prefix", "group": "sqlserver", "label": "consumer,sqlserver",
"required": false, "type": "string", "javaType": "java.lang.String",
"deprecated": false, "secret": false, "defaultValue": "__debezium-heartbeat",
"configurationClass":
"org.apache.camel.component.debezium.configuration.SqlServerConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "The prefix that is u
[...]
"maxBatchSize": { "kind": "parameter", "displayName": "Max Batch Size",
"group": "sqlserver", "label": "consumer,sqlserver", "required": false, "type":
"integer", "javaType": "int", "deprecated": false, "secret": false,
"defaultValue": "2048", "configurationClass":
"org.apache.camel.component.debezium.configuration.SqlServerConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "Maximum size of each
batch of source records. Defaults to 2048." },
"maxQueueSize": { "kind": "parameter", "displayName": "Max Queue Size",
"group": "sqlserver", "label": "consumer,sqlserver", "required": false, "type":
"integer", "javaType": "int", "deprecated": false, "secret": false,
"defaultValue": "8192", "configurationClass":
"org.apache.camel.component.debezium.configuration.SqlServerConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "Maximum size of the
queue for change events read from the database [...]
"messageKeyColumns": { "kind": "parameter", "displayName": "Message Key
Columns", "group": "sqlserver", "label": "consumer,sqlserver", "required":
false, "type": "string", "javaType": "java.lang.String", "deprecated": false,
"secret": false, "configurationClass":
"org.apache.camel.component.debezium.configuration.SqlServerConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "A semicolon-separated
list of expressions that match fully-qualified [...]
"pollIntervalMs": { "kind": "parameter", "displayName": "Poll Interval
Ms", "group": "sqlserver", "label": "consumer,sqlserver", "required": false,
"type": "integer", "javaType": "long", "deprecated": false, "secret": false,
"defaultValue": "500", "configurationClass":
"org.apache.camel.component.debezium.configuration.SqlServerConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "Frequency in
milliseconds to wait for new change events to app [...]
+ "provideTransactionMetadata": { "kind": "parameter", "displayName":
"Provide Transaction Metadata", "group": "sqlserver", "label":
"consumer,sqlserver", "required": false, "type": "boolean", "javaType":
"boolean", "deprecated": false, "secret": false, "defaultValue": "false",
"configurationClass":
"org.apache.camel.component.debezium.configuration.SqlServerConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "Enables transaction
metadata extr [...]
"snapshotDelayMs": { "kind": "parameter", "displayName": "Snapshot Delay
Ms", "group": "sqlserver", "label": "consumer,sqlserver", "required": false,
"type": "integer", "javaType": "long", "deprecated": false, "secret": false,
"defaultValue": "0", "configurationClass":
"org.apache.camel.component.debezium.configuration.SqlServerConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "The number of
milliseconds to delay before a snapshot will begin." },
"snapshotFetchSize": { "kind": "parameter", "displayName": "Snapshot Fetch
Size", "group": "sqlserver", "label": "consumer,sqlserver", "required": false,
"type": "integer", "javaType": "int", "deprecated": false, "secret": false,
"configurationClass":
"org.apache.camel.component.debezium.configuration.SqlServerConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "The maximum number of
records that should be loaded into memory while performing [...]
"snapshotLockTimeoutMs": { "kind": "parameter", "displayName": "Snapshot
Lock Timeout Ms", "group": "sqlserver", "label": "consumer,sqlserver",
"required": false, "type": "integer", "javaType": "long", "deprecated": false,
"secret": false, "defaultValue": "10000", "configurationClass":
"org.apache.camel.component.debezium.configuration.SqlServerConnectorEmbeddedDebeziumConfiguration",
"configurationField": "configuration", "description": "The maximum number of
millis to wait for tabl [...]
diff --git a/components-starter/camel-corda-starter/pom.xml
b/components-starter/camel-corda-starter/pom.xml
index 61d6d32..cba8670 100644
--- a/components-starter/camel-corda-starter/pom.xml
+++ b/components-starter/camel-corda-starter/pom.xml
@@ -38,6 +38,18 @@
<groupId>org.apache.camel</groupId>
<artifactId>camel-corda</artifactId>
<version>${camel-version}</version>
+ <!--START OF GENERATED CODE-->
+ <exclusions>
+ <exclusion>
+ <groupId>ch.qos.logback</groupId>
+ <artifactId>logback-classic</artifactId>
+ </exclusion>
+ <exclusion>
+ <groupId>ch.qos.logback</groupId>
+ <artifactId>logback-core</artifactId>
+ </exclusion>
+ </exclusions>
+ <!--END OF GENERATED CODE-->
</dependency>
<!--START OF GENERATED CODE-->
<dependency>
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 6b80be3..8574b5f 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
@@ -17,7 +17,7 @@ When using debezium-mongodb with Spring Boot make sure to use
the following Mave
----
-The component supports 43 options, which are listed below.
+The component supports 44 options, which are listed below.
@@ -41,7 +41,7 @@ The component supports 43 options, which are listed below.
| *camel.component.debezium-mongodb.field-renames* | Description is not
available here, please check Debezium website for corresponding key
'field.renames' description. | | String
| *camel.component.debezium-mongodb.heartbeat-interval-ms* | Length of an
interval in milli-seconds in in which the connector periodically sends
heartbeat messages to a heartbeat topic. Use 0 to disable heartbeat messages.
Disabled by default. | 0 | Integer
| *camel.component.debezium-mongodb.heartbeat-topics-prefix* | The prefix that
is used to name heartbeat topics.Defaults to __debezium-heartbeat. |
__debezium-heartbeat | String
-| *camel.component.debezium-mongodb.initial-sync-max-threads* | Maximum number
of threads used to perform an intial sync of the collections in a replica set.
Defaults to 1. | 1 | Integer
+| *camel.component.debezium-mongodb.initial-sync-max-threads* | Maximum number
of threads used to perform an initial sync of the collections in a replica set.
Defaults to 1. | 1 | Integer
| *camel.component.debezium-mongodb.internal-key-converter* | The Converter
class that should be used to serialize and deserialize key data for offsets.
The default is JSON converter. | org.apache.kafka.connect.json.JsonConverter |
String
| *camel.component.debezium-mongodb.internal-value-converter* | The Converter
class that should be used to serialize and deserialize value data for offsets.
The default is JSON converter. | org.apache.kafka.connect.json.JsonConverter |
String
| *camel.component.debezium-mongodb.max-batch-size* | Maximum size of each
batch of source records. Defaults to 2048. | 2048 | Integer
@@ -62,6 +62,7 @@ The component supports 43 options, which are listed below.
| *camel.component.debezium-mongodb.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-mongodb.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-mongodb.poll-interval-ms* | Frequency in
milliseconds to wait for new change events to appear after receiving no events.
Defaults to 500ms. | 500 | Long
+| *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.snapshot-delay-ms* | The number of
milliseconds to delay before a snapshot will begin. | 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
| *camel.component.debezium-mongodb.snapshot-mode* | The criteria for running
a snapshot upon startup of the connector. Options include: 'initial' (the
default) to specify the connector should always perform an initial sync when
required; 'never' to specify the connector should never perform an initial sync
| initial | String
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 9605a55..cb171b1 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
@@ -184,7 +184,7 @@ public class DebeziumMongodbComponentConfiguration
*/
private String heartbeatTopicsPrefix = "__debezium-heartbeat";
/**
- * Maximum number of threads used to perform an intial sync of the
+ * Maximum number of threads used to perform an initial sync of the
* collections in a replica set. Defaults to 1.
*/
private Integer initialSyncMaxThreads = 1;
@@ -240,6 +240,12 @@ public class DebeziumMongodbComponentConfiguration
*/
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.
+ */
+ private String skippedOperations;
+ /**
* The number of milliseconds to delay before a snapshot will begin.
*/
private Long snapshotDelayMs = 0L;
@@ -569,6 +575,14 @@ public class DebeziumMongodbComponentConfiguration
this.pollIntervalMs = pollIntervalMs;
}
+ public String getSkippedOperations() {
+ return skippedOperations;
+ }
+
+ public void setSkippedOperations(String skippedOperations) {
+ this.skippedOperations = skippedOperations;
+ }
+
public Long getSnapshotDelayMs() {
return snapshotDelayMs;
}
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 bfb5491..8abac9a 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
@@ -17,7 +17,7 @@ When using debezium-mysql with Spring Boot make sure to use
the following Maven
----
-The component supports 73 options, which are listed below.
+The component supports 74 options, which are listed below.
@@ -62,7 +62,8 @@ The component supports 73 options, which are listed below.
| *camel.component.debezium-mysql.enable-time-adjuster* | MySQL allows user to
insert year value as either 2-digit or 4-digit. In case of two digit the value
is automatically mapped into 1970 - 2069.false - delegates the implicit
conversion to the databasetrue - (the default) Debezium makes the conversion |
true | Boolean
| *camel.component.debezium-mysql.enabled* | Whether to enable auto
configuration of the debezium-mysql component. This is enabled by default. | |
Boolean
| *camel.component.debezium-mysql.event-deserialization-failure-handling-mode*
| Specify how failures during deserialization of binlog events (i.e. when
encountering a corrupted event) should be handled, including:'fail' (the
default) an exception indicating the problematic event and its binlog position
is raised, causing the connector to be stopped; 'warn' the problematic event
and its binlog position will be logged and the event will be skipped;'ignore'
the problematic event will be sk [...]
-| *camel.component.debezium-mysql.gtid-new-channel-position* | If set to
'latest', when connector sees new GTID, it will start consuming gtid channel
from the server latest executed gtid position. If 'earliest' connector starts
reading channel from first available (not purged) gtid position on the server.
| latest | String
+| *camel.component.debezium-mysql.event-processing-failure-handling-mode* |
Specify how failures during processing of events (i.e. when encountering a
corrupted event) should be handled, including:'fail' (the default) an exception
indicating the problematic event and its position is raised, causing the
connector to be stopped; 'warn' the problematic event and its position will be
logged and the event will be skipped;'ignore' the problematic event will be
skipped. | fail | String
+| *camel.component.debezium-mysql.gtid-new-channel-position* | If set to
'latest', when connector sees new GTID, it will start consuming gtid channel
from the server latest executed gtid position. If 'earliest' (the default)
connector starts reading channel from first available (not purged) gtid
position on the server. | earliest | String
| *camel.component.debezium-mysql.gtid-source-excludes* | The source UUIDs
used to exclude GTID ranges when determine the starting position in the MySQL
server's binlog. | | String
| *camel.component.debezium-mysql.gtid-source-filter-dml-events* | If set to
true, we will only produce DML events into Kafka for transactions that were
written on mysql servers with UUIDs matching the filters defined by the
gtid.source.includes or gtid.source.excludes configuration options, if they are
specified. | true | Boolean
| *camel.component.debezium-mysql.gtid-source-includes* | The source UUIDs
used to include GTID ranges when determine the starting position in the MySQL
server's binlog. | | String
@@ -70,7 +71,7 @@ The component supports 73 options, which are listed below.
| *camel.component.debezium-mysql.heartbeat-topics-prefix* | The prefix that
is used to name heartbeat topics.Defaults to __debezium-heartbeat. |
__debezium-heartbeat | String
| *camel.component.debezium-mysql.include-query* | Whether the connector
should include the original SQL query that generated the change event. Note:
This option requires MySQL be configured with the binlog_rows_query_log_events
option set to ON. Query will not be present for events generated from snapshot.
WARNING: Enabling this option may expose tables or fields explicitly
blacklisted or masked by including the original SQL statement in the change
event. For this reason the default val [...]
| *camel.component.debezium-mysql.include-schema-changes* | Whether the
connector should publish changes in the database schema to a Kafka topic with
the same name as the database server ID. Each schema change will be recorded
using a key that contains the database name and whose value includes the DDL
statement(s).The default is 'true'. This is independent of how the connector
internally records database history. | true | Boolean
-| *camel.component.debezium-mysql.inconsistent-schema-handling-mode* | Specify
how binlog events that belong to a table missing from internal schema
representation (i.e. internal representation is not consistent with database)
should be handled, including:'fail' (the default) an exception indicating the
problematic event and its binlog position is raised, causing the connector to
be stopped; 'warn' the problematic event and its binlog position will be logged
and the event will be skipped [...]
+| *camel.component.debezium-mysql.inconsistent-schema-handling-mode* | Specify
how binlog events that belong to a table missing from internal schema
representation (i.e. internal representation is not consistent with database)
should be handled, including:'fail' (the default) an exception indicating the
problematic event and its binlog position is raised, causing the connector to
be stopped; 'warn' the problematic event and its binlog position will be logged
and the event will be skipped [...]
| *camel.component.debezium-mysql.internal-key-converter* | The Converter
class that should be used to serialize and deserialize key data for offsets.
The default is JSON converter. | org.apache.kafka.connect.json.JsonConverter |
String
| *camel.component.debezium-mysql.internal-value-converter* | The Converter
class that should be used to serialize and deserialize value data for offsets.
The default is JSON converter. | org.apache.kafka.connect.json.JsonConverter |
String
| *camel.component.debezium-mysql.max-batch-size* | Maximum size of each batch
of source records. Defaults to 2048. | 2048 | 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 89eac34..726e36e 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
@@ -331,12 +331,21 @@ public class DebeziumMySqlComponentConfiguration
*/
private String eventDeserializationFailureHandlingMode = "fail";
/**
+ * Specify how failures during processing of events (i.e. when encountering
+ * a corrupted event) should be handled, including:'fail' (the default) an
+ * exception indicating the problematic event and its position is raised,
+ * causing the connector to be stopped; 'warn' the problematic event and
its
+ * position will be logged and the event will be skipped;'ignore' the
+ * problematic event will be skipped.
+ */
+ private String eventProcessingFailureHandlingMode = "fail";
+ /**
* If set to 'latest', when connector sees new GTID, it will start
consuming
* gtid channel from the server latest executed gtid position. If
'earliest'
- * connector starts reading channel from first available (not purged) gtid
- * position on the server.
+ * (the default) connector starts reading channel from first available (not
+ * purged) gtid position on the server.
*/
- private String gtidNewChannelPosition = "latest";
+ private String gtidNewChannelPosition = "earliest";
/**
* The source UUIDs used to exclude GTID ranges when determine the starting
* position in the MySQL server's binlog.
@@ -390,7 +399,7 @@ public class DebeziumMySqlComponentConfiguration
* exception indicating the problematic event and its binlog position is
* raised, causing the connector to be stopped; 'warn' the problematic
event
* and its binlog position will be logged and the event will be
- * skipped;'ignore' the problematic event will be skipped.
+ * skipped;'skip' the problematic event will be skipped.
*/
private String inconsistentSchemaHandlingMode = "fail";
/**
@@ -913,6 +922,15 @@ public class DebeziumMySqlComponentConfiguration
this.eventDeserializationFailureHandlingMode =
eventDeserializationFailureHandlingMode;
}
+ public String getEventProcessingFailureHandlingMode() {
+ return eventProcessingFailureHandlingMode;
+ }
+
+ public void setEventProcessingFailureHandlingMode(
+ String eventProcessingFailureHandlingMode) {
+ this.eventProcessingFailureHandlingMode =
eventProcessingFailureHandlingMode;
+ }
+
public String getGtidNewChannelPosition() {
return gtidNewChannelPosition;
}
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 156a4b8..f4b7f1a 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
@@ -17,7 +17,7 @@ When using debezium-postgres with Spring Boot make sure to
use the following Mav
----
-The component supports 65 options, which are listed below.
+The component supports 68 options, which are listed below.
@@ -46,9 +46,11 @@ The component supports 65 options, which are listed below.
| *camel.component.debezium-postgres.database-user* | Name of the Postgres
database user to be used when connecting to the database. | | String
| *camel.component.debezium-postgres.decimal-handling-mode* | Specify how
DECIMAL and NUMERIC columns should be represented in change events,
including:'precise' (the default) uses java.math.BigDecimal to represent
values, which are encoded in the change events using a binary representation
and Kafka Connect's 'org.apache.kafka.connect.data.Decimal' type; 'string' uses
string to represent values; 'double' represents values using Java's 'double',
which may not offer the precision but will [...]
| *camel.component.debezium-postgres.enabled* | Whether to enable auto
configuration of the debezium-postgres component. This is enabled by default. |
| Boolean
+| *camel.component.debezium-postgres.event-processing-failure-handling-mode* |
Specify how failures during processing of events (i.e. when encountering a
corrupted event) should be handled, including:'fail' (the default) an exception
indicating the problematic event and its position is raised, causing the
connector to be stopped; 'warn' the problematic event and its position will be
logged and the event will be skipped;'ignore' the problematic event will be
skipped. | fail | String
+| *camel.component.debezium-postgres.heartbeat-action-query* | The query
executed with every heartbeat. Defaults to an empty string. | | String
| *camel.component.debezium-postgres.heartbeat-interval-ms* | Length of an
interval in milli-seconds in in which the connector periodically sends
heartbeat messages to a heartbeat topic. Use 0 to disable heartbeat messages.
Disabled by default. | 0 | Integer
| *camel.component.debezium-postgres.heartbeat-topics-prefix* | The prefix
that is used to name heartbeat topics.Defaults to __debezium-heartbeat. |
__debezium-heartbeat | String
-| *camel.component.debezium-postgres.hstore-handling-mode* | Specify how
HSTORE columns should be represented in change events, including:'json'
represents values as json string'map' (default) represents values using
java.util.Map | json | String
+| *camel.component.debezium-postgres.hstore-handling-mode* | Specify how
HSTORE columns should be represented in change events, including:'json'
represents values as string-ified JSON (default)'map' represents values as a
key/value map | json | String
| *camel.component.debezium-postgres.include-unknown-datatypes* | Specify
whether the fields of data type not supported by Debezium should be
processed:'false' (the default) omits the fields; 'true' converts the field
into an implementation dependent binary representation. | false | Boolean
| *camel.component.debezium-postgres.internal-key-converter* | The Converter
class that should be used to serialize and deserialize key data for offsets.
The default is JSON converter. | org.apache.kafka.connect.json.JsonConverter |
String
| *camel.component.debezium-postgres.internal-value-converter* | The Converter
class that should be used to serialize and deserialize value data for offsets.
The default is JSON converter. | org.apache.kafka.connect.json.JsonConverter |
String
@@ -66,6 +68,7 @@ The component supports 65 options, which are listed below.
| *camel.component.debezium-postgres.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-postgres.plugin-name* | The name of the Postgres
logical decoding plugin installed on the server. Supported values are
'decoderbufs' and 'wal2json'. Defaults to 'decoderbufs'. | decoderbufs | String
| *camel.component.debezium-postgres.poll-interval-ms* | Frequency in
milliseconds to wait for new change events to appear after receiving no events.
Defaults to 500ms. | 500 | Long
+| *camel.component.debezium-postgres.provide-transaction-metadata* | Enables
transaction metadata extraction together with event counting | false | Boolean
| *camel.component.debezium-postgres.publication-name* | The name of the
Postgres 10 publication used for streaming changes from a plugin.Defaults to
'dbz_publication' | dbz_publication | String
| *camel.component.debezium-postgres.schema-blacklist* | The schemas for which
events must not 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 [...]
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 aa6fe0d..09df7b1 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
@@ -220,6 +220,19 @@ public class DebeziumPostgresComponentConfiguration
*/
private String decimalHandlingMode = "precise";
/**
+ * Specify how failures during processing of events (i.e. when encountering
+ * a corrupted event) should be handled, including:'fail' (the default) an
+ * exception indicating the problematic event and its position is raised,
+ * causing the connector to be stopped; 'warn' the problematic event and
its
+ * position will be logged and the event will be skipped;'ignore' the
+ * problematic event will be skipped.
+ */
+ private String eventProcessingFailureHandlingMode = "fail";
+ /**
+ * The query executed with every heartbeat. Defaults to an empty string.
+ */
+ private String heartbeatActionQuery;
+ /**
* Length of an interval in milli-seconds in in which the connector
* periodically sends heartbeat messages to a heartbeat topic. Use 0 to
* disable heartbeat messages. Disabled by default.
@@ -232,8 +245,8 @@ public class DebeziumPostgresComponentConfiguration
private String heartbeatTopicsPrefix = "__debezium-heartbeat";
/**
* Specify how HSTORE columns should be represented in change events,
- * including:'json' represents values as json string'map' (default)
- * represents values using java.util.Map
+ * including:'json' represents values as string-ified JSON (default)'map'
+ * represents values as a key/value map
*/
private String hstoreHandlingMode = "json";
/**
@@ -283,6 +296,10 @@ public class DebeziumPostgresComponentConfiguration
*/
private Long pollIntervalMs = 500L;
/**
+ * Enables transaction metadata extraction together with event counting
+ */
+ private Boolean provideTransactionMetadata = false;
+ /**
* The name of the Postgres 10 publication used for streaming changes from
a
* plugin.Defaults to 'dbz_publication'
*/
@@ -695,6 +712,23 @@ public class DebeziumPostgresComponentConfiguration
this.decimalHandlingMode = decimalHandlingMode;
}
+ public String getEventProcessingFailureHandlingMode() {
+ return eventProcessingFailureHandlingMode;
+ }
+
+ public void setEventProcessingFailureHandlingMode(
+ String eventProcessingFailureHandlingMode) {
+ this.eventProcessingFailureHandlingMode =
eventProcessingFailureHandlingMode;
+ }
+
+ public String getHeartbeatActionQuery() {
+ return heartbeatActionQuery;
+ }
+
+ public void setHeartbeatActionQuery(String heartbeatActionQuery) {
+ this.heartbeatActionQuery = heartbeatActionQuery;
+ }
+
public Integer getHeartbeatIntervalMs() {
return heartbeatIntervalMs;
}
@@ -775,6 +809,14 @@ public class DebeziumPostgresComponentConfiguration
this.pollIntervalMs = pollIntervalMs;
}
+ public Boolean getProvideTransactionMetadata() {
+ return provideTransactionMetadata;
+ }
+
+ public void setProvideTransactionMetadata(Boolean
provideTransactionMetadata) {
+ this.provideTransactionMetadata = provideTransactionMetadata;
+ }
+
public String getPublicationName() {
return publicationName;
}
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 95fbadc..2d13c93 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 47 options, which are listed below.
+The component supports 49 options, which are listed below.
@@ -44,6 +44,7 @@ The component supports 47 options, which are listed below.
| *camel.component.debezium-sqlserver.database-user* | Name of the SQL Server
database user to be used when connecting to the database. | | String
| *camel.component.debezium-sqlserver.decimal-handling-mode* | Specify how
DECIMAL and NUMERIC columns should be represented in change events,
including:'precise' (the default) uses java.math.BigDecimal to represent
values, which are encoded in the change events using a binary representation
and Kafka Connect's 'org.apache.kafka.connect.data.Decimal' type; 'string' uses
string to represent values; 'double' represents values using Java's 'double',
which may not offer the precision but wil [...]
| *camel.component.debezium-sqlserver.enabled* | Whether to enable auto
configuration of the debezium-sqlserver component. This is enabled by default.
| | Boolean
+| *camel.component.debezium-sqlserver.event-processing-failure-handling-mode*
| Specify how failures during processing of events (i.e. when encountering a
corrupted event) should be handled, including:'fail' (the default) an exception
indicating the problematic event and its position is raised, causing the
connector to be stopped; 'warn' the problematic event and its position will be
logged and the event will be skipped;'ignore' the problematic event will be
skipped. | fail | String
| *camel.component.debezium-sqlserver.heartbeat-interval-ms* | Length of an
interval in milli-seconds in in which the connector periodically sends
heartbeat messages to a heartbeat topic. Use 0 to disable heartbeat messages.
Disabled by default. | 0 | Integer
| *camel.component.debezium-sqlserver.heartbeat-topics-prefix* | The prefix
that is used to name heartbeat topics.Defaults to __debezium-heartbeat. |
__debezium-heartbeat | String
| *camel.component.debezium-sqlserver.internal-key-converter* | The Converter
class that should be used to serialize and deserialize key data for offsets.
The default is JSON converter. | org.apache.kafka.connect.json.JsonConverter |
String
@@ -60,6 +61,7 @@ The component supports 47 options, which are listed below.
| *camel.component.debezium-sqlserver.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-sqlserver.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-sqlserver.poll-interval-ms* | Frequency in
milliseconds to wait for new change events to appear after receiving no events.
Defaults to 500ms. | 500 | Long
+| *camel.component.debezium-sqlserver.provide-transaction-metadata* | Enables
transaction metadata extraction together with event counting | false | Boolean
| *camel.component.debezium-sqlserver.snapshot-delay-ms* | The number of
milliseconds to delay before a snapshot will begin. | 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-lock-timeout-ms* | The maximum
number of millis to wait for table locks at the beginning of a snapshot. If
locks cannot be acquired in this time frame, the snapshot will be aborted.
Defaults to 10 seconds | 10000 | Long
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 2f8f0c5..7fc2fe6 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
@@ -204,6 +204,15 @@ public class DebeziumSqlserverComponentConfiguration
*/
private String decimalHandlingMode = "precise";
/**
+ * Specify how failures during processing of events (i.e. when encountering
+ * a corrupted event) should be handled, including:'fail' (the default) an
+ * exception indicating the problematic event and its position is raised,
+ * causing the connector to be stopped; 'warn' the problematic event and
its
+ * position will be logged and the event will be skipped;'ignore' the
+ * problematic event will be skipped.
+ */
+ private String eventProcessingFailureHandlingMode = "fail";
+ /**
* Length of an interval in milli-seconds in in which the connector
* periodically sends heartbeat messages to a heartbeat topic. Use 0 to
* disable heartbeat messages. Disabled by default.
@@ -242,6 +251,10 @@ public class DebeziumSqlserverComponentConfiguration
*/
private Long pollIntervalMs = 500L;
/**
+ * Enables transaction metadata extraction together with event counting
+ */
+ private Boolean provideTransactionMetadata = false;
+ /**
* The number of milliseconds to delay before a snapshot will begin.
*/
private Long snapshotDelayMs = 0L;
@@ -554,6 +567,15 @@ public class DebeziumSqlserverComponentConfiguration
this.decimalHandlingMode = decimalHandlingMode;
}
+ public String getEventProcessingFailureHandlingMode() {
+ return eventProcessingFailureHandlingMode;
+ }
+
+ public void setEventProcessingFailureHandlingMode(
+ String eventProcessingFailureHandlingMode) {
+ this.eventProcessingFailureHandlingMode =
eventProcessingFailureHandlingMode;
+ }
+
public Integer getHeartbeatIntervalMs() {
return heartbeatIntervalMs;
}
@@ -602,6 +624,14 @@ public class DebeziumSqlserverComponentConfiguration
this.pollIntervalMs = pollIntervalMs;
}
+ public Boolean getProvideTransactionMetadata() {
+ return provideTransactionMetadata;
+ }
+
+ public void setProvideTransactionMetadata(Boolean
provideTransactionMetadata) {
+ this.provideTransactionMetadata = provideTransactionMetadata;
+ }
+
public Long getSnapshotDelayMs() {
return snapshotDelayMs;
}
diff --git a/docs/modules/ROOT/pages/debezium-mongodb-starter.adoc
b/docs/modules/ROOT/pages/debezium-mongodb-starter.adoc
index 6b80be3..8574b5f 100644
--- a/docs/modules/ROOT/pages/debezium-mongodb-starter.adoc
+++ b/docs/modules/ROOT/pages/debezium-mongodb-starter.adoc
@@ -17,7 +17,7 @@ When using debezium-mongodb with Spring Boot make sure to use
the following Mave
----
-The component supports 43 options, which are listed below.
+The component supports 44 options, which are listed below.
@@ -41,7 +41,7 @@ The component supports 43 options, which are listed below.
| *camel.component.debezium-mongodb.field-renames* | Description is not
available here, please check Debezium website for corresponding key
'field.renames' description. | | String
| *camel.component.debezium-mongodb.heartbeat-interval-ms* | Length of an
interval in milli-seconds in in which the connector periodically sends
heartbeat messages to a heartbeat topic. Use 0 to disable heartbeat messages.
Disabled by default. | 0 | Integer
| *camel.component.debezium-mongodb.heartbeat-topics-prefix* | The prefix that
is used to name heartbeat topics.Defaults to __debezium-heartbeat. |
__debezium-heartbeat | String
-| *camel.component.debezium-mongodb.initial-sync-max-threads* | Maximum number
of threads used to perform an intial sync of the collections in a replica set.
Defaults to 1. | 1 | Integer
+| *camel.component.debezium-mongodb.initial-sync-max-threads* | Maximum number
of threads used to perform an initial sync of the collections in a replica set.
Defaults to 1. | 1 | Integer
| *camel.component.debezium-mongodb.internal-key-converter* | The Converter
class that should be used to serialize and deserialize key data for offsets.
The default is JSON converter. | org.apache.kafka.connect.json.JsonConverter |
String
| *camel.component.debezium-mongodb.internal-value-converter* | The Converter
class that should be used to serialize and deserialize value data for offsets.
The default is JSON converter. | org.apache.kafka.connect.json.JsonConverter |
String
| *camel.component.debezium-mongodb.max-batch-size* | Maximum size of each
batch of source records. Defaults to 2048. | 2048 | Integer
@@ -62,6 +62,7 @@ The component supports 43 options, which are listed below.
| *camel.component.debezium-mongodb.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-mongodb.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-mongodb.poll-interval-ms* | Frequency in
milliseconds to wait for new change events to appear after receiving no events.
Defaults to 500ms. | 500 | Long
+| *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.snapshot-delay-ms* | The number of
milliseconds to delay before a snapshot will begin. | 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
| *camel.component.debezium-mongodb.snapshot-mode* | The criteria for running
a snapshot upon startup of the connector. Options include: 'initial' (the
default) to specify the connector should always perform an initial sync when
required; 'never' to specify the connector should never perform an initial sync
| initial | String
diff --git a/docs/modules/ROOT/pages/debezium-mysql-starter.adoc
b/docs/modules/ROOT/pages/debezium-mysql-starter.adoc
index bfb5491..8abac9a 100644
--- a/docs/modules/ROOT/pages/debezium-mysql-starter.adoc
+++ b/docs/modules/ROOT/pages/debezium-mysql-starter.adoc
@@ -17,7 +17,7 @@ When using debezium-mysql with Spring Boot make sure to use
the following Maven
----
-The component supports 73 options, which are listed below.
+The component supports 74 options, which are listed below.
@@ -62,7 +62,8 @@ The component supports 73 options, which are listed below.
| *camel.component.debezium-mysql.enable-time-adjuster* | MySQL allows user to
insert year value as either 2-digit or 4-digit. In case of two digit the value
is automatically mapped into 1970 - 2069.false - delegates the implicit
conversion to the databasetrue - (the default) Debezium makes the conversion |
true | Boolean
| *camel.component.debezium-mysql.enabled* | Whether to enable auto
configuration of the debezium-mysql component. This is enabled by default. | |
Boolean
| *camel.component.debezium-mysql.event-deserialization-failure-handling-mode*
| Specify how failures during deserialization of binlog events (i.e. when
encountering a corrupted event) should be handled, including:'fail' (the
default) an exception indicating the problematic event and its binlog position
is raised, causing the connector to be stopped; 'warn' the problematic event
and its binlog position will be logged and the event will be skipped;'ignore'
the problematic event will be sk [...]
-| *camel.component.debezium-mysql.gtid-new-channel-position* | If set to
'latest', when connector sees new GTID, it will start consuming gtid channel
from the server latest executed gtid position. If 'earliest' connector starts
reading channel from first available (not purged) gtid position on the server.
| latest | String
+| *camel.component.debezium-mysql.event-processing-failure-handling-mode* |
Specify how failures during processing of events (i.e. when encountering a
corrupted event) should be handled, including:'fail' (the default) an exception
indicating the problematic event and its position is raised, causing the
connector to be stopped; 'warn' the problematic event and its position will be
logged and the event will be skipped;'ignore' the problematic event will be
skipped. | fail | String
+| *camel.component.debezium-mysql.gtid-new-channel-position* | If set to
'latest', when connector sees new GTID, it will start consuming gtid channel
from the server latest executed gtid position. If 'earliest' (the default)
connector starts reading channel from first available (not purged) gtid
position on the server. | earliest | String
| *camel.component.debezium-mysql.gtid-source-excludes* | The source UUIDs
used to exclude GTID ranges when determine the starting position in the MySQL
server's binlog. | | String
| *camel.component.debezium-mysql.gtid-source-filter-dml-events* | If set to
true, we will only produce DML events into Kafka for transactions that were
written on mysql servers with UUIDs matching the filters defined by the
gtid.source.includes or gtid.source.excludes configuration options, if they are
specified. | true | Boolean
| *camel.component.debezium-mysql.gtid-source-includes* | The source UUIDs
used to include GTID ranges when determine the starting position in the MySQL
server's binlog. | | String
@@ -70,7 +71,7 @@ The component supports 73 options, which are listed below.
| *camel.component.debezium-mysql.heartbeat-topics-prefix* | The prefix that
is used to name heartbeat topics.Defaults to __debezium-heartbeat. |
__debezium-heartbeat | String
| *camel.component.debezium-mysql.include-query* | Whether the connector
should include the original SQL query that generated the change event. Note:
This option requires MySQL be configured with the binlog_rows_query_log_events
option set to ON. Query will not be present for events generated from snapshot.
WARNING: Enabling this option may expose tables or fields explicitly
blacklisted or masked by including the original SQL statement in the change
event. For this reason the default val [...]
| *camel.component.debezium-mysql.include-schema-changes* | Whether the
connector should publish changes in the database schema to a Kafka topic with
the same name as the database server ID. Each schema change will be recorded
using a key that contains the database name and whose value includes the DDL
statement(s).The default is 'true'. This is independent of how the connector
internally records database history. | true | Boolean
-| *camel.component.debezium-mysql.inconsistent-schema-handling-mode* | Specify
how binlog events that belong to a table missing from internal schema
representation (i.e. internal representation is not consistent with database)
should be handled, including:'fail' (the default) an exception indicating the
problematic event and its binlog position is raised, causing the connector to
be stopped; 'warn' the problematic event and its binlog position will be logged
and the event will be skipped [...]
+| *camel.component.debezium-mysql.inconsistent-schema-handling-mode* | Specify
how binlog events that belong to a table missing from internal schema
representation (i.e. internal representation is not consistent with database)
should be handled, including:'fail' (the default) an exception indicating the
problematic event and its binlog position is raised, causing the connector to
be stopped; 'warn' the problematic event and its binlog position will be logged
and the event will be skipped [...]
| *camel.component.debezium-mysql.internal-key-converter* | The Converter
class that should be used to serialize and deserialize key data for offsets.
The default is JSON converter. | org.apache.kafka.connect.json.JsonConverter |
String
| *camel.component.debezium-mysql.internal-value-converter* | The Converter
class that should be used to serialize and deserialize value data for offsets.
The default is JSON converter. | org.apache.kafka.connect.json.JsonConverter |
String
| *camel.component.debezium-mysql.max-batch-size* | Maximum size of each batch
of source records. Defaults to 2048. | 2048 | Integer
diff --git a/docs/modules/ROOT/pages/debezium-postgres-starter.adoc
b/docs/modules/ROOT/pages/debezium-postgres-starter.adoc
index 156a4b8..f4b7f1a 100644
--- a/docs/modules/ROOT/pages/debezium-postgres-starter.adoc
+++ b/docs/modules/ROOT/pages/debezium-postgres-starter.adoc
@@ -17,7 +17,7 @@ When using debezium-postgres with Spring Boot make sure to
use the following Mav
----
-The component supports 65 options, which are listed below.
+The component supports 68 options, which are listed below.
@@ -46,9 +46,11 @@ The component supports 65 options, which are listed below.
| *camel.component.debezium-postgres.database-user* | Name of the Postgres
database user to be used when connecting to the database. | | String
| *camel.component.debezium-postgres.decimal-handling-mode* | Specify how
DECIMAL and NUMERIC columns should be represented in change events,
including:'precise' (the default) uses java.math.BigDecimal to represent
values, which are encoded in the change events using a binary representation
and Kafka Connect's 'org.apache.kafka.connect.data.Decimal' type; 'string' uses
string to represent values; 'double' represents values using Java's 'double',
which may not offer the precision but will [...]
| *camel.component.debezium-postgres.enabled* | Whether to enable auto
configuration of the debezium-postgres component. This is enabled by default. |
| Boolean
+| *camel.component.debezium-postgres.event-processing-failure-handling-mode* |
Specify how failures during processing of events (i.e. when encountering a
corrupted event) should be handled, including:'fail' (the default) an exception
indicating the problematic event and its position is raised, causing the
connector to be stopped; 'warn' the problematic event and its position will be
logged and the event will be skipped;'ignore' the problematic event will be
skipped. | fail | String
+| *camel.component.debezium-postgres.heartbeat-action-query* | The query
executed with every heartbeat. Defaults to an empty string. | | String
| *camel.component.debezium-postgres.heartbeat-interval-ms* | Length of an
interval in milli-seconds in in which the connector periodically sends
heartbeat messages to a heartbeat topic. Use 0 to disable heartbeat messages.
Disabled by default. | 0 | Integer
| *camel.component.debezium-postgres.heartbeat-topics-prefix* | The prefix
that is used to name heartbeat topics.Defaults to __debezium-heartbeat. |
__debezium-heartbeat | String
-| *camel.component.debezium-postgres.hstore-handling-mode* | Specify how
HSTORE columns should be represented in change events, including:'json'
represents values as json string'map' (default) represents values using
java.util.Map | json | String
+| *camel.component.debezium-postgres.hstore-handling-mode* | Specify how
HSTORE columns should be represented in change events, including:'json'
represents values as string-ified JSON (default)'map' represents values as a
key/value map | json | String
| *camel.component.debezium-postgres.include-unknown-datatypes* | Specify
whether the fields of data type not supported by Debezium should be
processed:'false' (the default) omits the fields; 'true' converts the field
into an implementation dependent binary representation. | false | Boolean
| *camel.component.debezium-postgres.internal-key-converter* | The Converter
class that should be used to serialize and deserialize key data for offsets.
The default is JSON converter. | org.apache.kafka.connect.json.JsonConverter |
String
| *camel.component.debezium-postgres.internal-value-converter* | The Converter
class that should be used to serialize and deserialize value data for offsets.
The default is JSON converter. | org.apache.kafka.connect.json.JsonConverter |
String
@@ -66,6 +68,7 @@ The component supports 65 options, which are listed below.
| *camel.component.debezium-postgres.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-postgres.plugin-name* | The name of the Postgres
logical decoding plugin installed on the server. Supported values are
'decoderbufs' and 'wal2json'. Defaults to 'decoderbufs'. | decoderbufs | String
| *camel.component.debezium-postgres.poll-interval-ms* | Frequency in
milliseconds to wait for new change events to appear after receiving no events.
Defaults to 500ms. | 500 | Long
+| *camel.component.debezium-postgres.provide-transaction-metadata* | Enables
transaction metadata extraction together with event counting | false | Boolean
| *camel.component.debezium-postgres.publication-name* | The name of the
Postgres 10 publication used for streaming changes from a plugin.Defaults to
'dbz_publication' | dbz_publication | String
| *camel.component.debezium-postgres.schema-blacklist* | The schemas for which
events must not 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 [...]
diff --git a/docs/modules/ROOT/pages/debezium-sqlserver-starter.adoc
b/docs/modules/ROOT/pages/debezium-sqlserver-starter.adoc
index 95fbadc..2d13c93 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 47 options, which are listed below.
+The component supports 49 options, which are listed below.
@@ -44,6 +44,7 @@ The component supports 47 options, which are listed below.
| *camel.component.debezium-sqlserver.database-user* | Name of the SQL Server
database user to be used when connecting to the database. | | String
| *camel.component.debezium-sqlserver.decimal-handling-mode* | Specify how
DECIMAL and NUMERIC columns should be represented in change events,
including:'precise' (the default) uses java.math.BigDecimal to represent
values, which are encoded in the change events using a binary representation
and Kafka Connect's 'org.apache.kafka.connect.data.Decimal' type; 'string' uses
string to represent values; 'double' represents values using Java's 'double',
which may not offer the precision but wil [...]
| *camel.component.debezium-sqlserver.enabled* | Whether to enable auto
configuration of the debezium-sqlserver component. This is enabled by default.
| | Boolean
+| *camel.component.debezium-sqlserver.event-processing-failure-handling-mode*
| Specify how failures during processing of events (i.e. when encountering a
corrupted event) should be handled, including:'fail' (the default) an exception
indicating the problematic event and its position is raised, causing the
connector to be stopped; 'warn' the problematic event and its position will be
logged and the event will be skipped;'ignore' the problematic event will be
skipped. | fail | String
| *camel.component.debezium-sqlserver.heartbeat-interval-ms* | Length of an
interval in milli-seconds in in which the connector periodically sends
heartbeat messages to a heartbeat topic. Use 0 to disable heartbeat messages.
Disabled by default. | 0 | Integer
| *camel.component.debezium-sqlserver.heartbeat-topics-prefix* | The prefix
that is used to name heartbeat topics.Defaults to __debezium-heartbeat. |
__debezium-heartbeat | String
| *camel.component.debezium-sqlserver.internal-key-converter* | The Converter
class that should be used to serialize and deserialize key data for offsets.
The default is JSON converter. | org.apache.kafka.connect.json.JsonConverter |
String
@@ -60,6 +61,7 @@ The component supports 47 options, which are listed below.
| *camel.component.debezium-sqlserver.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-sqlserver.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-sqlserver.poll-interval-ms* | Frequency in
milliseconds to wait for new change events to appear after receiving no events.
Defaults to 500ms. | 500 | Long
+| *camel.component.debezium-sqlserver.provide-transaction-metadata* | Enables
transaction metadata extraction together with event counting | false | Boolean
| *camel.component.debezium-sqlserver.snapshot-delay-ms* | The number of
milliseconds to delay before a snapshot will begin. | 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-lock-timeout-ms* | The maximum
number of millis to wait for table locks at the beginning of a snapshot. If
locks cannot be acquired in this time frame, the snapshot will be aborted.
Defaults to 10 seconds | 10000 | Long
diff --git a/tooling/camel-spring-boot-dependencies/pom.xml
b/tooling/camel-spring-boot-dependencies/pom.xml
index 431a981..4e43e7e 100644
--- a/tooling/camel-spring-boot-dependencies/pom.xml
+++ b/tooling/camel-spring-boot-dependencies/pom.xml
@@ -3496,6 +3496,11 @@
</dependency>
<dependency>
<groupId>org.apache.camel</groupId>
+ <artifactId>camel-spring-main</artifactId>
+ <version>3.2.0-SNAPSHOT</version>
+ </dependency>
+ <dependency>
+ <groupId>org.apache.camel</groupId>
<artifactId>camel-spring-redis</artifactId>
<version>3.2.0-SNAPSHOT</version>
</dependency>
