This is an automated email from the ASF dual-hosted git repository.
davsclaus pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/camel.git
The following commit(s) were added to refs/heads/master by this push:
new 6eac49b Regen
6eac49b is described below
commit 6eac49bd46d8ea07ad2588a2b9043c2573e2074c
Author: Claus Ibsen <claus.ib...@gmail.com>
AuthorDate: Tue Mar 24 16:00:35 2020 +0100
Regen
---
.../java/org/apache/camel/processor/TransformTest.java | 6 ++----
.../org/apache/camel/processor/TransformViaDSLTest.java | 4 +---
docs/components/modules/ROOT/nav.adoc | 1 +
.../modules/ROOT/pages/debezium-mongodb-component.adoc | 10 ++++++----
.../modules/ROOT/pages/debezium-mysql-component.adoc | 14 ++++++++------
.../modules/ROOT/pages/debezium-postgres-component.adoc | 14 ++++++++++----
.../modules/ROOT/pages/debezium-sqlserver-component.adoc | 8 ++++++--
docs/components/modules/ROOT/pages/index.adoc | 4 +++-
docs/components/modules/ROOT/pages/spring-main.adoc | 5 +++++
parent/pom.xml | 10 +++++-----
10 files changed, 47 insertions(+), 29 deletions(-)
diff --git
a/core/camel-core-engine/src/main/docs/modules/eips/examples/core/camel-core/src/test/java/org/apache/camel/processor/TransformTest.java
b/core/camel-core-engine/src/main/docs/modules/eips/examples/core/camel-core/src/test/java/org/apache/camel/processor/TransformTest.java
index 9658893..67d2ce2 100644
---
a/core/camel-core-engine/src/main/docs/modules/eips/examples/core/camel-core/src/test/java/org/apache/camel/processor/TransformTest.java
+++
b/core/camel-core-engine/src/main/docs/modules/eips/examples/core/camel-core/src/test/java/org/apache/camel/processor/TransformTest.java
@@ -49,14 +49,12 @@ public class TransformTest extends ContextTestSupport {
protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
public void configure() {
- // tag::example[]
- from("direct:start").process(new Processor() {
+ /*tag::example[]*/from("direct:start").process(new Processor()
{
public void process(Exchange exchange) {
Message in = exchange.getIn();
in.setBody(in.getBody(String.class) + " World!");
}
- }).to("mock:result");
- // end::example[]
+ }).to("mock:result"); /*end::example[]*/
}
};
}
diff --git
a/core/camel-core-engine/src/main/docs/modules/eips/examples/core/camel-core/src/test/java/org/apache/camel/processor/TransformViaDSLTest.java
b/core/camel-core-engine/src/main/docs/modules/eips/examples/core/camel-core/src/test/java/org/apache/camel/processor/TransformViaDSLTest.java
index 2b79ff2..9bfa08e 100644
---
a/core/camel-core-engine/src/main/docs/modules/eips/examples/core/camel-core/src/test/java/org/apache/camel/processor/TransformViaDSLTest.java
+++
b/core/camel-core-engine/src/main/docs/modules/eips/examples/core/camel-core/src/test/java/org/apache/camel/processor/TransformViaDSLTest.java
@@ -46,9 +46,7 @@ public class TransformViaDSLTest extends ContextTestSupport {
protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
public void configure() {
- // tag::example[]
- from("direct:start").setBody(body().append("
World!")).to("mock:result");
- // end::example[]
+ /*tag::example[]*/from("direct:start").setBody(body().append("
World!")).to("mock:result"); /*end::example[]*/
}
};
}
diff --git a/docs/components/modules/ROOT/nav.adoc
b/docs/components/modules/ROOT/nav.adoc
index 7e7a0e0..c56b23c 100644
--- a/docs/components/modules/ROOT/nav.adoc
+++ b/docs/components/modules/ROOT/nav.adoc
@@ -324,6 +324,7 @@
** xref:spring-integration-component.adoc[Spring Integration Component]
** xref:spring-javaconfig.adoc[Spring Java Config]
** xref:spring-ldap-component.adoc[Spring LDAP Component]
+** xref:spring-main.adoc[Spring Main]
** xref:spring-redis-component.adoc[Spring Redis Component]
** xref:spring-security.adoc[Spring Security]
** xref:spring.adoc[Spring Support]
diff --git a/docs/components/modules/ROOT/pages/debezium-mongodb-component.adoc
b/docs/components/modules/ROOT/pages/debezium-mongodb-component.adoc
index e300fbe..b7b99be 100644
--- a/docs/components/modules/ROOT/pages/debezium-mongodb-component.adoc
+++ b/docs/components/modules/ROOT/pages/debezium-mongodb-component.adoc
@@ -43,7 +43,7 @@ debezium-mongodb:name[?options]
// component options: START
-The Debezium MongoDB Connector component supports 42 options, which are listed
below.
+The Debezium MongoDB Connector component supports 43 options, which are listed
below.
@@ -76,7 +76,7 @@ The Debezium MongoDB Connector component supports 42 options,
which are listed b
| *fieldRenames* (mongodb) | Description is not available here, please check
Debezium website for corresponding key 'field.renames' description. | | String
| *heartbeatIntervalMs* (mongodb) | 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 | int
| *heartbeatTopicsPrefix* (mongodb) | The prefix that is used to name
heartbeat topics.Defaults to __debezium-heartbeat. | __debezium-heartbeat |
String
-| *initialSyncMaxThreads* (mongodb) | Maximum number of threads used to
perform an intial sync of the collections in a replica set. Defaults to 1. | 1
| int
+| *initialSyncMaxThreads* (mongodb) | Maximum number of threads used to
perform an initial sync of the collections in a replica set. Defaults to 1. | 1
| int
| *maxBatchSize* (mongodb) | Maximum size of each batch of source records.
Defaults to 2048. | 2048 | int
| *maxQueueSize* (mongodb) | Maximum size of the queue for change events read
from the database log but not yet recorded or forwarded. Defaults to 8192, and
should always be larger than the maximum batch size. | 8192 | int
| *mongodbHosts* (mongodb) | The hostname and port pairs (in the form 'host'
or 'host:port') of the MongoDB server(s) in the replica set. | | String
@@ -87,6 +87,7 @@ The Debezium MongoDB Connector component supports 42 options,
which are listed b
| *mongodbSslInvalidHostname Allowed* (mongodb) | Whether invalid host names
are allowed when using SSL. If true the connection will not prevent
man-in-the-middle attacks | false | boolean
| *mongodbUser* (mongodb) | Database user for connecting to MongoDB, if
necessary. | | String
| *pollIntervalMs* (mongodb) | Frequency in milliseconds to wait for new
change events to appear after receiving no events. Defaults to 500ms. | 500 |
long
+| *skippedOperations* (mongodb) | The comma-separated list of operations to
skip during streaming, defined as: 'i' for inserts; 'u' for updates; 'd' for
deletes. By default, no operations will be skipped. | | String
| *snapshotDelayMs* (mongodb) | The number of milliseconds to delay before a
snapshot will begin. | 0 | long
| *snapshotFetchSize* (mongodb) | The maximum number of records that should be
loaded into memory while performing a snapshot | | int
| *snapshotMode* (mongodb) | 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
@@ -115,7 +116,7 @@ with the following path and query parameters:
|===
-=== Query Parameters (44 parameters):
+=== Query Parameters (45 parameters):
[width="100%",cols="2,5,^1,2",options="header"]
@@ -149,7 +150,7 @@ with the following path and query parameters:
| *fieldRenames* (mongodb) | Description is not available here, please check
Debezium website for corresponding key 'field.renames' description. | | String
| *heartbeatIntervalMs* (mongodb) | 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 | int
| *heartbeatTopicsPrefix* (mongodb) | The prefix that is used to name
heartbeat topics.Defaults to __debezium-heartbeat. | __debezium-heartbeat |
String
-| *initialSyncMaxThreads* (mongodb) | Maximum number of threads used to
perform an intial sync of the collections in a replica set. Defaults to 1. | 1
| int
+| *initialSyncMaxThreads* (mongodb) | Maximum number of threads used to
perform an initial sync of the collections in a replica set. Defaults to 1. | 1
| int
| *maxBatchSize* (mongodb) | Maximum size of each batch of source records.
Defaults to 2048. | 2048 | int
| *maxQueueSize* (mongodb) | Maximum size of the queue for change events read
from the database log but not yet recorded or forwarded. Defaults to 8192, and
should always be larger than the maximum batch size. | 8192 | int
| *mongodbHosts* (mongodb) | The hostname and port pairs (in the form 'host'
or 'host:port') of the MongoDB server(s) in the replica set. | | String
@@ -160,6 +161,7 @@ with the following path and query parameters:
| *mongodbSslInvalidHostname Allowed* (mongodb) | Whether invalid host names
are allowed when using SSL. If true the connection will not prevent
man-in-the-middle attacks | false | boolean
| *mongodbUser* (mongodb) | Database user for connecting to MongoDB, if
necessary. | | String
| *pollIntervalMs* (mongodb) | Frequency in milliseconds to wait for new
change events to appear after receiving no events. Defaults to 500ms. | 500 |
long
+| *skippedOperations* (mongodb) | The comma-separated list of operations to
skip during streaming, defined as: 'i' for inserts; 'u' for updates; 'd' for
deletes. By default, no operations will be skipped. | | String
| *snapshotDelayMs* (mongodb) | The number of milliseconds to delay before a
snapshot will begin. | 0 | long
| *snapshotFetchSize* (mongodb) | The maximum number of records that should be
loaded into memory while performing a snapshot | | int
| *snapshotMode* (mongodb) | 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/components/modules/ROOT/pages/debezium-mysql-component.adoc
b/docs/components/modules/ROOT/pages/debezium-mysql-component.adoc
index 1f4e2b4..fd5cadb 100644
--- a/docs/components/modules/ROOT/pages/debezium-mysql-component.adoc
+++ b/docs/components/modules/ROOT/pages/debezium-mysql-component.adoc
@@ -50,7 +50,7 @@ debezium-mysql:name[?options]
// component options: START
-The Debezium MySQL Connector component supports 72 options, which are listed
below.
+The Debezium MySQL Connector component supports 73 options, which are listed
below.
@@ -104,7 +104,8 @@ The Debezium MySQL Connector component supports 72 options,
which are listed bel
| *decimalHandlingMode* (mysql) | Specify how DECIMAL and NUMERIC columns
should be represented in change events, including:'precise' (the default) uses
java.math.BigDecimal to represent values, which are encoded in the change
events using a binary representation and Kafka Connect's
'org.apache.kafka.connect.data.Decimal' type; 'string' uses string to represent
values; 'double' represents values using Java's 'double', which may not offer
the precision but will be far easier to use in con [...]
| *enableTimeAdjuster* (mysql) | 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
| *eventDeserializationFailure HandlingMode* (mysql) | 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 skipped. | fail | String
-| *gtidNewChannelPosition* (mysql) | 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
+| *eventProcessingFailureHandling Mode* (mysql) | 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
+| *gtidNewChannelPosition* (mysql) | 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
| *gtidSourceExcludes* (mysql) | The source UUIDs used to exclude GTID ranges
when determine the starting position in the MySQL server's binlog. | | String
| *gtidSourceFilterDmlEvents* (mysql) | 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
| *gtidSourceIncludes* (mysql) | The source UUIDs used to include GTID ranges
when determine the starting position in the MySQL server's binlog. | | String
@@ -112,7 +113,7 @@ The Debezium MySQL Connector component supports 72 options,
which are listed bel
| *heartbeatTopicsPrefix* (mysql) | The prefix that is used to name heartbeat
topics.Defaults to __debezium-heartbeat. | __debezium-heartbeat | String
| *includeQuery* (mysql) | 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 value is 'false'. | false | [...]
| *includeSchemaChanges* (mysql) | 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
-| *inconsistentSchemaHandlingMode* (mysql) | 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;'ignore' the problematic [...]
+| *inconsistentSchemaHandlingMode* (mysql) | 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;'skip' the problematic ev [...]
| *maxBatchSize* (mysql) | Maximum size of each batch of source records.
Defaults to 2048. | 2048 | int
| *maxQueueSize* (mysql) | Maximum size of the queue for change events read
from the database log but not yet recorded or forwarded. Defaults to 8192, and
should always be larger than the maximum batch size. | 8192 | int
| *messageKeyColumns* (mysql) | A semicolon-separated list of expressions that
match fully-qualified tables and column(s) to be used as message key. Each
expression must match the pattern ':',where the table names could be defined as
(DB_NAME.TABLE_NAME) or (SCHEMA_NAME.TABLE_NAME), depending on the specific
connector,and the key columns are a comma-separated list of columns
representing the custom key. For any table without an explicit key
configuration the table's primary key column(s) [...]
@@ -152,7 +153,7 @@ with the following path and query parameters:
|===
-=== Query Parameters (74 parameters):
+=== Query Parameters (75 parameters):
[width="100%",cols="2,5,^1,2",options="header"]
@@ -207,7 +208,8 @@ with the following path and query parameters:
| *decimalHandlingMode* (mysql) | Specify how DECIMAL and NUMERIC columns
should be represented in change events, including:'precise' (the default) uses
java.math.BigDecimal to represent values, which are encoded in the change
events using a binary representation and Kafka Connect's
'org.apache.kafka.connect.data.Decimal' type; 'string' uses string to represent
values; 'double' represents values using Java's 'double', which may not offer
the precision but will be far easier to use in con [...]
| *enableTimeAdjuster* (mysql) | 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
| *eventDeserializationFailure HandlingMode* (mysql) | 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 skipped. | fail | String
-| *gtidNewChannelPosition* (mysql) | 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
+| *eventProcessingFailureHandling Mode* (mysql) | 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
+| *gtidNewChannelPosition* (mysql) | 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
| *gtidSourceExcludes* (mysql) | The source UUIDs used to exclude GTID ranges
when determine the starting position in the MySQL server's binlog. | | String
| *gtidSourceFilterDmlEvents* (mysql) | 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
| *gtidSourceIncludes* (mysql) | The source UUIDs used to include GTID ranges
when determine the starting position in the MySQL server's binlog. | | String
@@ -215,7 +217,7 @@ with the following path and query parameters:
| *heartbeatTopicsPrefix* (mysql) | The prefix that is used to name heartbeat
topics.Defaults to __debezium-heartbeat. | __debezium-heartbeat | String
| *includeQuery* (mysql) | 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 value is 'false'. | false | [...]
| *includeSchemaChanges* (mysql) | 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
-| *inconsistentSchemaHandlingMode* (mysql) | 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;'ignore' the problematic [...]
+| *inconsistentSchemaHandlingMode* (mysql) | 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;'skip' the problematic ev [...]
| *maxBatchSize* (mysql) | Maximum size of each batch of source records.
Defaults to 2048. | 2048 | int
| *maxQueueSize* (mysql) | Maximum size of the queue for change events read
from the database log but not yet recorded or forwarded. Defaults to 8192, and
should always be larger than the maximum batch size. | 8192 | int
| *messageKeyColumns* (mysql) | A semicolon-separated list of expressions that
match fully-qualified tables and column(s) to be used as message key. Each
expression must match the pattern ':',where the table names could be defined as
(DB_NAME.TABLE_NAME) or (SCHEMA_NAME.TABLE_NAME), depending on the specific
connector,and the key columns are a comma-separated list of columns
representing the custom key. For any table without an explicit key
configuration the table's primary key column(s) [...]
diff --git
a/docs/components/modules/ROOT/pages/debezium-postgres-component.adoc
b/docs/components/modules/ROOT/pages/debezium-postgres-component.adoc
index 0260e8a..849e759 100644
--- a/docs/components/modules/ROOT/pages/debezium-postgres-component.adoc
+++ b/docs/components/modules/ROOT/pages/debezium-postgres-component.adoc
@@ -41,7 +41,7 @@ debezium-postgres:name[?options]
// component options: START
-The Debezium PostgresSQL Connector component supports 64 options, which are
listed below.
+The Debezium PostgresSQL Connector component supports 67 options, which are
listed below.
@@ -79,9 +79,11 @@ The Debezium PostgresSQL Connector component supports 64
options, which are list
| *databaseTcpkeepalive* (postgres) | Enable or disable TCP keep-alive probe
to avoid dropping TCP connection | true | boolean
| *databaseUser* (postgres) | Name of the Postgres database user to be used
when connecting to the database. | | String
| *decimalHandlingMode* (postgres) | Specify how DECIMAL and NUMERIC columns
should be represented in change events, including:'precise' (the default) uses
java.math.BigDecimal to represent values, which are encoded in the change
events using a binary representation and Kafka Connect's
'org.apache.kafka.connect.data.Decimal' type; 'string' uses string to represent
values; 'double' represents values using Java's 'double', which may not offer
the precision but will be far easier to use in [...]
+| *eventProcessingFailureHandling Mode* (postgres) | 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
+| *heartbeatActionQuery* (postgres) | The query executed with every heartbeat.
Defaults to an empty string. | | String
| *heartbeatIntervalMs* (postgres) | 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 | int
| *heartbeatTopicsPrefix* (postgres) | The prefix that is used to name
heartbeat topics.Defaults to __debezium-heartbeat. | __debezium-heartbeat |
String
-| *hstoreHandlingMode* (postgres) | 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
+| *hstoreHandlingMode* (postgres) | 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
| *includeUnknownDatatypes* (postgres) | 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
| *intervalHandlingMode* (postgres) | Specify how INTERVAL columns should be
represented in change events, including:'string' represents values as an exact
ISO formatted string'numeric' (default) represents values using the inexact
conversion into microseconds | numeric | String
| *maxBatchSize* (postgres) | Maximum size of each batch of source records.
Defaults to 2048. | 2048 | int
@@ -89,6 +91,7 @@ The Debezium PostgresSQL Connector component supports 64
options, which are list
| *messageKeyColumns* (postgres) | A semicolon-separated list of expressions
that match fully-qualified tables and column(s) to be used as message key. Each
expression must match the pattern ':',where the table names could be defined as
(DB_NAME.TABLE_NAME) or (SCHEMA_NAME.TABLE_NAME), depending on the specific
connector,and the key columns are a comma-separated list of columns
representing the custom key. For any table without an explicit key
configuration the table's primary key column [...]
| *pluginName* (postgres) | The name of the Postgres logical decoding plugin
installed on the server. Supported values are 'decoderbufs' and 'wal2json'.
Defaults to 'decoderbufs'. | decoderbufs | String
| *pollIntervalMs* (postgres) | Frequency in milliseconds to wait for new
change events to appear after receiving no events. Defaults to 500ms. | 500 |
long
+| *provideTransactionMetadata* (postgres) | Enables transaction metadata
extraction together with event counting | false | boolean
| *publicationName* (postgres) | The name of the Postgres 10 publication used
for streaming changes from a plugin.Defaults to 'dbz_publication' |
dbz_publication | String
| *schemaBlacklist* (postgres) | The schemas for which events must not be
captured | | String
| *schemaRefreshMode* (postgres) | Specify the conditions that trigger a
refresh of the in-memory schema for a table. 'columns_diff' (the default) is
the safest mode, ensuring the in-memory schema stays in-sync with the database
table's schema at all times. 'columns_diff_exclude_unchanged_toast' instructs
the connector to refresh the in-memory schema cache if there is a discrepancy
between it and the schema derived from the incoming message, unless unchanged
TOASTable data fully accounts [...]
@@ -135,7 +138,7 @@ with the following path and query parameters:
|===
-=== Query Parameters (66 parameters):
+=== Query Parameters (69 parameters):
[width="100%",cols="2,5,^1,2",options="header"]
@@ -174,9 +177,11 @@ with the following path and query parameters:
| *databaseTcpkeepalive* (postgres) | Enable or disable TCP keep-alive probe
to avoid dropping TCP connection | true | boolean
| *databaseUser* (postgres) | Name of the Postgres database user to be used
when connecting to the database. | | String
| *decimalHandlingMode* (postgres) | Specify how DECIMAL and NUMERIC columns
should be represented in change events, including:'precise' (the default) uses
java.math.BigDecimal to represent values, which are encoded in the change
events using a binary representation and Kafka Connect's
'org.apache.kafka.connect.data.Decimal' type; 'string' uses string to represent
values; 'double' represents values using Java's 'double', which may not offer
the precision but will be far easier to use in [...]
+| *eventProcessingFailureHandling Mode* (postgres) | 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
+| *heartbeatActionQuery* (postgres) | The query executed with every heartbeat.
Defaults to an empty string. | | String
| *heartbeatIntervalMs* (postgres) | 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 | int
| *heartbeatTopicsPrefix* (postgres) | The prefix that is used to name
heartbeat topics.Defaults to __debezium-heartbeat. | __debezium-heartbeat |
String
-| *hstoreHandlingMode* (postgres) | 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
+| *hstoreHandlingMode* (postgres) | 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
| *includeUnknownDatatypes* (postgres) | 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
| *intervalHandlingMode* (postgres) | Specify how INTERVAL columns should be
represented in change events, including:'string' represents values as an exact
ISO formatted string'numeric' (default) represents values using the inexact
conversion into microseconds | numeric | String
| *maxBatchSize* (postgres) | Maximum size of each batch of source records.
Defaults to 2048. | 2048 | int
@@ -184,6 +189,7 @@ with the following path and query parameters:
| *messageKeyColumns* (postgres) | A semicolon-separated list of expressions
that match fully-qualified tables and column(s) to be used as message key. Each
expression must match the pattern ':',where the table names could be defined as
(DB_NAME.TABLE_NAME) or (SCHEMA_NAME.TABLE_NAME), depending on the specific
connector,and the key columns are a comma-separated list of columns
representing the custom key. For any table without an explicit key
configuration the table's primary key column [...]
| *pluginName* (postgres) | The name of the Postgres logical decoding plugin
installed on the server. Supported values are 'decoderbufs' and 'wal2json'.
Defaults to 'decoderbufs'. | decoderbufs | String
| *pollIntervalMs* (postgres) | Frequency in milliseconds to wait for new
change events to appear after receiving no events. Defaults to 500ms. | 500 |
long
+| *provideTransactionMetadata* (postgres) | Enables transaction metadata
extraction together with event counting | false | boolean
| *publicationName* (postgres) | The name of the Postgres 10 publication used
for streaming changes from a plugin.Defaults to 'dbz_publication' |
dbz_publication | String
| *schemaBlacklist* (postgres) | The schemas for which events must not be
captured | | String
| *schemaRefreshMode* (postgres) | Specify the conditions that trigger a
refresh of the in-memory schema for a table. 'columns_diff' (the default) is
the safest mode, ensuring the in-memory schema stays in-sync with the database
table's schema at all times. 'columns_diff_exclude_unchanged_toast' instructs
the connector to refresh the in-memory schema cache if there is a discrepancy
between it and the schema derived from the incoming message, unless unchanged
TOASTable data fully accounts [...]
diff --git
a/docs/components/modules/ROOT/pages/debezium-sqlserver-component.adoc
b/docs/components/modules/ROOT/pages/debezium-sqlserver-component.adoc
index ea03381..974868e 100644
--- a/docs/components/modules/ROOT/pages/debezium-sqlserver-component.adoc
+++ b/docs/components/modules/ROOT/pages/debezium-sqlserver-component.adoc
@@ -40,7 +40,7 @@ debezium-sqlserver:name[?options]
// component options: START
-The Debezium SQL Server Connector component supports 46 options, which are
listed below.
+The Debezium SQL Server Connector component supports 48 options, which are
listed below.
@@ -76,12 +76,14 @@ The Debezium SQL Server Connector component supports 46
options, which are liste
| *databaseServerTimezone* (sqlserver) | The timezone of the server used to
correctly shift the commit transaction timestamp on the client sideOptions
include: Any valid Java ZoneId | | String
| *databaseUser* (sqlserver) | Name of the SQL Server database user to be used
when connecting to the database. | | String
| *decimalHandlingMode* (sqlserver) | Specify how DECIMAL and NUMERIC columns
should be represented in change events, including:'precise' (the default) uses
java.math.BigDecimal to represent values, which are encoded in the change
events using a binary representation and Kafka Connect's
'org.apache.kafka.connect.data.Decimal' type; 'string' uses string to represent
values; 'double' represents values using Java's 'double', which may not offer
the precision but will be far easier to use in [...]
+| *eventProcessingFailureHandling Mode* (sqlserver) | 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
| *heartbeatIntervalMs* (sqlserver) | 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 | int
| *heartbeatTopicsPrefix* (sqlserver) | The prefix that is used to name
heartbeat topics.Defaults to __debezium-heartbeat. | __debezium-heartbeat |
String
| *maxBatchSize* (sqlserver) | Maximum size of each batch of source records.
Defaults to 2048. | 2048 | int
| *maxQueueSize* (sqlserver) | Maximum size of the queue for change events
read from the database log but not yet recorded or forwarded. Defaults to 8192,
and should always be larger than the maximum batch size. | 8192 | int
| *messageKeyColumns* (sqlserver) | A semicolon-separated list of expressions
that match fully-qualified tables and column(s) to be used as message key. Each
expression must match the pattern ':',where the table names could be defined as
(DB_NAME.TABLE_NAME) or (SCHEMA_NAME.TABLE_NAME), depending on the specific
connector,and the key columns are a comma-separated list of columns
representing the custom key. For any table without an explicit key
configuration the table's primary key colum [...]
| *pollIntervalMs* (sqlserver) | Frequency in milliseconds to wait for new
change events to appear after receiving no events. Defaults to 500ms. | 500 |
long
+| *provideTransactionMetadata* (sqlserver) | Enables transaction metadata
extraction together with event counting | false | boolean
| *snapshotDelayMs* (sqlserver) | The number of milliseconds to delay before a
snapshot will begin. | 0 | long
| *snapshotFetchSize* (sqlserver) | The maximum number of records that should
be loaded into memory while performing a snapshot | | int
| *snapshotLockTimeoutMs* (sqlserver) | 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
@@ -116,7 +118,7 @@ with the following path and query parameters:
|===
-=== Query Parameters (48 parameters):
+=== Query Parameters (50 parameters):
[width="100%",cols="2,5,^1,2",options="header"]
@@ -153,12 +155,14 @@ with the following path and query parameters:
| *databaseServerTimezone* (sqlserver) | The timezone of the server used to
correctly shift the commit transaction timestamp on the client sideOptions
include: Any valid Java ZoneId | | String
| *databaseUser* (sqlserver) | Name of the SQL Server database user to be used
when connecting to the database. | | String
| *decimalHandlingMode* (sqlserver) | Specify how DECIMAL and NUMERIC columns
should be represented in change events, including:'precise' (the default) uses
java.math.BigDecimal to represent values, which are encoded in the change
events using a binary representation and Kafka Connect's
'org.apache.kafka.connect.data.Decimal' type; 'string' uses string to represent
values; 'double' represents values using Java's 'double', which may not offer
the precision but will be far easier to use in [...]
+| *eventProcessingFailureHandling Mode* (sqlserver) | 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
| *heartbeatIntervalMs* (sqlserver) | 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 | int
| *heartbeatTopicsPrefix* (sqlserver) | The prefix that is used to name
heartbeat topics.Defaults to __debezium-heartbeat. | __debezium-heartbeat |
String
| *maxBatchSize* (sqlserver) | Maximum size of each batch of source records.
Defaults to 2048. | 2048 | int
| *maxQueueSize* (sqlserver) | Maximum size of the queue for change events
read from the database log but not yet recorded or forwarded. Defaults to 8192,
and should always be larger than the maximum batch size. | 8192 | int
| *messageKeyColumns* (sqlserver) | A semicolon-separated list of expressions
that match fully-qualified tables and column(s) to be used as message key. Each
expression must match the pattern ':',where the table names could be defined as
(DB_NAME.TABLE_NAME) or (SCHEMA_NAME.TABLE_NAME), depending on the specific
connector,and the key columns are a comma-separated list of columns
representing the custom key. For any table without an explicit key
configuration the table's primary key colum [...]
| *pollIntervalMs* (sqlserver) | Frequency in milliseconds to wait for new
change events to appear after receiving no events. Defaults to 500ms. | 500 |
long
+| *provideTransactionMetadata* (sqlserver) | Enables transaction metadata
extraction together with event counting | false | boolean
| *snapshotDelayMs* (sqlserver) | The number of milliseconds to delay before a
snapshot will begin. | 0 | long
| *snapshotFetchSize* (sqlserver) | The maximum number of records that should
be loaded into memory while performing a snapshot | | int
| *snapshotLockTimeoutMs* (sqlserver) | 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/docs/components/modules/ROOT/pages/index.adoc
b/docs/components/modules/ROOT/pages/index.adoc
index ff73665..e058017 100644
--- a/docs/components/modules/ROOT/pages/index.adoc
+++ b/docs/components/modules/ROOT/pages/index.adoc
@@ -688,7 +688,7 @@ Number of Components: 332 in 265 JAR artifacts (1
deprecated)
== Miscellaneous Components
// others: START
-Number of Miscellaneous Components: 37 in 37 JAR artifacts (0 deprecated)
+Number of Miscellaneous Components: 38 in 38 JAR artifacts (0 deprecated)
[width="100%",cols="4,1,5",options="header"]
|===
@@ -740,6 +740,8 @@ Number of Miscellaneous Components: 37 in 37 JAR artifacts
(0 deprecated)
| xref:spring-javaconfig.adoc[Spring Java Configuration]
(camel-spring-javaconfig) | 2.0 | Using Camel with Spring Java Configuration
+| xref:spring-main.adoc[Spring Main] (camel-spring-main) | 3.2 | Camel Spring
Main support
+
| xref:spring-security.adoc[Spring Security] (camel-spring-security) | 2.3 |
Security using Spring Security
| xref:swagger-java.adoc[Swagger Java] (camel-swagger-java) | 2.16 | Rest-dsl
support for using swagger api-doc
diff --git a/docs/components/modules/ROOT/pages/spring-main.adoc
b/docs/components/modules/ROOT/pages/spring-main.adoc
new file mode 100644
index 0000000..5a768d6
--- /dev/null
+++ b/docs/components/modules/ROOT/pages/spring-main.adoc
@@ -0,0 +1,5 @@
+[[SpringMain-SpringMain]]
+= Spring Main
+:page-source: components/camel-spring-main/src/main/docs/spring-main.adoc
+
+This module is used for running Spring standalone via a main class extended
from `camel-main`.
diff --git a/parent/pom.xml b/parent/pom.xml
index dafb2e4..5998f18 100644
--- a/parent/pom.xml
+++ b/parent/pom.xml
@@ -2332,11 +2332,6 @@
</dependency>
<dependency>
<groupId>org.apache.camel</groupId>
- <artifactId>camel-spring-main</artifactId>
- <version>${project.version}</version>
- </dependency>
- <dependency>
- <groupId>org.apache.camel</groupId>
<artifactId>camel-spring-batch</artifactId>
<version>${project.version}</version>
</dependency>
@@ -2357,6 +2352,11 @@
</dependency>
<dependency>
<groupId>org.apache.camel</groupId>
+ <artifactId>camel-spring-main</artifactId>
+ <version>${project.version}</version>
+ </dependency>
+ <dependency>
+ <groupId>org.apache.camel</groupId>
<artifactId>camel-spring-redis</artifactId>
<version>${project.version}</version>
</dependency>
