This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git
The following commit(s) were added to refs/heads/main by this push:
new 3e5427d [create-pull-request] automated change
3e5427d is described below
commit 3e5427d2980b69d9f8e6eca83e3b16da325e82d5
Author: github-actions[bot]
<41898282+github-actions[bot]@users.noreply.github.com>
AuthorDate: Tue Jun 22 03:44:25 2021 +0000
[create-pull-request] automated change
---
.../resources/connectors/camel-elsql-sink.json | 8 +-------
.../resources/connectors/camel-elsql-source.json | 8 +-------
.../connectors/camel-hwcloud-iam-sink.json | 24 ++++++++--------------
.../connectors/camel-hwcloud-smn-sink.json | 2 +-
.../resources/connectors/camel-iota-sink.json | 2 +-
.../resources/connectors/camel-kamelet-sink.json | 10 +++++++--
.../resources/connectors/camel-kamelet-source.json | 10 +++++++--
.../resources/connectors/camel-sql-sink.json | 8 +-------
.../resources/connectors/camel-sql-source.json | 8 +-------
.../src/generated/resources/camel-elsql-sink.json | 8 +-------
.../generated/resources/camel-elsql-source.json | 8 +-------
.../docs/camel-elsql-kafka-sink-connector.adoc | 5 ++---
.../docs/camel-elsql-kafka-source-connector.adoc | 5 ++---
.../elsql/CamelElsqlSinkConnectorConfig.java | 6 +-----
.../elsql/CamelElsqlSourceConnectorConfig.java | 6 +-----
.../resources/camel-hwcloud-iam-sink.json | 24 ++++++++--------------
.../camel-hwcloud-iam-kafka-sink-connector.adoc | 11 +++-------
.../CamelHwcloudiamSinkConnector.properties | 2 +-
.../CamelHwcloudiamSinkConnectorConfig.java | 14 +++++--------
.../resources/camel-hwcloud-smn-sink.json | 2 +-
.../camel-hwcloud-smn-kafka-sink-connector.adoc | 2 +-
.../src/generated/resources/camel-iota-sink.json | 2 +-
.../main/docs/camel-iota-kafka-sink-connector.adoc | 2 +-
.../iota/CamelIotaSinkConnectorConfig.java | 2 +-
.../generated/resources/camel-kamelet-sink.json | 10 +++++++--
.../generated/resources/camel-kamelet-source.json | 10 +++++++--
.../docs/camel-kamelet-kafka-sink-connector.adoc | 5 +++--
.../docs/camel-kamelet-kafka-source-connector.adoc | 5 +++--
.../kamelet/CamelKameletSinkConnectorConfig.java | 12 +++++++----
.../kamelet/CamelKameletSourceConnectorConfig.java | 12 +++++++----
.../src/generated/resources/camel-sql-sink.json | 8 +-------
.../src/generated/resources/camel-sql-source.json | 8 +-------
.../main/docs/camel-sql-kafka-sink-connector.adoc | 5 ++---
.../docs/camel-sql-kafka-source-connector.adoc | 5 ++---
.../sql/CamelSqlSinkConnectorConfig.java | 6 +-----
.../sql/CamelSqlSourceConnectorConfig.java | 6 +-----
.../camel-elsql-kafka-sink-connector.adoc | 9 ++------
.../camel-elsql-kafka-source-connector.adoc | 9 ++------
.../camel-hwcloud-iam-kafka-sink-connector.adoc | 11 +++-------
.../camel-hwcloud-smn-kafka-sink-connector.adoc | 6 +-----
.../camel-iota-kafka-sink-connector.adoc | 6 +-----
.../camel-kamelet-kafka-sink-connector.adoc | 9 +++-----
.../camel-kamelet-kafka-source-connector.adoc | 9 +++-----
.../connectors/camel-sql-kafka-sink-connector.adoc | 9 ++------
.../camel-sql-kafka-source-connector.adoc | 9 ++------
45 files changed, 127 insertions(+), 221 deletions(-)
diff --git
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-elsql-sink.json
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-elsql-sink.json
index 0732497..7389b73 100644
---
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-elsql-sink.json
+++
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-elsql-sink.json
@@ -45,16 +45,10 @@
},
"camel.sink.endpoint.dataSource": {
"name": "camel.sink.endpoint.dataSource",
- "description": "Sets the DataSource to use to
communicate with the database.",
+ "description": "Sets the DataSource to use to
communicate with the database at endpoint level.",
"priority": "MEDIUM",
"required": "false"
},
- "camel.sink.endpoint.dataSourceRef": {
- "name": "camel.sink.endpoint.dataSourceRef",
- "description": "Sets the reference to a DataSource to
lookup from the registry, to use for communicating with the database.",
- "priority": "LOW",
- "required": "false"
- },
"camel.sink.endpoint.outputClass": {
"name": "camel.sink.endpoint.outputClass",
"description": "Specify the full package and class name
to use as conversion when outputType=SelectOne.",
diff --git
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-elsql-source.json
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-elsql-source.json
index 38b8e5b..bbed3e6 100644
---
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-elsql-source.json
+++
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-elsql-source.json
@@ -45,16 +45,10 @@
},
"camel.source.endpoint.dataSource": {
"name": "camel.source.endpoint.dataSource",
- "description": "Sets the DataSource to use to
communicate with the database.",
+ "description": "Sets the DataSource to use to
communicate with the database at endpoint level.",
"priority": "MEDIUM",
"required": "false"
},
- "camel.source.endpoint.dataSourceRef": {
- "name": "camel.source.endpoint.dataSourceRef",
- "description": "Sets the reference to a DataSource to
lookup from the registry, to use for communicating with the database.",
- "priority": "LOW",
- "required": "false"
- },
"camel.source.endpoint.outputClass": {
"name": "camel.source.endpoint.outputClass",
"description": "Specify the full package and class name
to use as conversion when outputType=SelectOne.",
diff --git
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-hwcloud-iam-sink.json
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-hwcloud-iam-sink.json
index 3670e52..12652ab 100644
---
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-hwcloud-iam-sink.json
+++
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-hwcloud-iam-sink.json
@@ -21,12 +21,6 @@
"priority": "HIGH",
"required": "true"
},
- "camel.sink.endpoint.endpoint": {
- "name": "camel.sink.endpoint.endpoint",
- "description": "IAM endpoint url. Carries higher
precedence than region parameter based client initialization",
- "priority": "MEDIUM",
- "required": "false"
- },
"camel.sink.endpoint.groupId": {
"name": "camel.sink.endpoint.groupId",
"description": "Group ID to perform operation with",
@@ -40,6 +34,13 @@
"priority": "MEDIUM",
"required": "false"
},
+ "camel.sink.endpoint.lazyStartProducer": {
+ "name": "camel.sink.endpoint.lazyStartProducer",
+ "description": "Whether the producer should be started
lazy (on the first message). By starting lazy you can use this to allow
CamelContext and routes to startup in situations where a producer may otherwise
fail during starting and cause the route to fail being started. By deferring
this startup to be lazy then the startup failure can be handled during routing
messages via Camel's routing error handlers. Beware that when the first message
is processed then creating and starting the pr [...]
+ "defaultValue": "false",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
"camel.sink.endpoint.proxyHost": {
"name": "camel.sink.endpoint.proxyHost",
"description": "Proxy server ip\/hostname",
@@ -66,7 +67,7 @@
},
"camel.sink.endpoint.region": {
"name": "camel.sink.endpoint.region",
- "description": "IAM service region. This is lower
precedence than endpoint based configuration",
+ "description": "IAM service region",
"priority": "HIGH",
"required": "true"
},
@@ -88,13 +89,6 @@
"priority": "MEDIUM",
"required": "false"
},
- "camel.sink.endpoint.lazyStartProducer": {
- "name": "camel.sink.endpoint.lazyStartProducer",
- "description": "Whether the producer should be started
lazy (on the first message). By starting lazy you can use this to allow
CamelContext and routes to startup in situations where a producer may otherwise
fail during starting and cause the route to fail being started. By deferring
this startup to be lazy then the startup failure can be handled during routing
messages via Camel's routing error handlers. Beware that when the first message
is processed then creating and starting the pr [...]
- "defaultValue": "false",
- "priority": "MEDIUM",
- "required": "false"
- },
"camel.component.hwcloud-iam.lazyStartProducer": {
"name": "camel.component.hwcloud-iam.lazyStartProducer",
"description": "Whether the producer should be started
lazy (on the first message). By starting lazy you can use this to allow
CamelContext and routes to startup in situations where a producer may otherwise
fail during starting and cause the route to fail being started. By deferring
this startup to be lazy then the startup failure can be handled during routing
messages via Camel's routing error handlers. Beware that when the first message
is processed then creating and starting the pr [...]
@@ -110,4 +104,4 @@
"required": "false"
}
}
-}
+}
\ No newline at end of file
diff --git
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-hwcloud-smn-sink.json
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-hwcloud-smn-sink.json
index 7773d69..cbd96e7 100644
---
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-hwcloud-smn-sink.json
+++
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-hwcloud-smn-sink.json
@@ -6,7 +6,7 @@
"id": "camel-hwcloud-smn-sink",
"type": "sink",
"version": "0.11.0-SNAPSHOT",
- "description": "Huawei Cloud component to integrate with
SimpleNotification services"
+ "description": "To broadcast messages and connect cloud
services through notifications on Huawei Cloud"
},
"properties": {
"camel.sink.path.smnService": {
diff --git
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-iota-sink.json
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-iota-sink.json
index a7ca664..ca11558 100644
---
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-iota-sink.json
+++
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-iota-sink.json
@@ -61,7 +61,7 @@
},
"camel.sink.endpoint.securityLevel": {
"name": "camel.sink.endpoint.securityLevel",
- "description": "Address security level",
+ "description": "Security level to be used for the
private key \/ address. Can be 1, 2 or 3.",
"defaultValue": "\"1\"",
"priority": "MEDIUM",
"required": "false"
diff --git
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-kamelet-sink.json
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-kamelet-sink.json
index 4c1842a..e45e81e 100644
---
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-kamelet-sink.json
+++
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-kamelet-sink.json
@@ -21,6 +21,12 @@
"priority": "MEDIUM",
"required": "false"
},
+ "camel.sink.endpoint.location": {
+ "name": "camel.sink.endpoint.location",
+ "description": "Location of the Kamelet to use which
can be specified as a resource from file system, classpath etc. The location
cannot use wildcards, and must refer to a file including extension, for example
file:\/etc\/foo-kamelet.xml",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
"camel.sink.endpoint.block": {
"name": "camel.sink.endpoint.block",
"description": "If sending a message to a direct
endpoint which has no active consumer, then we can tell the producer to block
and wait for the consumer to become active.",
@@ -96,8 +102,8 @@
"priority": "MEDIUM",
"required": "false"
},
- "camel.component.kamelet.kameletResourceLoaderListener": {
- "name":
"camel.component.kamelet.kameletResourceLoaderListener",
+ "camel.component.kamelet.routeTemplateLoaderListener": {
+ "name":
"camel.component.kamelet.routeTemplateLoaderListener",
"description": "To plugin a custom listener for when
the Kamelet component is loading Kamelets from external resources.",
"priority": "MEDIUM",
"required": "false"
diff --git
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-kamelet-source.json
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-kamelet-source.json
index d6742db..b88b62c 100644
---
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-kamelet-source.json
+++
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-kamelet-source.json
@@ -21,6 +21,12 @@
"priority": "MEDIUM",
"required": "false"
},
+ "camel.source.endpoint.location": {
+ "name": "camel.source.endpoint.location",
+ "description": "Location of the Kamelet to use which
can be specified as a resource from file system, classpath etc. The location
cannot use wildcards, and must refer to a file including extension, for example
file:\/etc\/foo-kamelet.xml",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
"camel.source.endpoint.bridgeErrorHandler": {
"name": "camel.source.endpoint.bridgeErrorHandler",
"description": "Allows for bridging the consumer to the
Camel routing Error Handler, which mean any exceptions occurred while the
consumer is trying to pickup incoming messages, or the likes, will now be
processed as a message and handled by the routing Error Handler. By default the
consumer will use the org.apache.camel.spi.ExceptionHandler to deal with
exceptions, that will be logged at WARN or ERROR level and ignored.",
@@ -78,8 +84,8 @@
"priority": "MEDIUM",
"required": "false"
},
- "camel.component.kamelet.kameletResourceLoaderListener": {
- "name":
"camel.component.kamelet.kameletResourceLoaderListener",
+ "camel.component.kamelet.routeTemplateLoaderListener": {
+ "name":
"camel.component.kamelet.routeTemplateLoaderListener",
"description": "To plugin a custom listener for when
the Kamelet component is loading Kamelets from external resources.",
"priority": "MEDIUM",
"required": "false"
diff --git
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-sql-sink.json
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-sql-sink.json
index b73c0b6..a7bf2a3 100644
---
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-sql-sink.json
+++
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-sql-sink.json
@@ -24,16 +24,10 @@
},
"camel.sink.endpoint.dataSource": {
"name": "camel.sink.endpoint.dataSource",
- "description": "Sets the DataSource to use to
communicate with the databaset at endpoint level.",
+ "description": "Sets the DataSource to use to
communicate with the database at endpoint level.",
"priority": "MEDIUM",
"required": "false"
},
- "camel.sink.endpoint.dataSourceRef": {
- "name": "camel.sink.endpoint.dataSourceRef",
- "description": "Sets the reference to a DataSource to
lookup from the registry, to use for communicating with the database.",
- "priority": "LOW",
- "required": "false"
- },
"camel.sink.endpoint.outputClass": {
"name": "camel.sink.endpoint.outputClass",
"description": "Specify the full package and class name
to use as conversion when outputType=SelectOne.",
diff --git
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-sql-source.json
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-sql-source.json
index 4a2fd76..935fd14 100644
---
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-sql-source.json
+++
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-sql-source.json
@@ -24,16 +24,10 @@
},
"camel.source.endpoint.dataSource": {
"name": "camel.source.endpoint.dataSource",
- "description": "Sets the DataSource to use to
communicate with the databaset at endpoint level.",
+ "description": "Sets the DataSource to use to
communicate with the database at endpoint level.",
"priority": "MEDIUM",
"required": "false"
},
- "camel.source.endpoint.dataSourceRef": {
- "name": "camel.source.endpoint.dataSourceRef",
- "description": "Sets the reference to a DataSource to
lookup from the registry, to use for communicating with the database.",
- "priority": "LOW",
- "required": "false"
- },
"camel.source.endpoint.outputClass": {
"name": "camel.source.endpoint.outputClass",
"description": "Specify the full package and class name
to use as conversion when outputType=SelectOne.",
diff --git
a/connectors/camel-elsql-kafka-connector/src/generated/resources/camel-elsql-sink.json
b/connectors/camel-elsql-kafka-connector/src/generated/resources/camel-elsql-sink.json
index 0732497..7389b73 100644
---
a/connectors/camel-elsql-kafka-connector/src/generated/resources/camel-elsql-sink.json
+++
b/connectors/camel-elsql-kafka-connector/src/generated/resources/camel-elsql-sink.json
@@ -45,16 +45,10 @@
},
"camel.sink.endpoint.dataSource": {
"name": "camel.sink.endpoint.dataSource",
- "description": "Sets the DataSource to use to
communicate with the database.",
+ "description": "Sets the DataSource to use to
communicate with the database at endpoint level.",
"priority": "MEDIUM",
"required": "false"
},
- "camel.sink.endpoint.dataSourceRef": {
- "name": "camel.sink.endpoint.dataSourceRef",
- "description": "Sets the reference to a DataSource to
lookup from the registry, to use for communicating with the database.",
- "priority": "LOW",
- "required": "false"
- },
"camel.sink.endpoint.outputClass": {
"name": "camel.sink.endpoint.outputClass",
"description": "Specify the full package and class name
to use as conversion when outputType=SelectOne.",
diff --git
a/connectors/camel-elsql-kafka-connector/src/generated/resources/camel-elsql-source.json
b/connectors/camel-elsql-kafka-connector/src/generated/resources/camel-elsql-source.json
index 38b8e5b..bbed3e6 100644
---
a/connectors/camel-elsql-kafka-connector/src/generated/resources/camel-elsql-source.json
+++
b/connectors/camel-elsql-kafka-connector/src/generated/resources/camel-elsql-source.json
@@ -45,16 +45,10 @@
},
"camel.source.endpoint.dataSource": {
"name": "camel.source.endpoint.dataSource",
- "description": "Sets the DataSource to use to
communicate with the database.",
+ "description": "Sets the DataSource to use to
communicate with the database at endpoint level.",
"priority": "MEDIUM",
"required": "false"
},
- "camel.source.endpoint.dataSourceRef": {
- "name": "camel.source.endpoint.dataSourceRef",
- "description": "Sets the reference to a DataSource to
lookup from the registry, to use for communicating with the database.",
- "priority": "LOW",
- "required": "false"
- },
"camel.source.endpoint.outputClass": {
"name": "camel.source.endpoint.outputClass",
"description": "Specify the full package and class name
to use as conversion when outputType=SelectOne.",
diff --git
a/connectors/camel-elsql-kafka-connector/src/main/docs/camel-elsql-kafka-sink-connector.adoc
b/connectors/camel-elsql-kafka-connector/src/main/docs/camel-elsql-kafka-sink-connector.adoc
index 65bdd36..f418171 100644
---
a/connectors/camel-elsql-kafka-connector/src/main/docs/camel-elsql-kafka-sink-connector.adoc
+++
b/connectors/camel-elsql-kafka-connector/src/main/docs/camel-elsql-kafka-sink-connector.adoc
@@ -24,7 +24,7 @@
connector.class=org.apache.camel.kafkaconnector.elsql.CamelElsqlSinkConnector
----
-The camel-elsql sink connector supports 27 options, which are listed below.
+The camel-elsql sink connector supports 26 options, which are listed below.
@@ -35,8 +35,7 @@ The camel-elsql sink connector supports 27 options, which are
listed below.
| *camel.sink.path.resourceUri* | The resource file which contains the elsql
SQL statements to use. You can specify multiple resources separated by comma.
The resources are loaded on the classpath by default, you can prefix with file:
to load from file system. Notice you can set this option on the component and
then you do not have to configure this on the endpoint. | null | false | MEDIUM
| *camel.sink.endpoint.allowNamedParameters* | Whether to allow using named
parameters in the queries. | true | false | MEDIUM
| *camel.sink.endpoint.databaseVendor* | To use a vendor specific
com.opengamma.elsql.ElSqlConfig One of: [Default] [Postgres] [HSql] [MySql]
[Oracle] [SqlServer2008] [Veritca] | null | false | MEDIUM
-| *camel.sink.endpoint.dataSource* | Sets the DataSource to use to communicate
with the database. | null | false | MEDIUM
-| *camel.sink.endpoint.dataSourceRef* | Sets the reference to a DataSource to
lookup from the registry, to use for communicating with the database. | null |
false | LOW
+| *camel.sink.endpoint.dataSource* | Sets the DataSource to use to communicate
with the database at endpoint level. | null | false | MEDIUM
| *camel.sink.endpoint.outputClass* | Specify the full package and class name
to use as conversion when outputType=SelectOne. | null | false | MEDIUM
| *camel.sink.endpoint.outputHeader* | Store the query result in a header
instead of the message body. By default, outputHeader == null and the query
result is stored in the message body, any existing content in the message body
is discarded. If outputHeader is set, the value is used as the name of the
header to store the query result and the original message body is preserved. |
null | false | MEDIUM
| *camel.sink.endpoint.outputType* | Make the output of consumer or producer
to SelectList as List of Map, or SelectOne as single Java object in the
following way: a) If the query has only single column, then that JDBC Column
object is returned. (such as SELECT COUNT( ) FROM PROJECT will return a Long
object. b) If the query has more than one column, then it will return a Map of
that result. c) If the outputClass is set, then it will convert the query
result into an Java bean object by c [...]
diff --git
a/connectors/camel-elsql-kafka-connector/src/main/docs/camel-elsql-kafka-source-connector.adoc
b/connectors/camel-elsql-kafka-connector/src/main/docs/camel-elsql-kafka-source-connector.adoc
index 4de4d40..d0b92fe 100644
---
a/connectors/camel-elsql-kafka-connector/src/main/docs/camel-elsql-kafka-source-connector.adoc
+++
b/connectors/camel-elsql-kafka-connector/src/main/docs/camel-elsql-kafka-source-connector.adoc
@@ -24,7 +24,7 @@
connector.class=org.apache.camel.kafkaconnector.elsql.CamelElsqlSourceConnector
----
-The camel-elsql source connector supports 52 options, which are listed below.
+The camel-elsql source connector supports 51 options, which are listed below.
@@ -35,8 +35,7 @@ The camel-elsql source connector supports 52 options, which
are listed below.
| *camel.source.path.resourceUri* | The resource file which contains the elsql
SQL statements to use. You can specify multiple resources separated by comma.
The resources are loaded on the classpath by default, you can prefix with file:
to load from file system. Notice you can set this option on the component and
then you do not have to configure this on the endpoint. | null | false | MEDIUM
| *camel.source.endpoint.allowNamedParameters* | Whether to allow using named
parameters in the queries. | true | false | MEDIUM
| *camel.source.endpoint.databaseVendor* | To use a vendor specific
com.opengamma.elsql.ElSqlConfig One of: [Default] [Postgres] [HSql] [MySql]
[Oracle] [SqlServer2008] [Veritca] | null | false | MEDIUM
-| *camel.source.endpoint.dataSource* | Sets the DataSource to use to
communicate with the database. | null | false | MEDIUM
-| *camel.source.endpoint.dataSourceRef* | Sets the reference to a DataSource
to lookup from the registry, to use for communicating with the database. | null
| false | LOW
+| *camel.source.endpoint.dataSource* | Sets the DataSource to use to
communicate with the database at endpoint level. | null | false | MEDIUM
| *camel.source.endpoint.outputClass* | Specify the full package and class
name to use as conversion when outputType=SelectOne. | null | false | MEDIUM
| *camel.source.endpoint.outputHeader* | Store the query result in a header
instead of the message body. By default, outputHeader == null and the query
result is stored in the message body, any existing content in the message body
is discarded. If outputHeader is set, the value is used as the name of the
header to store the query result and the original message body is preserved. |
null | false | MEDIUM
| *camel.source.endpoint.outputType* | Make the output of consumer or producer
to SelectList as List of Map, or SelectOne as single Java object in the
following way: a) If the query has only single column, then that JDBC Column
object is returned. (such as SELECT COUNT( ) FROM PROJECT will return a Long
object. b) If the query has more than one column, then it will return a Map of
that result. c) If the outputClass is set, then it will convert the query
result into an Java bean object by [...]
diff --git
a/connectors/camel-elsql-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/elsql/CamelElsqlSinkConnectorConfig.java
b/connectors/camel-elsql-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/elsql/CamelElsqlSinkConnectorConfig.java
index e874089..3abce1f 100644
---
a/connectors/camel-elsql-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/elsql/CamelElsqlSinkConnectorConfig.java
+++
b/connectors/camel-elsql-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/elsql/CamelElsqlSinkConnectorConfig.java
@@ -37,11 +37,8 @@ public class CamelElsqlSinkConnectorConfig extends
CamelSinkConnectorConfig {
public static final String CAMEL_SINK_ELSQL_ENDPOINT_DATABASE_VENDOR_DOC =
"To use a vendor specific com.opengamma.elsql.ElSqlConfig One of: [Default]
[Postgres] [HSql] [MySql] [Oracle] [SqlServer2008] [Veritca]";
public static final String
CAMEL_SINK_ELSQL_ENDPOINT_DATABASE_VENDOR_DEFAULT = null;
public static final String CAMEL_SINK_ELSQL_ENDPOINT_DATA_SOURCE_CONF =
"camel.sink.endpoint.dataSource";
- public static final String CAMEL_SINK_ELSQL_ENDPOINT_DATA_SOURCE_DOC =
"Sets the DataSource to use to communicate with the database.";
+ public static final String CAMEL_SINK_ELSQL_ENDPOINT_DATA_SOURCE_DOC =
"Sets the DataSource to use to communicate with the database at endpoint
level.";
public static final String CAMEL_SINK_ELSQL_ENDPOINT_DATA_SOURCE_DEFAULT =
null;
- public static final String CAMEL_SINK_ELSQL_ENDPOINT_DATA_SOURCE_REF_CONF
= "camel.sink.endpoint.dataSourceRef";
- public static final String CAMEL_SINK_ELSQL_ENDPOINT_DATA_SOURCE_REF_DOC =
"Sets the reference to a DataSource to lookup from the registry, to use for
communicating with the database.";
- public static final String
CAMEL_SINK_ELSQL_ENDPOINT_DATA_SOURCE_REF_DEFAULT = null;
public static final String CAMEL_SINK_ELSQL_ENDPOINT_OUTPUT_CLASS_CONF =
"camel.sink.endpoint.outputClass";
public static final String CAMEL_SINK_ELSQL_ENDPOINT_OUTPUT_CLASS_DOC =
"Specify the full package and class name to use as conversion when
outputType=SelectOne.";
public static final String CAMEL_SINK_ELSQL_ENDPOINT_OUTPUT_CLASS_DEFAULT
= null;
@@ -123,7 +120,6 @@ public class CamelElsqlSinkConnectorConfig extends
CamelSinkConnectorConfig {
conf.define(CAMEL_SINK_ELSQL_ENDPOINT_ALLOW_NAMED_PARAMETERS_CONF,
ConfigDef.Type.BOOLEAN,
CAMEL_SINK_ELSQL_ENDPOINT_ALLOW_NAMED_PARAMETERS_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SINK_ELSQL_ENDPOINT_ALLOW_NAMED_PARAMETERS_DOC);
conf.define(CAMEL_SINK_ELSQL_ENDPOINT_DATABASE_VENDOR_CONF,
ConfigDef.Type.STRING, CAMEL_SINK_ELSQL_ENDPOINT_DATABASE_VENDOR_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_ELSQL_ENDPOINT_DATABASE_VENDOR_DOC);
conf.define(CAMEL_SINK_ELSQL_ENDPOINT_DATA_SOURCE_CONF,
ConfigDef.Type.STRING, CAMEL_SINK_ELSQL_ENDPOINT_DATA_SOURCE_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_ELSQL_ENDPOINT_DATA_SOURCE_DOC);
- conf.define(CAMEL_SINK_ELSQL_ENDPOINT_DATA_SOURCE_REF_CONF,
ConfigDef.Type.STRING, CAMEL_SINK_ELSQL_ENDPOINT_DATA_SOURCE_REF_DEFAULT,
ConfigDef.Importance.LOW, CAMEL_SINK_ELSQL_ENDPOINT_DATA_SOURCE_REF_DOC);
conf.define(CAMEL_SINK_ELSQL_ENDPOINT_OUTPUT_CLASS_CONF,
ConfigDef.Type.STRING, CAMEL_SINK_ELSQL_ENDPOINT_OUTPUT_CLASS_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_ELSQL_ENDPOINT_OUTPUT_CLASS_DOC);
conf.define(CAMEL_SINK_ELSQL_ENDPOINT_OUTPUT_HEADER_CONF,
ConfigDef.Type.STRING, CAMEL_SINK_ELSQL_ENDPOINT_OUTPUT_HEADER_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_ELSQL_ENDPOINT_OUTPUT_HEADER_DOC);
conf.define(CAMEL_SINK_ELSQL_ENDPOINT_OUTPUT_TYPE_CONF,
ConfigDef.Type.STRING, CAMEL_SINK_ELSQL_ENDPOINT_OUTPUT_TYPE_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_ELSQL_ENDPOINT_OUTPUT_TYPE_DOC);
diff --git
a/connectors/camel-elsql-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/elsql/CamelElsqlSourceConnectorConfig.java
b/connectors/camel-elsql-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/elsql/CamelElsqlSourceConnectorConfig.java
index d4d1fc1..3889e4e 100644
---
a/connectors/camel-elsql-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/elsql/CamelElsqlSourceConnectorConfig.java
+++
b/connectors/camel-elsql-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/elsql/CamelElsqlSourceConnectorConfig.java
@@ -39,11 +39,8 @@ public class CamelElsqlSourceConnectorConfig
public static final String CAMEL_SOURCE_ELSQL_ENDPOINT_DATABASE_VENDOR_DOC
= "To use a vendor specific com.opengamma.elsql.ElSqlConfig One of: [Default]
[Postgres] [HSql] [MySql] [Oracle] [SqlServer2008] [Veritca]";
public static final String
CAMEL_SOURCE_ELSQL_ENDPOINT_DATABASE_VENDOR_DEFAULT = null;
public static final String CAMEL_SOURCE_ELSQL_ENDPOINT_DATA_SOURCE_CONF =
"camel.source.endpoint.dataSource";
- public static final String CAMEL_SOURCE_ELSQL_ENDPOINT_DATA_SOURCE_DOC =
"Sets the DataSource to use to communicate with the database.";
+ public static final String CAMEL_SOURCE_ELSQL_ENDPOINT_DATA_SOURCE_DOC =
"Sets the DataSource to use to communicate with the database at endpoint
level.";
public static final String CAMEL_SOURCE_ELSQL_ENDPOINT_DATA_SOURCE_DEFAULT
= null;
- public static final String
CAMEL_SOURCE_ELSQL_ENDPOINT_DATA_SOURCE_REF_CONF =
"camel.source.endpoint.dataSourceRef";
- public static final String CAMEL_SOURCE_ELSQL_ENDPOINT_DATA_SOURCE_REF_DOC
= "Sets the reference to a DataSource to lookup from the registry, to use for
communicating with the database.";
- public static final String
CAMEL_SOURCE_ELSQL_ENDPOINT_DATA_SOURCE_REF_DEFAULT = null;
public static final String CAMEL_SOURCE_ELSQL_ENDPOINT_OUTPUT_CLASS_CONF =
"camel.source.endpoint.outputClass";
public static final String CAMEL_SOURCE_ELSQL_ENDPOINT_OUTPUT_CLASS_DOC =
"Specify the full package and class name to use as conversion when
outputType=SelectOne.";
public static final String
CAMEL_SOURCE_ELSQL_ENDPOINT_OUTPUT_CLASS_DEFAULT = null;
@@ -200,7 +197,6 @@ public class CamelElsqlSourceConnectorConfig
conf.define(CAMEL_SOURCE_ELSQL_ENDPOINT_ALLOW_NAMED_PARAMETERS_CONF,
ConfigDef.Type.BOOLEAN,
CAMEL_SOURCE_ELSQL_ENDPOINT_ALLOW_NAMED_PARAMETERS_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SOURCE_ELSQL_ENDPOINT_ALLOW_NAMED_PARAMETERS_DOC);
conf.define(CAMEL_SOURCE_ELSQL_ENDPOINT_DATABASE_VENDOR_CONF,
ConfigDef.Type.STRING, CAMEL_SOURCE_ELSQL_ENDPOINT_DATABASE_VENDOR_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_ELSQL_ENDPOINT_DATABASE_VENDOR_DOC);
conf.define(CAMEL_SOURCE_ELSQL_ENDPOINT_DATA_SOURCE_CONF,
ConfigDef.Type.STRING, CAMEL_SOURCE_ELSQL_ENDPOINT_DATA_SOURCE_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_ELSQL_ENDPOINT_DATA_SOURCE_DOC);
- conf.define(CAMEL_SOURCE_ELSQL_ENDPOINT_DATA_SOURCE_REF_CONF,
ConfigDef.Type.STRING, CAMEL_SOURCE_ELSQL_ENDPOINT_DATA_SOURCE_REF_DEFAULT,
ConfigDef.Importance.LOW, CAMEL_SOURCE_ELSQL_ENDPOINT_DATA_SOURCE_REF_DOC);
conf.define(CAMEL_SOURCE_ELSQL_ENDPOINT_OUTPUT_CLASS_CONF,
ConfigDef.Type.STRING, CAMEL_SOURCE_ELSQL_ENDPOINT_OUTPUT_CLASS_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_ELSQL_ENDPOINT_OUTPUT_CLASS_DOC);
conf.define(CAMEL_SOURCE_ELSQL_ENDPOINT_OUTPUT_HEADER_CONF,
ConfigDef.Type.STRING, CAMEL_SOURCE_ELSQL_ENDPOINT_OUTPUT_HEADER_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_ELSQL_ENDPOINT_OUTPUT_HEADER_DOC);
conf.define(CAMEL_SOURCE_ELSQL_ENDPOINT_OUTPUT_TYPE_CONF,
ConfigDef.Type.STRING, CAMEL_SOURCE_ELSQL_ENDPOINT_OUTPUT_TYPE_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_ELSQL_ENDPOINT_OUTPUT_TYPE_DOC);
diff --git
a/connectors/camel-hwcloud-iam-kafka-connector/src/generated/resources/camel-hwcloud-iam-sink.json
b/connectors/camel-hwcloud-iam-kafka-connector/src/generated/resources/camel-hwcloud-iam-sink.json
index 3670e52..12652ab 100644
---
a/connectors/camel-hwcloud-iam-kafka-connector/src/generated/resources/camel-hwcloud-iam-sink.json
+++
b/connectors/camel-hwcloud-iam-kafka-connector/src/generated/resources/camel-hwcloud-iam-sink.json
@@ -21,12 +21,6 @@
"priority": "HIGH",
"required": "true"
},
- "camel.sink.endpoint.endpoint": {
- "name": "camel.sink.endpoint.endpoint",
- "description": "IAM endpoint url. Carries higher
precedence than region parameter based client initialization",
- "priority": "MEDIUM",
- "required": "false"
- },
"camel.sink.endpoint.groupId": {
"name": "camel.sink.endpoint.groupId",
"description": "Group ID to perform operation with",
@@ -40,6 +34,13 @@
"priority": "MEDIUM",
"required": "false"
},
+ "camel.sink.endpoint.lazyStartProducer": {
+ "name": "camel.sink.endpoint.lazyStartProducer",
+ "description": "Whether the producer should be started
lazy (on the first message). By starting lazy you can use this to allow
CamelContext and routes to startup in situations where a producer may otherwise
fail during starting and cause the route to fail being started. By deferring
this startup to be lazy then the startup failure can be handled during routing
messages via Camel's routing error handlers. Beware that when the first message
is processed then creating and starting the pr [...]
+ "defaultValue": "false",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
"camel.sink.endpoint.proxyHost": {
"name": "camel.sink.endpoint.proxyHost",
"description": "Proxy server ip\/hostname",
@@ -66,7 +67,7 @@
},
"camel.sink.endpoint.region": {
"name": "camel.sink.endpoint.region",
- "description": "IAM service region. This is lower
precedence than endpoint based configuration",
+ "description": "IAM service region",
"priority": "HIGH",
"required": "true"
},
@@ -88,13 +89,6 @@
"priority": "MEDIUM",
"required": "false"
},
- "camel.sink.endpoint.lazyStartProducer": {
- "name": "camel.sink.endpoint.lazyStartProducer",
- "description": "Whether the producer should be started
lazy (on the first message). By starting lazy you can use this to allow
CamelContext and routes to startup in situations where a producer may otherwise
fail during starting and cause the route to fail being started. By deferring
this startup to be lazy then the startup failure can be handled during routing
messages via Camel's routing error handlers. Beware that when the first message
is processed then creating and starting the pr [...]
- "defaultValue": "false",
- "priority": "MEDIUM",
- "required": "false"
- },
"camel.component.hwcloud-iam.lazyStartProducer": {
"name": "camel.component.hwcloud-iam.lazyStartProducer",
"description": "Whether the producer should be started
lazy (on the first message). By starting lazy you can use this to allow
CamelContext and routes to startup in situations where a producer may otherwise
fail during starting and cause the route to fail being started. By deferring
this startup to be lazy then the startup failure can be handled during routing
messages via Camel's routing error handlers. Beware that when the first message
is processed then creating and starting the pr [...]
@@ -110,4 +104,4 @@
"required": "false"
}
}
-}
+}
\ No newline at end of file
diff --git
a/connectors/camel-hwcloud-iam-kafka-connector/src/main/docs/camel-hwcloud-iam-kafka-sink-connector.adoc
b/connectors/camel-hwcloud-iam-kafka-connector/src/main/docs/camel-hwcloud-iam-kafka-sink-connector.adoc
index fb97e72..bc9d2c2 100644
---
a/connectors/camel-hwcloud-iam-kafka-connector/src/main/docs/camel-hwcloud-iam-kafka-sink-connector.adoc
+++
b/connectors/camel-hwcloud-iam-kafka-connector/src/main/docs/camel-hwcloud-iam-kafka-sink-connector.adoc
@@ -24,7 +24,7 @@
connector.class=org.apache.camel.kafkaconnector.hwcloudiam.CamelHwcloudiamSinkCo
----
-The camel-hwcloud-iam sink connector supports 16 options, which are listed
below.
+The camel-hwcloud-iam sink connector supports 15 options, which are listed
below.
@@ -33,18 +33,17 @@ The camel-hwcloud-iam sink connector supports 16 options,
which are listed below
| Name | Description | Default | Required | Priority
| *camel.sink.path.operation* | Operation to be performed | null | true | HIGH
| *camel.sink.endpoint.authenticationKey* | Authentication key for the cloud
user | null | true | HIGH
-| *camel.sink.endpoint.endpoint* | IAM endpoint url. Carries higher precedence
than region parameter based client initialization | null | false | MEDIUM
| *camel.sink.endpoint.groupId* | Group ID to perform operation with | null |
false | MEDIUM
| *camel.sink.endpoint.ignoreSslVerification* | Ignore SSL verification |
false | false | MEDIUM
+| *camel.sink.endpoint.lazyStartProducer* | Whether the producer should be
started lazy (on the first message). By starting lazy you can use this to allow
CamelContext and routes to startup in situations where a producer may otherwise
fail during starting and cause the route to fail being started. By deferring
this startup to be lazy then the startup failure can be handled during routing
messages via Camel's routing error handlers. Beware that when the first message
is processed then cre [...]
| *camel.sink.endpoint.proxyHost* | Proxy server ip/hostname | null | false |
MEDIUM
| *camel.sink.endpoint.proxyPassword* | Proxy authentication password | null |
false | MEDIUM
| *camel.sink.endpoint.proxyPort* | Proxy server port | null | false | MEDIUM
| *camel.sink.endpoint.proxyUser* | Proxy authentication user | null | false |
MEDIUM
-| *camel.sink.endpoint.region* | IAM service region. This is lower precedence
than endpoint based configuration | null | true | HIGH
+| *camel.sink.endpoint.region* | IAM service region | null | true | HIGH
| *camel.sink.endpoint.secretKey* | Secret key for the cloud user | null |
true | HIGH
| *camel.sink.endpoint.serviceKeys* | Configuration object for cloud service
authentication | null | false | MEDIUM
| *camel.sink.endpoint.userId* | User ID to perform operation with | null |
false | MEDIUM
-| *camel.sink.endpoint.lazyStartProducer* | Whether the producer should be
started lazy (on the first message). By starting lazy you can use this to allow
CamelContext and routes to startup in situations where a producer may otherwise
fail during starting and cause the route to fail being started. By deferring
this startup to be lazy then the startup failure can be handled during routing
messages via Camel's routing error handlers. Beware that when the first message
is processed then cre [...]
| *camel.component.hwcloud-iam.lazyStartProducer* | Whether the producer
should be started lazy (on the first message). By starting lazy you can use
this to allow CamelContext and routes to startup in situations where a producer
may otherwise fail during starting and cause the route to fail being started.
By deferring this startup to be lazy then the startup failure can be handled
during routing messages via Camel's routing error handlers. Beware that when
the first message is processed [...]
| *camel.component.hwcloud-iam.autowiredEnabled* | Whether autowiring is
enabled. This is used for automatic autowiring options (the option must be
marked as autowired) by looking up in the registry to find if there is a single
instance of matching type, which then gets configured on the component. This
can be used for automatic configuring JDBC data sources, JMS connection
factories, AWS Clients, etc. | true | false | MEDIUM
|===
@@ -64,8 +63,4 @@ The camel-hwcloud-iam sink connector has no transforms out of
the box.
The camel-hwcloud-iam sink connector has no aggregation strategies out of the
box.
-
-
-
-
// kafka-connector options: END
diff --git
a/connectors/camel-hwcloud-iam-kafka-connector/src/main/docs/examples/CamelHwcloudiamSinkConnector.properties
b/connectors/camel-hwcloud-iam-kafka-connector/src/main/docs/examples/CamelHwcloudiamSinkConnector.properties
index 4b3903e..de8af99 100644
---
a/connectors/camel-hwcloud-iam-kafka-connector/src/main/docs/examples/CamelHwcloudiamSinkConnector.properties
+++
b/connectors/camel-hwcloud-iam-kafka-connector/src/main/docs/examples/CamelHwcloudiamSinkConnector.properties
@@ -30,7 +30,7 @@ topics=
# Authentication key for the cloud user
camel.sink.endpoint.authenticationKey=
-# IAM service region. This is lower precedence than endpoint based
configuration
+# IAM service region
camel.sink.endpoint.region=
# Secret key for the cloud user
camel.sink.endpoint.secretKey=
diff --git
a/connectors/camel-hwcloud-iam-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/hwcloudiam/CamelHwcloudiamSinkConnectorConfig.java
b/connectors/camel-hwcloud-iam-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/hwcloudiam/CamelHwcloudiamSinkConnectorConfig.java
index ef366e8..247e779 100644
---
a/connectors/camel-hwcloud-iam-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/hwcloudiam/CamelHwcloudiamSinkConnectorConfig.java
+++
b/connectors/camel-hwcloud-iam-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/hwcloudiam/CamelHwcloudiamSinkConnectorConfig.java
@@ -32,15 +32,15 @@ public class CamelHwcloudiamSinkConnectorConfig
public static final String
CAMEL_SINK_HWCLOUDIAM_ENDPOINT_AUTHENTICATION_KEY_CONF =
"camel.sink.endpoint.authenticationKey";
public static final String
CAMEL_SINK_HWCLOUDIAM_ENDPOINT_AUTHENTICATION_KEY_DOC = "Authentication key for
the cloud user";
public static final String
CAMEL_SINK_HWCLOUDIAM_ENDPOINT_AUTHENTICATION_KEY_DEFAULT = null;
- public static final String CAMEL_SINK_HWCLOUDIAM_ENDPOINT_ENDPOINT_CONF =
"camel.sink.endpoint.endpoint";
- public static final String CAMEL_SINK_HWCLOUDIAM_ENDPOINT_ENDPOINT_DOC =
"IAM endpoint url. Carries higher precedence than region parameter based client
initialization";
- public static final String CAMEL_SINK_HWCLOUDIAM_ENDPOINT_ENDPOINT_DEFAULT
= null;
public static final String CAMEL_SINK_HWCLOUDIAM_ENDPOINT_GROUP_ID_CONF =
"camel.sink.endpoint.groupId";
public static final String CAMEL_SINK_HWCLOUDIAM_ENDPOINT_GROUP_ID_DOC =
"Group ID to perform operation with";
public static final String CAMEL_SINK_HWCLOUDIAM_ENDPOINT_GROUP_ID_DEFAULT
= null;
public static final String
CAMEL_SINK_HWCLOUDIAM_ENDPOINT_IGNORE_SSL_VERIFICATION_CONF =
"camel.sink.endpoint.ignoreSslVerification";
public static final String
CAMEL_SINK_HWCLOUDIAM_ENDPOINT_IGNORE_SSL_VERIFICATION_DOC = "Ignore SSL
verification";
public static final Boolean
CAMEL_SINK_HWCLOUDIAM_ENDPOINT_IGNORE_SSL_VERIFICATION_DEFAULT = false;
+ public static final String
CAMEL_SINK_HWCLOUDIAM_ENDPOINT_LAZY_START_PRODUCER_CONF =
"camel.sink.endpoint.lazyStartProducer";
+ public static final String
CAMEL_SINK_HWCLOUDIAM_ENDPOINT_LAZY_START_PRODUCER_DOC = "Whether the producer
should be started lazy (on the first message). By starting lazy you can use
this to allow CamelContext and routes to startup in situations where a producer
may otherwise fail during starting and cause the route to fail being started.
By deferring this startup to be lazy then the startup failure can be handled
during routing messages via Camel's routing error handlers. Beware that [...]
+ public static final Boolean
CAMEL_SINK_HWCLOUDIAM_ENDPOINT_LAZY_START_PRODUCER_DEFAULT = false;
public static final String CAMEL_SINK_HWCLOUDIAM_ENDPOINT_PROXY_HOST_CONF
= "camel.sink.endpoint.proxyHost";
public static final String CAMEL_SINK_HWCLOUDIAM_ENDPOINT_PROXY_HOST_DOC =
"Proxy server ip/hostname";
public static final String
CAMEL_SINK_HWCLOUDIAM_ENDPOINT_PROXY_HOST_DEFAULT = null;
@@ -54,7 +54,7 @@ public class CamelHwcloudiamSinkConnectorConfig
public static final String CAMEL_SINK_HWCLOUDIAM_ENDPOINT_PROXY_USER_DOC =
"Proxy authentication user";
public static final String
CAMEL_SINK_HWCLOUDIAM_ENDPOINT_PROXY_USER_DEFAULT = null;
public static final String CAMEL_SINK_HWCLOUDIAM_ENDPOINT_REGION_CONF =
"camel.sink.endpoint.region";
- public static final String CAMEL_SINK_HWCLOUDIAM_ENDPOINT_REGION_DOC =
"IAM service region. This is lower precedence than endpoint based
configuration";
+ public static final String CAMEL_SINK_HWCLOUDIAM_ENDPOINT_REGION_DOC =
"IAM service region";
public static final String CAMEL_SINK_HWCLOUDIAM_ENDPOINT_REGION_DEFAULT =
null;
public static final String CAMEL_SINK_HWCLOUDIAM_ENDPOINT_SECRET_KEY_CONF
= "camel.sink.endpoint.secretKey";
public static final String CAMEL_SINK_HWCLOUDIAM_ENDPOINT_SECRET_KEY_DOC =
"Secret key for the cloud user";
@@ -65,9 +65,6 @@ public class CamelHwcloudiamSinkConnectorConfig
public static final String CAMEL_SINK_HWCLOUDIAM_ENDPOINT_USER_ID_CONF =
"camel.sink.endpoint.userId";
public static final String CAMEL_SINK_HWCLOUDIAM_ENDPOINT_USER_ID_DOC =
"User ID to perform operation with";
public static final String CAMEL_SINK_HWCLOUDIAM_ENDPOINT_USER_ID_DEFAULT
= null;
- public static final String
CAMEL_SINK_HWCLOUDIAM_ENDPOINT_LAZY_START_PRODUCER_CONF =
"camel.sink.endpoint.lazyStartProducer";
- public static final String
CAMEL_SINK_HWCLOUDIAM_ENDPOINT_LAZY_START_PRODUCER_DOC = "Whether the producer
should be started lazy (on the first message). By starting lazy you can use
this to allow CamelContext and routes to startup in situations where a producer
may otherwise fail during starting and cause the route to fail being started.
By deferring this startup to be lazy then the startup failure can be handled
during routing messages via Camel's routing error handlers. Beware that [...]
- public static final Boolean
CAMEL_SINK_HWCLOUDIAM_ENDPOINT_LAZY_START_PRODUCER_DEFAULT = false;
public static final String
CAMEL_SINK_HWCLOUDIAM_COMPONENT_LAZY_START_PRODUCER_CONF =
"camel.component.hwcloud-iam.lazyStartProducer";
public static final String
CAMEL_SINK_HWCLOUDIAM_COMPONENT_LAZY_START_PRODUCER_DOC = "Whether the producer
should be started lazy (on the first message). By starting lazy you can use
this to allow CamelContext and routes to startup in situations where a producer
may otherwise fail during starting and cause the route to fail being started.
By deferring this startup to be lazy then the startup failure can be handled
during routing messages via Camel's routing error handlers. Beware tha [...]
public static final Boolean
CAMEL_SINK_HWCLOUDIAM_COMPONENT_LAZY_START_PRODUCER_DEFAULT = false;
@@ -89,9 +86,9 @@ public class CamelHwcloudiamSinkConnectorConfig
ConfigDef conf = new ConfigDef(CamelSinkConnectorConfig.conf());
conf.define(CAMEL_SINK_HWCLOUDIAM_PATH_OPERATION_CONF,
ConfigDef.Type.STRING, CAMEL_SINK_HWCLOUDIAM_PATH_OPERATION_DEFAULT,
ConfigDef.Importance.HIGH, CAMEL_SINK_HWCLOUDIAM_PATH_OPERATION_DOC);
conf.define(CAMEL_SINK_HWCLOUDIAM_ENDPOINT_AUTHENTICATION_KEY_CONF,
ConfigDef.Type.PASSWORD,
CAMEL_SINK_HWCLOUDIAM_ENDPOINT_AUTHENTICATION_KEY_DEFAULT,
ConfigDef.Importance.HIGH,
CAMEL_SINK_HWCLOUDIAM_ENDPOINT_AUTHENTICATION_KEY_DOC);
- conf.define(CAMEL_SINK_HWCLOUDIAM_ENDPOINT_ENDPOINT_CONF,
ConfigDef.Type.STRING, CAMEL_SINK_HWCLOUDIAM_ENDPOINT_ENDPOINT_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_HWCLOUDIAM_ENDPOINT_ENDPOINT_DOC);
conf.define(CAMEL_SINK_HWCLOUDIAM_ENDPOINT_GROUP_ID_CONF,
ConfigDef.Type.PASSWORD, CAMEL_SINK_HWCLOUDIAM_ENDPOINT_GROUP_ID_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_HWCLOUDIAM_ENDPOINT_GROUP_ID_DOC);
conf.define(CAMEL_SINK_HWCLOUDIAM_ENDPOINT_IGNORE_SSL_VERIFICATION_CONF,
ConfigDef.Type.BOOLEAN,
CAMEL_SINK_HWCLOUDIAM_ENDPOINT_IGNORE_SSL_VERIFICATION_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SINK_HWCLOUDIAM_ENDPOINT_IGNORE_SSL_VERIFICATION_DOC);
+ conf.define(CAMEL_SINK_HWCLOUDIAM_ENDPOINT_LAZY_START_PRODUCER_CONF,
ConfigDef.Type.BOOLEAN,
CAMEL_SINK_HWCLOUDIAM_ENDPOINT_LAZY_START_PRODUCER_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SINK_HWCLOUDIAM_ENDPOINT_LAZY_START_PRODUCER_DOC);
conf.define(CAMEL_SINK_HWCLOUDIAM_ENDPOINT_PROXY_HOST_CONF,
ConfigDef.Type.STRING, CAMEL_SINK_HWCLOUDIAM_ENDPOINT_PROXY_HOST_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_HWCLOUDIAM_ENDPOINT_PROXY_HOST_DOC);
conf.define(CAMEL_SINK_HWCLOUDIAM_ENDPOINT_PROXY_PASSWORD_CONF,
ConfigDef.Type.PASSWORD, CAMEL_SINK_HWCLOUDIAM_ENDPOINT_PROXY_PASSWORD_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_HWCLOUDIAM_ENDPOINT_PROXY_PASSWORD_DOC);
conf.define(CAMEL_SINK_HWCLOUDIAM_ENDPOINT_PROXY_PORT_CONF,
ConfigDef.Type.INT, CAMEL_SINK_HWCLOUDIAM_ENDPOINT_PROXY_PORT_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_HWCLOUDIAM_ENDPOINT_PROXY_PORT_DOC);
@@ -100,7 +97,6 @@ public class CamelHwcloudiamSinkConnectorConfig
conf.define(CAMEL_SINK_HWCLOUDIAM_ENDPOINT_SECRET_KEY_CONF,
ConfigDef.Type.PASSWORD, CAMEL_SINK_HWCLOUDIAM_ENDPOINT_SECRET_KEY_DEFAULT,
ConfigDef.Importance.HIGH, CAMEL_SINK_HWCLOUDIAM_ENDPOINT_SECRET_KEY_DOC);
conf.define(CAMEL_SINK_HWCLOUDIAM_ENDPOINT_SERVICE_KEYS_CONF,
ConfigDef.Type.PASSWORD, CAMEL_SINK_HWCLOUDIAM_ENDPOINT_SERVICE_KEYS_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_HWCLOUDIAM_ENDPOINT_SERVICE_KEYS_DOC);
conf.define(CAMEL_SINK_HWCLOUDIAM_ENDPOINT_USER_ID_CONF,
ConfigDef.Type.PASSWORD, CAMEL_SINK_HWCLOUDIAM_ENDPOINT_USER_ID_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_HWCLOUDIAM_ENDPOINT_USER_ID_DOC);
- conf.define(CAMEL_SINK_HWCLOUDIAM_ENDPOINT_LAZY_START_PRODUCER_CONF,
ConfigDef.Type.BOOLEAN,
CAMEL_SINK_HWCLOUDIAM_ENDPOINT_LAZY_START_PRODUCER_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SINK_HWCLOUDIAM_ENDPOINT_LAZY_START_PRODUCER_DOC);
conf.define(CAMEL_SINK_HWCLOUDIAM_COMPONENT_LAZY_START_PRODUCER_CONF,
ConfigDef.Type.BOOLEAN,
CAMEL_SINK_HWCLOUDIAM_COMPONENT_LAZY_START_PRODUCER_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SINK_HWCLOUDIAM_COMPONENT_LAZY_START_PRODUCER_DOC);
conf.define(CAMEL_SINK_HWCLOUDIAM_COMPONENT_AUTOWIRED_ENABLED_CONF,
ConfigDef.Type.BOOLEAN,
CAMEL_SINK_HWCLOUDIAM_COMPONENT_AUTOWIRED_ENABLED_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SINK_HWCLOUDIAM_COMPONENT_AUTOWIRED_ENABLED_DOC);
return conf;
diff --git
a/connectors/camel-hwcloud-smn-kafka-connector/src/generated/resources/camel-hwcloud-smn-sink.json
b/connectors/camel-hwcloud-smn-kafka-connector/src/generated/resources/camel-hwcloud-smn-sink.json
index 7773d69..cbd96e7 100644
---
a/connectors/camel-hwcloud-smn-kafka-connector/src/generated/resources/camel-hwcloud-smn-sink.json
+++
b/connectors/camel-hwcloud-smn-kafka-connector/src/generated/resources/camel-hwcloud-smn-sink.json
@@ -6,7 +6,7 @@
"id": "camel-hwcloud-smn-sink",
"type": "sink",
"version": "0.11.0-SNAPSHOT",
- "description": "Huawei Cloud component to integrate with
SimpleNotification services"
+ "description": "To broadcast messages and connect cloud
services through notifications on Huawei Cloud"
},
"properties": {
"camel.sink.path.smnService": {
diff --git
a/connectors/camel-hwcloud-smn-kafka-connector/src/main/docs/camel-hwcloud-smn-kafka-sink-connector.adoc
b/connectors/camel-hwcloud-smn-kafka-connector/src/main/docs/camel-hwcloud-smn-kafka-sink-connector.adoc
index d525124..0bb23e1 100644
---
a/connectors/camel-hwcloud-smn-kafka-connector/src/main/docs/camel-hwcloud-smn-kafka-sink-connector.adoc
+++
b/connectors/camel-hwcloud-smn-kafka-connector/src/main/docs/camel-hwcloud-smn-kafka-sink-connector.adoc
@@ -2,7 +2,7 @@
[[camel-hwcloud-smn-kafka-connector-sink]]
= camel-hwcloud-smn-kafka-connector sink configuration
-Connector Description: Huawei Cloud component to integrate with
SimpleNotification services
+Connector Description: To broadcast messages and connect cloud services
through notifications on Huawei Cloud
When using camel-hwcloud-smn-kafka-connector as sink make sure to use the
following Maven dependency to have support for the connector:
diff --git
a/connectors/camel-iota-kafka-connector/src/generated/resources/camel-iota-sink.json
b/connectors/camel-iota-kafka-connector/src/generated/resources/camel-iota-sink.json
index a7ca664..ca11558 100644
---
a/connectors/camel-iota-kafka-connector/src/generated/resources/camel-iota-sink.json
+++
b/connectors/camel-iota-kafka-connector/src/generated/resources/camel-iota-sink.json
@@ -61,7 +61,7 @@
},
"camel.sink.endpoint.securityLevel": {
"name": "camel.sink.endpoint.securityLevel",
- "description": "Address security level",
+ "description": "Security level to be used for the
private key \/ address. Can be 1, 2 or 3.",
"defaultValue": "\"1\"",
"priority": "MEDIUM",
"required": "false"
diff --git
a/connectors/camel-iota-kafka-connector/src/main/docs/camel-iota-kafka-sink-connector.adoc
b/connectors/camel-iota-kafka-connector/src/main/docs/camel-iota-kafka-sink-connector.adoc
index 208aade..7d18567 100644
---
a/connectors/camel-iota-kafka-connector/src/main/docs/camel-iota-kafka-sink-connector.adoc
+++
b/connectors/camel-iota-kafka-connector/src/main/docs/camel-iota-kafka-sink-connector.adoc
@@ -38,7 +38,7 @@ The camel-iota sink connector supports 10 options, which are
listed below.
| *camel.sink.endpoint.operation* | Which operation to perform, one of:
sendTransfer, getNewAddress, getTransfers One of: [sendTransfer]
[getNewAddress] [getTransfers] | null | true | HIGH
| *camel.sink.endpoint.tag* | TAG | null | false | MEDIUM
| *camel.sink.endpoint.url* | Node url | null | true | HIGH
-| *camel.sink.endpoint.securityLevel* | Address security level | "1" | false |
MEDIUM
+| *camel.sink.endpoint.securityLevel* | Security level to be used for the
private key / address. Can be 1, 2 or 3. | "1" | false | MEDIUM
| *camel.component.iota.lazyStartProducer* | Whether the producer should be
started lazy (on the first message). By starting lazy you can use this to allow
CamelContext and routes to startup in situations where a producer may otherwise
fail during starting and cause the route to fail being started. By deferring
this startup to be lazy then the startup failure can be handled during routing
messages via Camel's routing error handlers. Beware that when the first message
is processed then cr [...]
| *camel.component.iota.autowiredEnabled* | Whether autowiring is enabled.
This is used for automatic autowiring options (the option must be marked as
autowired) by looking up in the registry to find if there is a single instance
of matching type, which then gets configured on the component. This can be used
for automatic configuring JDBC data sources, JMS connection factories, AWS
Clients, etc. | true | false | MEDIUM
|===
diff --git
a/connectors/camel-iota-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/iota/CamelIotaSinkConnectorConfig.java
b/connectors/camel-iota-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/iota/CamelIotaSinkConnectorConfig.java
index daabf79..ff3483f 100644
---
a/connectors/camel-iota-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/iota/CamelIotaSinkConnectorConfig.java
+++
b/connectors/camel-iota-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/iota/CamelIotaSinkConnectorConfig.java
@@ -46,7 +46,7 @@ public class CamelIotaSinkConnectorConfig extends
CamelSinkConnectorConfig {
public static final String CAMEL_SINK_IOTA_ENDPOINT_URL_DOC = "Node url";
public static final String CAMEL_SINK_IOTA_ENDPOINT_URL_DEFAULT = null;
public static final String CAMEL_SINK_IOTA_ENDPOINT_SECURITY_LEVEL_CONF =
"camel.sink.endpoint.securityLevel";
- public static final String CAMEL_SINK_IOTA_ENDPOINT_SECURITY_LEVEL_DOC =
"Address security level";
+ public static final String CAMEL_SINK_IOTA_ENDPOINT_SECURITY_LEVEL_DOC =
"Security level to be used for the private key / address. Can be 1, 2 or 3.";
public static final String CAMEL_SINK_IOTA_ENDPOINT_SECURITY_LEVEL_DEFAULT
= "1";
public static final String
CAMEL_SINK_IOTA_COMPONENT_LAZY_START_PRODUCER_CONF =
"camel.component.iota.lazyStartProducer";
public static final String
CAMEL_SINK_IOTA_COMPONENT_LAZY_START_PRODUCER_DOC = "Whether the producer
should be started lazy (on the first message). By starting lazy you can use
this to allow CamelContext and routes to startup in situations where a producer
may otherwise fail during starting and cause the route to fail being started.
By deferring this startup to be lazy then the startup failure can be handled
during routing messages via Camel's routing error handlers. Beware that when
[...]
diff --git
a/connectors/camel-kamelet-kafka-connector/src/generated/resources/camel-kamelet-sink.json
b/connectors/camel-kamelet-kafka-connector/src/generated/resources/camel-kamelet-sink.json
index 4c1842a..e45e81e 100644
---
a/connectors/camel-kamelet-kafka-connector/src/generated/resources/camel-kamelet-sink.json
+++
b/connectors/camel-kamelet-kafka-connector/src/generated/resources/camel-kamelet-sink.json
@@ -21,6 +21,12 @@
"priority": "MEDIUM",
"required": "false"
},
+ "camel.sink.endpoint.location": {
+ "name": "camel.sink.endpoint.location",
+ "description": "Location of the Kamelet to use which
can be specified as a resource from file system, classpath etc. The location
cannot use wildcards, and must refer to a file including extension, for example
file:\/etc\/foo-kamelet.xml",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
"camel.sink.endpoint.block": {
"name": "camel.sink.endpoint.block",
"description": "If sending a message to a direct
endpoint which has no active consumer, then we can tell the producer to block
and wait for the consumer to become active.",
@@ -96,8 +102,8 @@
"priority": "MEDIUM",
"required": "false"
},
- "camel.component.kamelet.kameletResourceLoaderListener": {
- "name":
"camel.component.kamelet.kameletResourceLoaderListener",
+ "camel.component.kamelet.routeTemplateLoaderListener": {
+ "name":
"camel.component.kamelet.routeTemplateLoaderListener",
"description": "To plugin a custom listener for when
the Kamelet component is loading Kamelets from external resources.",
"priority": "MEDIUM",
"required": "false"
diff --git
a/connectors/camel-kamelet-kafka-connector/src/generated/resources/camel-kamelet-source.json
b/connectors/camel-kamelet-kafka-connector/src/generated/resources/camel-kamelet-source.json
index d6742db..b88b62c 100644
---
a/connectors/camel-kamelet-kafka-connector/src/generated/resources/camel-kamelet-source.json
+++
b/connectors/camel-kamelet-kafka-connector/src/generated/resources/camel-kamelet-source.json
@@ -21,6 +21,12 @@
"priority": "MEDIUM",
"required": "false"
},
+ "camel.source.endpoint.location": {
+ "name": "camel.source.endpoint.location",
+ "description": "Location of the Kamelet to use which
can be specified as a resource from file system, classpath etc. The location
cannot use wildcards, and must refer to a file including extension, for example
file:\/etc\/foo-kamelet.xml",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
"camel.source.endpoint.bridgeErrorHandler": {
"name": "camel.source.endpoint.bridgeErrorHandler",
"description": "Allows for bridging the consumer to the
Camel routing Error Handler, which mean any exceptions occurred while the
consumer is trying to pickup incoming messages, or the likes, will now be
processed as a message and handled by the routing Error Handler. By default the
consumer will use the org.apache.camel.spi.ExceptionHandler to deal with
exceptions, that will be logged at WARN or ERROR level and ignored.",
@@ -78,8 +84,8 @@
"priority": "MEDIUM",
"required": "false"
},
- "camel.component.kamelet.kameletResourceLoaderListener": {
- "name":
"camel.component.kamelet.kameletResourceLoaderListener",
+ "camel.component.kamelet.routeTemplateLoaderListener": {
+ "name":
"camel.component.kamelet.routeTemplateLoaderListener",
"description": "To plugin a custom listener for when
the Kamelet component is loading Kamelets from external resources.",
"priority": "MEDIUM",
"required": "false"
diff --git
a/connectors/camel-kamelet-kafka-connector/src/main/docs/camel-kamelet-kafka-sink-connector.adoc
b/connectors/camel-kamelet-kafka-connector/src/main/docs/camel-kamelet-kafka-sink-connector.adoc
index a23cf18..41871d6 100644
---
a/connectors/camel-kamelet-kafka-connector/src/main/docs/camel-kamelet-kafka-sink-connector.adoc
+++
b/connectors/camel-kamelet-kafka-connector/src/main/docs/camel-kamelet-kafka-sink-connector.adoc
@@ -24,7 +24,7 @@
connector.class=org.apache.camel.kafkaconnector.kamelet.CamelKameletSinkConnecto
----
-The camel-kamelet sink connector supports 14 options, which are listed below.
+The camel-kamelet sink connector supports 15 options, which are listed below.
@@ -33,6 +33,7 @@ The camel-kamelet sink connector supports 14 options, which
are listed below.
| Name | Description | Default | Required | Priority
| *camel.sink.path.templateId* | The Route Template ID | null | true | HIGH
| *camel.sink.path.routeId* | The Route ID. Default value notice: The ID will
be auto-generated if not provided | null | false | MEDIUM
+| *camel.sink.endpoint.location* | Location of the Kamelet to use which can be
specified as a resource from file system, classpath etc. The location cannot
use wildcards, and must refer to a file including extension, for example
file:/etc/foo-kamelet.xml | null | false | MEDIUM
| *camel.sink.endpoint.block* | If sending a message to a direct endpoint
which has no active consumer, then we can tell the producer to block and wait
for the consumer to become active. | true | false | MEDIUM
| *camel.sink.endpoint.failIfNoConsumers* | Whether the producer should fail
by throwing an exception, when sending to a kamelet endpoint with no active
consumers. | true | false | MEDIUM
| *camel.sink.endpoint.lazyStartProducer* | Whether the producer should be
started lazy (on the first message). By starting lazy you can use this to allow
CamelContext and routes to startup in situations where a producer may otherwise
fail during starting and cause the route to fail being started. By deferring
this startup to be lazy then the startup failure can be handled during routing
messages via Camel's routing error handlers. Beware that when the first message
is processed then cre [...]
@@ -44,7 +45,7 @@ The camel-kamelet sink connector supports 14 options, which
are listed below.
| *camel.component.kamelet.lazyStartProducer* | Whether the producer should be
started lazy (on the first message). By starting lazy you can use this to allow
CamelContext and routes to startup in situations where a producer may otherwise
fail during starting and cause the route to fail being started. By deferring
this startup to be lazy then the startup failure can be handled during routing
messages via Camel's routing error handlers. Beware that when the first message
is processed then [...]
| *camel.component.kamelet.timeout* | The timeout value to use if block is
enabled. | 30000L | false | MEDIUM
| *camel.component.kamelet.autowiredEnabled* | Whether autowiring is enabled.
This is used for automatic autowiring options (the option must be marked as
autowired) by looking up in the registry to find if there is a single instance
of matching type, which then gets configured on the component. This can be used
for automatic configuring JDBC data sources, JMS connection factories, AWS
Clients, etc. | true | false | MEDIUM
-| *camel.component.kamelet.kameletResourceLoader Listener* | To plugin a
custom listener for when the Kamelet component is loading Kamelets from
external resources. | null | false | MEDIUM
+| *camel.component.kamelet.routeTemplateLoader Listener* | To plugin a custom
listener for when the Kamelet component is loading Kamelets from external
resources. | null | false | MEDIUM
|===
diff --git
a/connectors/camel-kamelet-kafka-connector/src/main/docs/camel-kamelet-kafka-source-connector.adoc
b/connectors/camel-kamelet-kafka-connector/src/main/docs/camel-kamelet-kafka-source-connector.adoc
index 5c9558b..0558e12 100644
---
a/connectors/camel-kamelet-kafka-connector/src/main/docs/camel-kamelet-kafka-source-connector.adoc
+++
b/connectors/camel-kamelet-kafka-connector/src/main/docs/camel-kamelet-kafka-source-connector.adoc
@@ -24,7 +24,7 @@
connector.class=org.apache.camel.kafkaconnector.kamelet.CamelKameletSourceConnec
----
-The camel-kamelet source connector supports 11 options, which are listed below.
+The camel-kamelet source connector supports 12 options, which are listed below.
@@ -33,6 +33,7 @@ The camel-kamelet source connector supports 11 options, which
are listed below.
| Name | Description | Default | Required | Priority
| *camel.source.path.templateId* | The Route Template ID | null | true | HIGH
| *camel.source.path.routeId* | The Route ID. Default value notice: The ID
will be auto-generated if not provided | null | false | MEDIUM
+| *camel.source.endpoint.location* | Location of the Kamelet to use which can
be specified as a resource from file system, classpath etc. The location cannot
use wildcards, and must refer to a file including extension, for example
file:/etc/foo-kamelet.xml | null | false | MEDIUM
| *camel.source.endpoint.bridgeErrorHandler* | Allows for bridging the
consumer to the Camel routing Error Handler, which mean any exceptions occurred
while the consumer is trying to pickup incoming messages, or the likes, will
now be processed as a message and handled by the routing Error Handler. By
default the consumer will use the org.apache.camel.spi.ExceptionHandler to deal
with exceptions, that will be logged at WARN or ERROR level and ignored. |
false | false | MEDIUM
| *camel.source.endpoint.exceptionHandler* | To let the consumer use a custom
ExceptionHandler. Notice if the option bridgeErrorHandler is enabled then this
option is not in use. By default the consumer will deal with exceptions, that
will be logged at WARN or ERROR level and ignored. | null | false | MEDIUM
| *camel.source.endpoint.exchangePattern* | Sets the exchange pattern when the
consumer creates an exchange. One of: [InOnly] [InOut] [InOptionalOut] | null |
false | MEDIUM
@@ -41,7 +42,7 @@ The camel-kamelet source connector supports 11 options, which
are listed below.
| *camel.component.kamelet.templateProperties* | Set template local
parameters. | null | false | MEDIUM
| *camel.component.kamelet.bridgeErrorHandler* | Allows for bridging the
consumer to the Camel routing Error Handler, which mean any exceptions occurred
while the consumer is trying to pickup incoming messages, or the likes, will
now be processed as a message and handled by the routing Error Handler. By
default the consumer will use the org.apache.camel.spi.ExceptionHandler to deal
with exceptions, that will be logged at WARN or ERROR level and ignored. |
false | false | MEDIUM
| *camel.component.kamelet.autowiredEnabled* | Whether autowiring is enabled.
This is used for automatic autowiring options (the option must be marked as
autowired) by looking up in the registry to find if there is a single instance
of matching type, which then gets configured on the component. This can be used
for automatic configuring JDBC data sources, JMS connection factories, AWS
Clients, etc. | true | false | MEDIUM
-| *camel.component.kamelet.kameletResourceLoader Listener* | To plugin a
custom listener for when the Kamelet component is loading Kamelets from
external resources. | null | false | MEDIUM
+| *camel.component.kamelet.routeTemplateLoader Listener* | To plugin a custom
listener for when the Kamelet component is loading Kamelets from external
resources. | null | false | MEDIUM
|===
diff --git
a/connectors/camel-kamelet-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/kamelet/CamelKameletSinkConnectorConfig.java
b/connectors/camel-kamelet-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/kamelet/CamelKameletSinkConnectorConfig.java
index e29341e..d5d4ce8 100644
---
a/connectors/camel-kamelet-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/kamelet/CamelKameletSinkConnectorConfig.java
+++
b/connectors/camel-kamelet-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/kamelet/CamelKameletSinkConnectorConfig.java
@@ -30,6 +30,9 @@ public class CamelKameletSinkConnectorConfig extends
CamelSinkConnectorConfig {
public static final String CAMEL_SINK_KAMELET_PATH_ROUTE_ID_CONF =
"camel.sink.path.routeId";
public static final String CAMEL_SINK_KAMELET_PATH_ROUTE_ID_DOC = "The
Route ID. Default value notice: The ID will be auto-generated if not provided";
public static final String CAMEL_SINK_KAMELET_PATH_ROUTE_ID_DEFAULT = null;
+ public static final String CAMEL_SINK_KAMELET_ENDPOINT_LOCATION_CONF =
"camel.sink.endpoint.location";
+ public static final String CAMEL_SINK_KAMELET_ENDPOINT_LOCATION_DOC =
"Location of the Kamelet to use which can be specified as a resource from file
system, classpath etc. The location cannot use wildcards, and must refer to a
file including extension, for example file:/etc/foo-kamelet.xml";
+ public static final String CAMEL_SINK_KAMELET_ENDPOINT_LOCATION_DEFAULT =
null;
public static final String CAMEL_SINK_KAMELET_ENDPOINT_BLOCK_CONF =
"camel.sink.endpoint.block";
public static final String CAMEL_SINK_KAMELET_ENDPOINT_BLOCK_DOC = "If
sending a message to a direct endpoint which has no active consumer, then we
can tell the producer to block and wait for the consumer to become active.";
public static final Boolean CAMEL_SINK_KAMELET_ENDPOINT_BLOCK_DEFAULT =
true;
@@ -63,9 +66,9 @@ public class CamelKameletSinkConnectorConfig extends
CamelSinkConnectorConfig {
public static final String
CAMEL_SINK_KAMELET_COMPONENT_AUTOWIRED_ENABLED_CONF =
"camel.component.kamelet.autowiredEnabled";
public static final String
CAMEL_SINK_KAMELET_COMPONENT_AUTOWIRED_ENABLED_DOC = "Whether autowiring is
enabled. This is used for automatic autowiring options (the option must be
marked as autowired) by looking up in the registry to find if there is a single
instance of matching type, which then gets configured on the component. This
can be used for automatic configuring JDBC data sources, JMS connection
factories, AWS Clients, etc.";
public static final Boolean
CAMEL_SINK_KAMELET_COMPONENT_AUTOWIRED_ENABLED_DEFAULT = true;
- public static final String
CAMEL_SINK_KAMELET_COMPONENT_KAMELET_RESOURCE_LOADER_LISTENER_CONF =
"camel.component.kamelet.kameletResourceLoaderListener";
- public static final String
CAMEL_SINK_KAMELET_COMPONENT_KAMELET_RESOURCE_LOADER_LISTENER_DOC = "To plugin
a custom listener for when the Kamelet component is loading Kamelets from
external resources.";
- public static final String
CAMEL_SINK_KAMELET_COMPONENT_KAMELET_RESOURCE_LOADER_LISTENER_DEFAULT = null;
+ public static final String
CAMEL_SINK_KAMELET_COMPONENT_ROUTE_TEMPLATE_LOADER_LISTENER_CONF =
"camel.component.kamelet.routeTemplateLoaderListener";
+ public static final String
CAMEL_SINK_KAMELET_COMPONENT_ROUTE_TEMPLATE_LOADER_LISTENER_DOC = "To plugin a
custom listener for when the Kamelet component is loading Kamelets from
external resources.";
+ public static final String
CAMEL_SINK_KAMELET_COMPONENT_ROUTE_TEMPLATE_LOADER_LISTENER_DEFAULT = null;
public CamelKameletSinkConnectorConfig(
ConfigDef config,
@@ -81,6 +84,7 @@ public class CamelKameletSinkConnectorConfig extends
CamelSinkConnectorConfig {
ConfigDef conf = new ConfigDef(CamelSinkConnectorConfig.conf());
conf.define(CAMEL_SINK_KAMELET_PATH_TEMPLATE_ID_CONF,
ConfigDef.Type.STRING, CAMEL_SINK_KAMELET_PATH_TEMPLATE_ID_DEFAULT,
ConfigDef.Importance.HIGH, CAMEL_SINK_KAMELET_PATH_TEMPLATE_ID_DOC);
conf.define(CAMEL_SINK_KAMELET_PATH_ROUTE_ID_CONF,
ConfigDef.Type.STRING, CAMEL_SINK_KAMELET_PATH_ROUTE_ID_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_KAMELET_PATH_ROUTE_ID_DOC);
+ conf.define(CAMEL_SINK_KAMELET_ENDPOINT_LOCATION_CONF,
ConfigDef.Type.STRING, CAMEL_SINK_KAMELET_ENDPOINT_LOCATION_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_KAMELET_ENDPOINT_LOCATION_DOC);
conf.define(CAMEL_SINK_KAMELET_ENDPOINT_BLOCK_CONF,
ConfigDef.Type.BOOLEAN, CAMEL_SINK_KAMELET_ENDPOINT_BLOCK_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_KAMELET_ENDPOINT_BLOCK_DOC);
conf.define(CAMEL_SINK_KAMELET_ENDPOINT_FAIL_IF_NO_CONSUMERS_CONF,
ConfigDef.Type.BOOLEAN,
CAMEL_SINK_KAMELET_ENDPOINT_FAIL_IF_NO_CONSUMERS_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SINK_KAMELET_ENDPOINT_FAIL_IF_NO_CONSUMERS_DOC);
conf.define(CAMEL_SINK_KAMELET_ENDPOINT_LAZY_START_PRODUCER_CONF,
ConfigDef.Type.BOOLEAN,
CAMEL_SINK_KAMELET_ENDPOINT_LAZY_START_PRODUCER_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SINK_KAMELET_ENDPOINT_LAZY_START_PRODUCER_DOC);
@@ -92,7 +96,7 @@ public class CamelKameletSinkConnectorConfig extends
CamelSinkConnectorConfig {
conf.define(CAMEL_SINK_KAMELET_COMPONENT_LAZY_START_PRODUCER_CONF,
ConfigDef.Type.BOOLEAN,
CAMEL_SINK_KAMELET_COMPONENT_LAZY_START_PRODUCER_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SINK_KAMELET_COMPONENT_LAZY_START_PRODUCER_DOC);
conf.define(CAMEL_SINK_KAMELET_COMPONENT_TIMEOUT_CONF,
ConfigDef.Type.LONG, CAMEL_SINK_KAMELET_COMPONENT_TIMEOUT_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_KAMELET_COMPONENT_TIMEOUT_DOC);
conf.define(CAMEL_SINK_KAMELET_COMPONENT_AUTOWIRED_ENABLED_CONF,
ConfigDef.Type.BOOLEAN, CAMEL_SINK_KAMELET_COMPONENT_AUTOWIRED_ENABLED_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SINK_KAMELET_COMPONENT_AUTOWIRED_ENABLED_DOC);
-
conf.define(CAMEL_SINK_KAMELET_COMPONENT_KAMELET_RESOURCE_LOADER_LISTENER_CONF,
ConfigDef.Type.STRING,
CAMEL_SINK_KAMELET_COMPONENT_KAMELET_RESOURCE_LOADER_LISTENER_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SINK_KAMELET_COMPONENT_KAMELET_RESOURCE_LOADER_LISTENER_DOC);
+
conf.define(CAMEL_SINK_KAMELET_COMPONENT_ROUTE_TEMPLATE_LOADER_LISTENER_CONF,
ConfigDef.Type.STRING,
CAMEL_SINK_KAMELET_COMPONENT_ROUTE_TEMPLATE_LOADER_LISTENER_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SINK_KAMELET_COMPONENT_ROUTE_TEMPLATE_LOADER_LISTENER_DOC);
return conf;
}
}
\ No newline at end of file
diff --git
a/connectors/camel-kamelet-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/kamelet/CamelKameletSourceConnectorConfig.java
b/connectors/camel-kamelet-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/kamelet/CamelKameletSourceConnectorConfig.java
index 75f1f7e..65c8fd1 100644
---
a/connectors/camel-kamelet-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/kamelet/CamelKameletSourceConnectorConfig.java
+++
b/connectors/camel-kamelet-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/kamelet/CamelKameletSourceConnectorConfig.java
@@ -32,6 +32,9 @@ public class CamelKameletSourceConnectorConfig
public static final String CAMEL_SOURCE_KAMELET_PATH_ROUTE_ID_CONF =
"camel.source.path.routeId";
public static final String CAMEL_SOURCE_KAMELET_PATH_ROUTE_ID_DOC = "The
Route ID. Default value notice: The ID will be auto-generated if not provided";
public static final String CAMEL_SOURCE_KAMELET_PATH_ROUTE_ID_DEFAULT =
null;
+ public static final String CAMEL_SOURCE_KAMELET_ENDPOINT_LOCATION_CONF =
"camel.source.endpoint.location";
+ public static final String CAMEL_SOURCE_KAMELET_ENDPOINT_LOCATION_DOC =
"Location of the Kamelet to use which can be specified as a resource from file
system, classpath etc. The location cannot use wildcards, and must refer to a
file including extension, for example file:/etc/foo-kamelet.xml";
+ public static final String CAMEL_SOURCE_KAMELET_ENDPOINT_LOCATION_DEFAULT
= null;
public static final String
CAMEL_SOURCE_KAMELET_ENDPOINT_BRIDGE_ERROR_HANDLER_CONF =
"camel.source.endpoint.bridgeErrorHandler";
public static final String
CAMEL_SOURCE_KAMELET_ENDPOINT_BRIDGE_ERROR_HANDLER_DOC = "Allows for bridging
the consumer to the Camel routing Error Handler, which mean any exceptions
occurred while the consumer is trying to pickup incoming messages, or the
likes, will now be processed as a message and handled by the routing Error
Handler. By default the consumer will use the
org.apache.camel.spi.ExceptionHandler to deal with exceptions, that will be
logged at WARN or ERROR level and ignored.";
public static final Boolean
CAMEL_SOURCE_KAMELET_ENDPOINT_BRIDGE_ERROR_HANDLER_DEFAULT = false;
@@ -56,9 +59,9 @@ public class CamelKameletSourceConnectorConfig
public static final String
CAMEL_SOURCE_KAMELET_COMPONENT_AUTOWIRED_ENABLED_CONF =
"camel.component.kamelet.autowiredEnabled";
public static final String
CAMEL_SOURCE_KAMELET_COMPONENT_AUTOWIRED_ENABLED_DOC = "Whether autowiring is
enabled. This is used for automatic autowiring options (the option must be
marked as autowired) by looking up in the registry to find if there is a single
instance of matching type, which then gets configured on the component. This
can be used for automatic configuring JDBC data sources, JMS connection
factories, AWS Clients, etc.";
public static final Boolean
CAMEL_SOURCE_KAMELET_COMPONENT_AUTOWIRED_ENABLED_DEFAULT = true;
- public static final String
CAMEL_SOURCE_KAMELET_COMPONENT_KAMELET_RESOURCE_LOADER_LISTENER_CONF =
"camel.component.kamelet.kameletResourceLoaderListener";
- public static final String
CAMEL_SOURCE_KAMELET_COMPONENT_KAMELET_RESOURCE_LOADER_LISTENER_DOC = "To
plugin a custom listener for when the Kamelet component is loading Kamelets
from external resources.";
- public static final String
CAMEL_SOURCE_KAMELET_COMPONENT_KAMELET_RESOURCE_LOADER_LISTENER_DEFAULT = null;
+ public static final String
CAMEL_SOURCE_KAMELET_COMPONENT_ROUTE_TEMPLATE_LOADER_LISTENER_CONF =
"camel.component.kamelet.routeTemplateLoaderListener";
+ public static final String
CAMEL_SOURCE_KAMELET_COMPONENT_ROUTE_TEMPLATE_LOADER_LISTENER_DOC = "To plugin
a custom listener for when the Kamelet component is loading Kamelets from
external resources.";
+ public static final String
CAMEL_SOURCE_KAMELET_COMPONENT_ROUTE_TEMPLATE_LOADER_LISTENER_DEFAULT = null;
public CamelKameletSourceConnectorConfig(
ConfigDef config,
@@ -74,6 +77,7 @@ public class CamelKameletSourceConnectorConfig
ConfigDef conf = new ConfigDef(CamelSourceConnectorConfig.conf());
conf.define(CAMEL_SOURCE_KAMELET_PATH_TEMPLATE_ID_CONF,
ConfigDef.Type.STRING, CAMEL_SOURCE_KAMELET_PATH_TEMPLATE_ID_DEFAULT,
ConfigDef.Importance.HIGH, CAMEL_SOURCE_KAMELET_PATH_TEMPLATE_ID_DOC);
conf.define(CAMEL_SOURCE_KAMELET_PATH_ROUTE_ID_CONF,
ConfigDef.Type.STRING, CAMEL_SOURCE_KAMELET_PATH_ROUTE_ID_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_KAMELET_PATH_ROUTE_ID_DOC);
+ conf.define(CAMEL_SOURCE_KAMELET_ENDPOINT_LOCATION_CONF,
ConfigDef.Type.STRING, CAMEL_SOURCE_KAMELET_ENDPOINT_LOCATION_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_KAMELET_ENDPOINT_LOCATION_DOC);
conf.define(CAMEL_SOURCE_KAMELET_ENDPOINT_BRIDGE_ERROR_HANDLER_CONF,
ConfigDef.Type.BOOLEAN,
CAMEL_SOURCE_KAMELET_ENDPOINT_BRIDGE_ERROR_HANDLER_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SOURCE_KAMELET_ENDPOINT_BRIDGE_ERROR_HANDLER_DOC);
conf.define(CAMEL_SOURCE_KAMELET_ENDPOINT_EXCEPTION_HANDLER_CONF,
ConfigDef.Type.STRING, CAMEL_SOURCE_KAMELET_ENDPOINT_EXCEPTION_HANDLER_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SOURCE_KAMELET_ENDPOINT_EXCEPTION_HANDLER_DOC);
conf.define(CAMEL_SOURCE_KAMELET_ENDPOINT_EXCHANGE_PATTERN_CONF,
ConfigDef.Type.STRING, CAMEL_SOURCE_KAMELET_ENDPOINT_EXCHANGE_PATTERN_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SOURCE_KAMELET_ENDPOINT_EXCHANGE_PATTERN_DOC);
@@ -82,7 +86,7 @@ public class CamelKameletSourceConnectorConfig
conf.define(CAMEL_SOURCE_KAMELET_COMPONENT_TEMPLATE_PROPERTIES_CONF,
ConfigDef.Type.STRING,
CAMEL_SOURCE_KAMELET_COMPONENT_TEMPLATE_PROPERTIES_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SOURCE_KAMELET_COMPONENT_TEMPLATE_PROPERTIES_DOC);
conf.define(CAMEL_SOURCE_KAMELET_COMPONENT_BRIDGE_ERROR_HANDLER_CONF,
ConfigDef.Type.BOOLEAN,
CAMEL_SOURCE_KAMELET_COMPONENT_BRIDGE_ERROR_HANDLER_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SOURCE_KAMELET_COMPONENT_BRIDGE_ERROR_HANDLER_DOC);
conf.define(CAMEL_SOURCE_KAMELET_COMPONENT_AUTOWIRED_ENABLED_CONF,
ConfigDef.Type.BOOLEAN,
CAMEL_SOURCE_KAMELET_COMPONENT_AUTOWIRED_ENABLED_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SOURCE_KAMELET_COMPONENT_AUTOWIRED_ENABLED_DOC);
-
conf.define(CAMEL_SOURCE_KAMELET_COMPONENT_KAMELET_RESOURCE_LOADER_LISTENER_CONF,
ConfigDef.Type.STRING,
CAMEL_SOURCE_KAMELET_COMPONENT_KAMELET_RESOURCE_LOADER_LISTENER_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SOURCE_KAMELET_COMPONENT_KAMELET_RESOURCE_LOADER_LISTENER_DOC);
+
conf.define(CAMEL_SOURCE_KAMELET_COMPONENT_ROUTE_TEMPLATE_LOADER_LISTENER_CONF,
ConfigDef.Type.STRING,
CAMEL_SOURCE_KAMELET_COMPONENT_ROUTE_TEMPLATE_LOADER_LISTENER_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SOURCE_KAMELET_COMPONENT_ROUTE_TEMPLATE_LOADER_LISTENER_DOC);
return conf;
}
}
\ No newline at end of file
diff --git
a/connectors/camel-sql-kafka-connector/src/generated/resources/camel-sql-sink.json
b/connectors/camel-sql-kafka-connector/src/generated/resources/camel-sql-sink.json
index b73c0b6..a7bf2a3 100644
---
a/connectors/camel-sql-kafka-connector/src/generated/resources/camel-sql-sink.json
+++
b/connectors/camel-sql-kafka-connector/src/generated/resources/camel-sql-sink.json
@@ -24,16 +24,10 @@
},
"camel.sink.endpoint.dataSource": {
"name": "camel.sink.endpoint.dataSource",
- "description": "Sets the DataSource to use to
communicate with the databaset at endpoint level.",
+ "description": "Sets the DataSource to use to
communicate with the database at endpoint level.",
"priority": "MEDIUM",
"required": "false"
},
- "camel.sink.endpoint.dataSourceRef": {
- "name": "camel.sink.endpoint.dataSourceRef",
- "description": "Sets the reference to a DataSource to
lookup from the registry, to use for communicating with the database.",
- "priority": "LOW",
- "required": "false"
- },
"camel.sink.endpoint.outputClass": {
"name": "camel.sink.endpoint.outputClass",
"description": "Specify the full package and class name
to use as conversion when outputType=SelectOne.",
diff --git
a/connectors/camel-sql-kafka-connector/src/generated/resources/camel-sql-source.json
b/connectors/camel-sql-kafka-connector/src/generated/resources/camel-sql-source.json
index 4a2fd76..935fd14 100644
---
a/connectors/camel-sql-kafka-connector/src/generated/resources/camel-sql-source.json
+++
b/connectors/camel-sql-kafka-connector/src/generated/resources/camel-sql-source.json
@@ -24,16 +24,10 @@
},
"camel.source.endpoint.dataSource": {
"name": "camel.source.endpoint.dataSource",
- "description": "Sets the DataSource to use to
communicate with the databaset at endpoint level.",
+ "description": "Sets the DataSource to use to
communicate with the database at endpoint level.",
"priority": "MEDIUM",
"required": "false"
},
- "camel.source.endpoint.dataSourceRef": {
- "name": "camel.source.endpoint.dataSourceRef",
- "description": "Sets the reference to a DataSource to
lookup from the registry, to use for communicating with the database.",
- "priority": "LOW",
- "required": "false"
- },
"camel.source.endpoint.outputClass": {
"name": "camel.source.endpoint.outputClass",
"description": "Specify the full package and class name
to use as conversion when outputType=SelectOne.",
diff --git
a/connectors/camel-sql-kafka-connector/src/main/docs/camel-sql-kafka-sink-connector.adoc
b/connectors/camel-sql-kafka-connector/src/main/docs/camel-sql-kafka-sink-connector.adoc
index d6f579c..52d2bb4 100644
---
a/connectors/camel-sql-kafka-connector/src/main/docs/camel-sql-kafka-sink-connector.adoc
+++
b/connectors/camel-sql-kafka-connector/src/main/docs/camel-sql-kafka-sink-connector.adoc
@@ -24,7 +24,7 @@
connector.class=org.apache.camel.kafkaconnector.sql.CamelSqlSinkConnector
----
-The camel-sql sink connector supports 22 options, which are listed below.
+The camel-sql sink connector supports 21 options, which are listed below.
@@ -33,8 +33,7 @@ The camel-sql sink connector supports 22 options, which are
listed below.
| Name | Description | Default | Required | Priority
| *camel.sink.path.query* | Sets the SQL query to perform. You can externalize
the query by using file: or classpath: as prefix and specify the location of
the file. | null | true | HIGH
| *camel.sink.endpoint.allowNamedParameters* | Whether to allow using named
parameters in the queries. | true | false | MEDIUM
-| *camel.sink.endpoint.dataSource* | Sets the DataSource to use to communicate
with the databaset at endpoint level. | null | false | MEDIUM
-| *camel.sink.endpoint.dataSourceRef* | Sets the reference to a DataSource to
lookup from the registry, to use for communicating with the database. | null |
false | LOW
+| *camel.sink.endpoint.dataSource* | Sets the DataSource to use to communicate
with the database at endpoint level. | null | false | MEDIUM
| *camel.sink.endpoint.outputClass* | Specify the full package and class name
to use as conversion when outputType=SelectOne. | null | false | MEDIUM
| *camel.sink.endpoint.outputHeader* | Store the query result in a header
instead of the message body. By default, outputHeader == null and the query
result is stored in the message body, any existing content in the message body
is discarded. If outputHeader is set, the value is used as the name of the
header to store the query result and the original message body is preserved. |
null | false | MEDIUM
| *camel.sink.endpoint.outputType* | Make the output of consumer or producer
to SelectList as List of Map, or SelectOne as single Java object in the
following way: a) If the query has only single column, then that JDBC Column
object is returned. (such as SELECT COUNT( ) FROM PROJECT will return a Long
object. b) If the query has more than one column, then it will return a Map of
that result. c) If the outputClass is set, then it will convert the query
result into an Java bean object by c [...]
diff --git
a/connectors/camel-sql-kafka-connector/src/main/docs/camel-sql-kafka-source-connector.adoc
b/connectors/camel-sql-kafka-connector/src/main/docs/camel-sql-kafka-source-connector.adoc
index 0813cf1..792419a 100644
---
a/connectors/camel-sql-kafka-connector/src/main/docs/camel-sql-kafka-source-connector.adoc
+++
b/connectors/camel-sql-kafka-connector/src/main/docs/camel-sql-kafka-source-connector.adoc
@@ -24,7 +24,7 @@
connector.class=org.apache.camel.kafkaconnector.sql.CamelSqlSourceConnector
----
-The camel-sql source connector supports 47 options, which are listed below.
+The camel-sql source connector supports 46 options, which are listed below.
@@ -33,8 +33,7 @@ The camel-sql source connector supports 47 options, which are
listed below.
| Name | Description | Default | Required | Priority
| *camel.source.path.query* | Sets the SQL query to perform. You can
externalize the query by using file: or classpath: as prefix and specify the
location of the file. | null | true | HIGH
| *camel.source.endpoint.allowNamedParameters* | Whether to allow using named
parameters in the queries. | true | false | MEDIUM
-| *camel.source.endpoint.dataSource* | Sets the DataSource to use to
communicate with the databaset at endpoint level. | null | false | MEDIUM
-| *camel.source.endpoint.dataSourceRef* | Sets the reference to a DataSource
to lookup from the registry, to use for communicating with the database. | null
| false | LOW
+| *camel.source.endpoint.dataSource* | Sets the DataSource to use to
communicate with the database at endpoint level. | null | false | MEDIUM
| *camel.source.endpoint.outputClass* | Specify the full package and class
name to use as conversion when outputType=SelectOne. | null | false | MEDIUM
| *camel.source.endpoint.outputHeader* | Store the query result in a header
instead of the message body. By default, outputHeader == null and the query
result is stored in the message body, any existing content in the message body
is discarded. If outputHeader is set, the value is used as the name of the
header to store the query result and the original message body is preserved. |
null | false | MEDIUM
| *camel.source.endpoint.outputType* | Make the output of consumer or producer
to SelectList as List of Map, or SelectOne as single Java object in the
following way: a) If the query has only single column, then that JDBC Column
object is returned. (such as SELECT COUNT( ) FROM PROJECT will return a Long
object. b) If the query has more than one column, then it will return a Map of
that result. c) If the outputClass is set, then it will convert the query
result into an Java bean object by [...]
diff --git
a/connectors/camel-sql-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/sql/CamelSqlSinkConnectorConfig.java
b/connectors/camel-sql-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/sql/CamelSqlSinkConnectorConfig.java
index 6fa33b1..cb12626 100644
---
a/connectors/camel-sql-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/sql/CamelSqlSinkConnectorConfig.java
+++
b/connectors/camel-sql-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/sql/CamelSqlSinkConnectorConfig.java
@@ -31,11 +31,8 @@ public class CamelSqlSinkConnectorConfig extends
CamelSinkConnectorConfig {
public static final String
CAMEL_SINK_SQL_ENDPOINT_ALLOW_NAMED_PARAMETERS_DOC = "Whether to allow using
named parameters in the queries.";
public static final Boolean
CAMEL_SINK_SQL_ENDPOINT_ALLOW_NAMED_PARAMETERS_DEFAULT = true;
public static final String CAMEL_SINK_SQL_ENDPOINT_DATA_SOURCE_CONF =
"camel.sink.endpoint.dataSource";
- public static final String CAMEL_SINK_SQL_ENDPOINT_DATA_SOURCE_DOC = "Sets
the DataSource to use to communicate with the databaset at endpoint level.";
+ public static final String CAMEL_SINK_SQL_ENDPOINT_DATA_SOURCE_DOC = "Sets
the DataSource to use to communicate with the database at endpoint level.";
public static final String CAMEL_SINK_SQL_ENDPOINT_DATA_SOURCE_DEFAULT =
null;
- public static final String CAMEL_SINK_SQL_ENDPOINT_DATA_SOURCE_REF_CONF =
"camel.sink.endpoint.dataSourceRef";
- public static final String CAMEL_SINK_SQL_ENDPOINT_DATA_SOURCE_REF_DOC =
"Sets the reference to a DataSource to lookup from the registry, to use for
communicating with the database.";
- public static final String CAMEL_SINK_SQL_ENDPOINT_DATA_SOURCE_REF_DEFAULT
= null;
public static final String CAMEL_SINK_SQL_ENDPOINT_OUTPUT_CLASS_CONF =
"camel.sink.endpoint.outputClass";
public static final String CAMEL_SINK_SQL_ENDPOINT_OUTPUT_CLASS_DOC =
"Specify the full package and class name to use as conversion when
outputType=SelectOne.";
public static final String CAMEL_SINK_SQL_ENDPOINT_OUTPUT_CLASS_DEFAULT =
null;
@@ -106,7 +103,6 @@ public class CamelSqlSinkConnectorConfig extends
CamelSinkConnectorConfig {
conf.define(CAMEL_SINK_SQL_PATH_QUERY_CONF, ConfigDef.Type.STRING,
CAMEL_SINK_SQL_PATH_QUERY_DEFAULT, ConfigDef.Importance.HIGH,
CAMEL_SINK_SQL_PATH_QUERY_DOC);
conf.define(CAMEL_SINK_SQL_ENDPOINT_ALLOW_NAMED_PARAMETERS_CONF,
ConfigDef.Type.BOOLEAN, CAMEL_SINK_SQL_ENDPOINT_ALLOW_NAMED_PARAMETERS_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SINK_SQL_ENDPOINT_ALLOW_NAMED_PARAMETERS_DOC);
conf.define(CAMEL_SINK_SQL_ENDPOINT_DATA_SOURCE_CONF,
ConfigDef.Type.STRING, CAMEL_SINK_SQL_ENDPOINT_DATA_SOURCE_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_SQL_ENDPOINT_DATA_SOURCE_DOC);
- conf.define(CAMEL_SINK_SQL_ENDPOINT_DATA_SOURCE_REF_CONF,
ConfigDef.Type.STRING, CAMEL_SINK_SQL_ENDPOINT_DATA_SOURCE_REF_DEFAULT,
ConfigDef.Importance.LOW, CAMEL_SINK_SQL_ENDPOINT_DATA_SOURCE_REF_DOC);
conf.define(CAMEL_SINK_SQL_ENDPOINT_OUTPUT_CLASS_CONF,
ConfigDef.Type.STRING, CAMEL_SINK_SQL_ENDPOINT_OUTPUT_CLASS_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_SQL_ENDPOINT_OUTPUT_CLASS_DOC);
conf.define(CAMEL_SINK_SQL_ENDPOINT_OUTPUT_HEADER_CONF,
ConfigDef.Type.STRING, CAMEL_SINK_SQL_ENDPOINT_OUTPUT_HEADER_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_SQL_ENDPOINT_OUTPUT_HEADER_DOC);
conf.define(CAMEL_SINK_SQL_ENDPOINT_OUTPUT_TYPE_CONF,
ConfigDef.Type.STRING, CAMEL_SINK_SQL_ENDPOINT_OUTPUT_TYPE_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_SQL_ENDPOINT_OUTPUT_TYPE_DOC);
diff --git
a/connectors/camel-sql-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/sql/CamelSqlSourceConnectorConfig.java
b/connectors/camel-sql-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/sql/CamelSqlSourceConnectorConfig.java
index b494b52..99d2cde 100644
---
a/connectors/camel-sql-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/sql/CamelSqlSourceConnectorConfig.java
+++
b/connectors/camel-sql-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/sql/CamelSqlSourceConnectorConfig.java
@@ -31,11 +31,8 @@ public class CamelSqlSourceConnectorConfig extends
CamelSourceConnectorConfig {
public static final String
CAMEL_SOURCE_SQL_ENDPOINT_ALLOW_NAMED_PARAMETERS_DOC = "Whether to allow using
named parameters in the queries.";
public static final Boolean
CAMEL_SOURCE_SQL_ENDPOINT_ALLOW_NAMED_PARAMETERS_DEFAULT = true;
public static final String CAMEL_SOURCE_SQL_ENDPOINT_DATA_SOURCE_CONF =
"camel.source.endpoint.dataSource";
- public static final String CAMEL_SOURCE_SQL_ENDPOINT_DATA_SOURCE_DOC =
"Sets the DataSource to use to communicate with the databaset at endpoint
level.";
+ public static final String CAMEL_SOURCE_SQL_ENDPOINT_DATA_SOURCE_DOC =
"Sets the DataSource to use to communicate with the database at endpoint
level.";
public static final String CAMEL_SOURCE_SQL_ENDPOINT_DATA_SOURCE_DEFAULT =
null;
- public static final String CAMEL_SOURCE_SQL_ENDPOINT_DATA_SOURCE_REF_CONF
= "camel.source.endpoint.dataSourceRef";
- public static final String CAMEL_SOURCE_SQL_ENDPOINT_DATA_SOURCE_REF_DOC =
"Sets the reference to a DataSource to lookup from the registry, to use for
communicating with the database.";
- public static final String
CAMEL_SOURCE_SQL_ENDPOINT_DATA_SOURCE_REF_DEFAULT = null;
public static final String CAMEL_SOURCE_SQL_ENDPOINT_OUTPUT_CLASS_CONF =
"camel.source.endpoint.outputClass";
public static final String CAMEL_SOURCE_SQL_ENDPOINT_OUTPUT_CLASS_DOC =
"Specify the full package and class name to use as conversion when
outputType=SelectOne.";
public static final String CAMEL_SOURCE_SQL_ENDPOINT_OUTPUT_CLASS_DEFAULT
= null;
@@ -181,7 +178,6 @@ public class CamelSqlSourceConnectorConfig extends
CamelSourceConnectorConfig {
conf.define(CAMEL_SOURCE_SQL_PATH_QUERY_CONF, ConfigDef.Type.STRING,
CAMEL_SOURCE_SQL_PATH_QUERY_DEFAULT, ConfigDef.Importance.HIGH,
CAMEL_SOURCE_SQL_PATH_QUERY_DOC);
conf.define(CAMEL_SOURCE_SQL_ENDPOINT_ALLOW_NAMED_PARAMETERS_CONF,
ConfigDef.Type.BOOLEAN,
CAMEL_SOURCE_SQL_ENDPOINT_ALLOW_NAMED_PARAMETERS_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SOURCE_SQL_ENDPOINT_ALLOW_NAMED_PARAMETERS_DOC);
conf.define(CAMEL_SOURCE_SQL_ENDPOINT_DATA_SOURCE_CONF,
ConfigDef.Type.STRING, CAMEL_SOURCE_SQL_ENDPOINT_DATA_SOURCE_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_SQL_ENDPOINT_DATA_SOURCE_DOC);
- conf.define(CAMEL_SOURCE_SQL_ENDPOINT_DATA_SOURCE_REF_CONF,
ConfigDef.Type.STRING, CAMEL_SOURCE_SQL_ENDPOINT_DATA_SOURCE_REF_DEFAULT,
ConfigDef.Importance.LOW, CAMEL_SOURCE_SQL_ENDPOINT_DATA_SOURCE_REF_DOC);
conf.define(CAMEL_SOURCE_SQL_ENDPOINT_OUTPUT_CLASS_CONF,
ConfigDef.Type.STRING, CAMEL_SOURCE_SQL_ENDPOINT_OUTPUT_CLASS_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_SQL_ENDPOINT_OUTPUT_CLASS_DOC);
conf.define(CAMEL_SOURCE_SQL_ENDPOINT_OUTPUT_HEADER_CONF,
ConfigDef.Type.STRING, CAMEL_SOURCE_SQL_ENDPOINT_OUTPUT_HEADER_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_SQL_ENDPOINT_OUTPUT_HEADER_DOC);
conf.define(CAMEL_SOURCE_SQL_ENDPOINT_OUTPUT_TYPE_CONF,
ConfigDef.Type.STRING, CAMEL_SOURCE_SQL_ENDPOINT_OUTPUT_TYPE_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_SQL_ENDPOINT_OUTPUT_TYPE_DOC);
diff --git
a/docs/modules/ROOT/pages/connectors/camel-elsql-kafka-sink-connector.adoc
b/docs/modules/ROOT/pages/connectors/camel-elsql-kafka-sink-connector.adoc
index 028f032..f418171 100644
--- a/docs/modules/ROOT/pages/connectors/camel-elsql-kafka-sink-connector.adoc
+++ b/docs/modules/ROOT/pages/connectors/camel-elsql-kafka-sink-connector.adoc
@@ -24,7 +24,7 @@
connector.class=org.apache.camel.kafkaconnector.elsql.CamelElsqlSinkConnector
----
-The camel-elsql sink connector supports 27 options, which are listed below.
+The camel-elsql sink connector supports 26 options, which are listed below.
@@ -35,8 +35,7 @@ The camel-elsql sink connector supports 27 options, which are
listed below.
| *camel.sink.path.resourceUri* | The resource file which contains the elsql
SQL statements to use. You can specify multiple resources separated by comma.
The resources are loaded on the classpath by default, you can prefix with file:
to load from file system. Notice you can set this option on the component and
then you do not have to configure this on the endpoint. | null | false | MEDIUM
| *camel.sink.endpoint.allowNamedParameters* | Whether to allow using named
parameters in the queries. | true | false | MEDIUM
| *camel.sink.endpoint.databaseVendor* | To use a vendor specific
com.opengamma.elsql.ElSqlConfig One of: [Default] [Postgres] [HSql] [MySql]
[Oracle] [SqlServer2008] [Veritca] | null | false | MEDIUM
-| *camel.sink.endpoint.dataSource* | Sets the DataSource to use to communicate
with the database. | null | false | MEDIUM
-| *camel.sink.endpoint.dataSourceRef* | Sets the reference to a DataSource to
lookup from the registry, to use for communicating with the database. | null |
false | LOW
+| *camel.sink.endpoint.dataSource* | Sets the DataSource to use to communicate
with the database at endpoint level. | null | false | MEDIUM
| *camel.sink.endpoint.outputClass* | Specify the full package and class name
to use as conversion when outputType=SelectOne. | null | false | MEDIUM
| *camel.sink.endpoint.outputHeader* | Store the query result in a header
instead of the message body. By default, outputHeader == null and the query
result is stored in the message body, any existing content in the message body
is discarded. If outputHeader is set, the value is used as the name of the
header to store the query result and the original message body is preserved. |
null | false | MEDIUM
| *camel.sink.endpoint.outputType* | Make the output of consumer or producer
to SelectList as List of Map, or SelectOne as single Java object in the
following way: a) If the query has only single column, then that JDBC Column
object is returned. (such as SELECT COUNT( ) FROM PROJECT will return a Long
object. b) If the query has more than one column, then it will return a Map of
that result. c) If the outputClass is set, then it will convert the query
result into an Java bean object by c [...]
@@ -75,8 +74,4 @@ The camel-elsql sink connector has no transforms out of the
box.
The camel-elsql sink connector has no aggregation strategies out of the box.
-
-
-
-
// kafka-connector options: END
diff --git
a/docs/modules/ROOT/pages/connectors/camel-elsql-kafka-source-connector.adoc
b/docs/modules/ROOT/pages/connectors/camel-elsql-kafka-source-connector.adoc
index d982125..d0b92fe 100644
--- a/docs/modules/ROOT/pages/connectors/camel-elsql-kafka-source-connector.adoc
+++ b/docs/modules/ROOT/pages/connectors/camel-elsql-kafka-source-connector.adoc
@@ -24,7 +24,7 @@
connector.class=org.apache.camel.kafkaconnector.elsql.CamelElsqlSourceConnector
----
-The camel-elsql source connector supports 52 options, which are listed below.
+The camel-elsql source connector supports 51 options, which are listed below.
@@ -35,8 +35,7 @@ The camel-elsql source connector supports 52 options, which
are listed below.
| *camel.source.path.resourceUri* | The resource file which contains the elsql
SQL statements to use. You can specify multiple resources separated by comma.
The resources are loaded on the classpath by default, you can prefix with file:
to load from file system. Notice you can set this option on the component and
then you do not have to configure this on the endpoint. | null | false | MEDIUM
| *camel.source.endpoint.allowNamedParameters* | Whether to allow using named
parameters in the queries. | true | false | MEDIUM
| *camel.source.endpoint.databaseVendor* | To use a vendor specific
com.opengamma.elsql.ElSqlConfig One of: [Default] [Postgres] [HSql] [MySql]
[Oracle] [SqlServer2008] [Veritca] | null | false | MEDIUM
-| *camel.source.endpoint.dataSource* | Sets the DataSource to use to
communicate with the database. | null | false | MEDIUM
-| *camel.source.endpoint.dataSourceRef* | Sets the reference to a DataSource
to lookup from the registry, to use for communicating with the database. | null
| false | LOW
+| *camel.source.endpoint.dataSource* | Sets the DataSource to use to
communicate with the database at endpoint level. | null | false | MEDIUM
| *camel.source.endpoint.outputClass* | Specify the full package and class
name to use as conversion when outputType=SelectOne. | null | false | MEDIUM
| *camel.source.endpoint.outputHeader* | Store the query result in a header
instead of the message body. By default, outputHeader == null and the query
result is stored in the message body, any existing content in the message body
is discarded. If outputHeader is set, the value is used as the name of the
header to store the query result and the original message body is preserved. |
null | false | MEDIUM
| *camel.source.endpoint.outputType* | Make the output of consumer or producer
to SelectList as List of Map, or SelectOne as single Java object in the
following way: a) If the query has only single column, then that JDBC Column
object is returned. (such as SELECT COUNT( ) FROM PROJECT will return a Long
object. b) If the query has more than one column, then it will return a Map of
that result. c) If the outputClass is set, then it will convert the query
result into an Java bean object by [...]
@@ -100,8 +99,4 @@ The camel-elsql source connector has no transforms out of
the box.
The camel-elsql source connector has no aggregation strategies out of the box.
-
-
-
-
// kafka-connector options: END
diff --git
a/docs/modules/ROOT/pages/connectors/camel-hwcloud-iam-kafka-sink-connector.adoc
b/docs/modules/ROOT/pages/connectors/camel-hwcloud-iam-kafka-sink-connector.adoc
index fb97e72..bc9d2c2 100644
---
a/docs/modules/ROOT/pages/connectors/camel-hwcloud-iam-kafka-sink-connector.adoc
+++
b/docs/modules/ROOT/pages/connectors/camel-hwcloud-iam-kafka-sink-connector.adoc
@@ -24,7 +24,7 @@
connector.class=org.apache.camel.kafkaconnector.hwcloudiam.CamelHwcloudiamSinkCo
----
-The camel-hwcloud-iam sink connector supports 16 options, which are listed
below.
+The camel-hwcloud-iam sink connector supports 15 options, which are listed
below.
@@ -33,18 +33,17 @@ The camel-hwcloud-iam sink connector supports 16 options,
which are listed below
| Name | Description | Default | Required | Priority
| *camel.sink.path.operation* | Operation to be performed | null | true | HIGH
| *camel.sink.endpoint.authenticationKey* | Authentication key for the cloud
user | null | true | HIGH
-| *camel.sink.endpoint.endpoint* | IAM endpoint url. Carries higher precedence
than region parameter based client initialization | null | false | MEDIUM
| *camel.sink.endpoint.groupId* | Group ID to perform operation with | null |
false | MEDIUM
| *camel.sink.endpoint.ignoreSslVerification* | Ignore SSL verification |
false | false | MEDIUM
+| *camel.sink.endpoint.lazyStartProducer* | Whether the producer should be
started lazy (on the first message). By starting lazy you can use this to allow
CamelContext and routes to startup in situations where a producer may otherwise
fail during starting and cause the route to fail being started. By deferring
this startup to be lazy then the startup failure can be handled during routing
messages via Camel's routing error handlers. Beware that when the first message
is processed then cre [...]
| *camel.sink.endpoint.proxyHost* | Proxy server ip/hostname | null | false |
MEDIUM
| *camel.sink.endpoint.proxyPassword* | Proxy authentication password | null |
false | MEDIUM
| *camel.sink.endpoint.proxyPort* | Proxy server port | null | false | MEDIUM
| *camel.sink.endpoint.proxyUser* | Proxy authentication user | null | false |
MEDIUM
-| *camel.sink.endpoint.region* | IAM service region. This is lower precedence
than endpoint based configuration | null | true | HIGH
+| *camel.sink.endpoint.region* | IAM service region | null | true | HIGH
| *camel.sink.endpoint.secretKey* | Secret key for the cloud user | null |
true | HIGH
| *camel.sink.endpoint.serviceKeys* | Configuration object for cloud service
authentication | null | false | MEDIUM
| *camel.sink.endpoint.userId* | User ID to perform operation with | null |
false | MEDIUM
-| *camel.sink.endpoint.lazyStartProducer* | Whether the producer should be
started lazy (on the first message). By starting lazy you can use this to allow
CamelContext and routes to startup in situations where a producer may otherwise
fail during starting and cause the route to fail being started. By deferring
this startup to be lazy then the startup failure can be handled during routing
messages via Camel's routing error handlers. Beware that when the first message
is processed then cre [...]
| *camel.component.hwcloud-iam.lazyStartProducer* | Whether the producer
should be started lazy (on the first message). By starting lazy you can use
this to allow CamelContext and routes to startup in situations where a producer
may otherwise fail during starting and cause the route to fail being started.
By deferring this startup to be lazy then the startup failure can be handled
during routing messages via Camel's routing error handlers. Beware that when
the first message is processed [...]
| *camel.component.hwcloud-iam.autowiredEnabled* | Whether autowiring is
enabled. This is used for automatic autowiring options (the option must be
marked as autowired) by looking up in the registry to find if there is a single
instance of matching type, which then gets configured on the component. This
can be used for automatic configuring JDBC data sources, JMS connection
factories, AWS Clients, etc. | true | false | MEDIUM
|===
@@ -64,8 +63,4 @@ The camel-hwcloud-iam sink connector has no transforms out of
the box.
The camel-hwcloud-iam sink connector has no aggregation strategies out of the
box.
-
-
-
-
// kafka-connector options: END
diff --git
a/docs/modules/ROOT/pages/connectors/camel-hwcloud-smn-kafka-sink-connector.adoc
b/docs/modules/ROOT/pages/connectors/camel-hwcloud-smn-kafka-sink-connector.adoc
index f5ca21b..0bb23e1 100644
---
a/docs/modules/ROOT/pages/connectors/camel-hwcloud-smn-kafka-sink-connector.adoc
+++
b/docs/modules/ROOT/pages/connectors/camel-hwcloud-smn-kafka-sink-connector.adoc
@@ -2,7 +2,7 @@
[[camel-hwcloud-smn-kafka-connector-sink]]
= camel-hwcloud-smn-kafka-connector sink configuration
-Connector Description: Huawei Cloud component to integrate with
SimpleNotification services
+Connector Description: To broadcast messages and connect cloud services
through notifications on Huawei Cloud
When using camel-hwcloud-smn-kafka-connector as sink make sure to use the
following Maven dependency to have support for the connector:
@@ -65,8 +65,4 @@ The camel-hwcloud-smn sink connector has no transforms out of
the box.
The camel-hwcloud-smn sink connector has no aggregation strategies out of the
box.
-
-
-
-
// kafka-connector options: END
diff --git
a/docs/modules/ROOT/pages/connectors/camel-iota-kafka-sink-connector.adoc
b/docs/modules/ROOT/pages/connectors/camel-iota-kafka-sink-connector.adoc
index 68f07e2..7d18567 100644
--- a/docs/modules/ROOT/pages/connectors/camel-iota-kafka-sink-connector.adoc
+++ b/docs/modules/ROOT/pages/connectors/camel-iota-kafka-sink-connector.adoc
@@ -38,7 +38,7 @@ The camel-iota sink connector supports 10 options, which are
listed below.
| *camel.sink.endpoint.operation* | Which operation to perform, one of:
sendTransfer, getNewAddress, getTransfers One of: [sendTransfer]
[getNewAddress] [getTransfers] | null | true | HIGH
| *camel.sink.endpoint.tag* | TAG | null | false | MEDIUM
| *camel.sink.endpoint.url* | Node url | null | true | HIGH
-| *camel.sink.endpoint.securityLevel* | Address security level | "1" | false |
MEDIUM
+| *camel.sink.endpoint.securityLevel* | Security level to be used for the
private key / address. Can be 1, 2 or 3. | "1" | false | MEDIUM
| *camel.component.iota.lazyStartProducer* | Whether the producer should be
started lazy (on the first message). By starting lazy you can use this to allow
CamelContext and routes to startup in situations where a producer may otherwise
fail during starting and cause the route to fail being started. By deferring
this startup to be lazy then the startup failure can be handled during routing
messages via Camel's routing error handlers. Beware that when the first message
is processed then cr [...]
| *camel.component.iota.autowiredEnabled* | Whether autowiring is enabled.
This is used for automatic autowiring options (the option must be marked as
autowired) by looking up in the registry to find if there is a single instance
of matching type, which then gets configured on the component. This can be used
for automatic configuring JDBC data sources, JMS connection factories, AWS
Clients, etc. | true | false | MEDIUM
|===
@@ -58,8 +58,4 @@ The camel-iota sink connector has no transforms out of the
box.
The camel-iota sink connector has no aggregation strategies out of the box.
-
-
-
-
// kafka-connector options: END
diff --git
a/docs/modules/ROOT/pages/connectors/camel-kamelet-kafka-sink-connector.adoc
b/docs/modules/ROOT/pages/connectors/camel-kamelet-kafka-sink-connector.adoc
index c5829c9..41871d6 100644
--- a/docs/modules/ROOT/pages/connectors/camel-kamelet-kafka-sink-connector.adoc
+++ b/docs/modules/ROOT/pages/connectors/camel-kamelet-kafka-sink-connector.adoc
@@ -24,7 +24,7 @@
connector.class=org.apache.camel.kafkaconnector.kamelet.CamelKameletSinkConnecto
----
-The camel-kamelet sink connector supports 14 options, which are listed below.
+The camel-kamelet sink connector supports 15 options, which are listed below.
@@ -33,6 +33,7 @@ The camel-kamelet sink connector supports 14 options, which
are listed below.
| Name | Description | Default | Required | Priority
| *camel.sink.path.templateId* | The Route Template ID | null | true | HIGH
| *camel.sink.path.routeId* | The Route ID. Default value notice: The ID will
be auto-generated if not provided | null | false | MEDIUM
+| *camel.sink.endpoint.location* | Location of the Kamelet to use which can be
specified as a resource from file system, classpath etc. The location cannot
use wildcards, and must refer to a file including extension, for example
file:/etc/foo-kamelet.xml | null | false | MEDIUM
| *camel.sink.endpoint.block* | If sending a message to a direct endpoint
which has no active consumer, then we can tell the producer to block and wait
for the consumer to become active. | true | false | MEDIUM
| *camel.sink.endpoint.failIfNoConsumers* | Whether the producer should fail
by throwing an exception, when sending to a kamelet endpoint with no active
consumers. | true | false | MEDIUM
| *camel.sink.endpoint.lazyStartProducer* | Whether the producer should be
started lazy (on the first message). By starting lazy you can use this to allow
CamelContext and routes to startup in situations where a producer may otherwise
fail during starting and cause the route to fail being started. By deferring
this startup to be lazy then the startup failure can be handled during routing
messages via Camel's routing error handlers. Beware that when the first message
is processed then cre [...]
@@ -44,7 +45,7 @@ The camel-kamelet sink connector supports 14 options, which
are listed below.
| *camel.component.kamelet.lazyStartProducer* | Whether the producer should be
started lazy (on the first message). By starting lazy you can use this to allow
CamelContext and routes to startup in situations where a producer may otherwise
fail during starting and cause the route to fail being started. By deferring
this startup to be lazy then the startup failure can be handled during routing
messages via Camel's routing error handlers. Beware that when the first message
is processed then [...]
| *camel.component.kamelet.timeout* | The timeout value to use if block is
enabled. | 30000L | false | MEDIUM
| *camel.component.kamelet.autowiredEnabled* | Whether autowiring is enabled.
This is used for automatic autowiring options (the option must be marked as
autowired) by looking up in the registry to find if there is a single instance
of matching type, which then gets configured on the component. This can be used
for automatic configuring JDBC data sources, JMS connection factories, AWS
Clients, etc. | true | false | MEDIUM
-| *camel.component.kamelet.kameletResourceLoader Listener* | To plugin a
custom listener for when the Kamelet component is loading Kamelets from
external resources. | null | false | MEDIUM
+| *camel.component.kamelet.routeTemplateLoader Listener* | To plugin a custom
listener for when the Kamelet component is loading Kamelets from external
resources. | null | false | MEDIUM
|===
@@ -62,8 +63,4 @@ The camel-kamelet sink connector has no transforms out of the
box.
The camel-kamelet sink connector has no aggregation strategies out of the box.
-
-
-
-
// kafka-connector options: END
diff --git
a/docs/modules/ROOT/pages/connectors/camel-kamelet-kafka-source-connector.adoc
b/docs/modules/ROOT/pages/connectors/camel-kamelet-kafka-source-connector.adoc
index 04be73a..0558e12 100644
---
a/docs/modules/ROOT/pages/connectors/camel-kamelet-kafka-source-connector.adoc
+++
b/docs/modules/ROOT/pages/connectors/camel-kamelet-kafka-source-connector.adoc
@@ -24,7 +24,7 @@
connector.class=org.apache.camel.kafkaconnector.kamelet.CamelKameletSourceConnec
----
-The camel-kamelet source connector supports 11 options, which are listed below.
+The camel-kamelet source connector supports 12 options, which are listed below.
@@ -33,6 +33,7 @@ The camel-kamelet source connector supports 11 options, which
are listed below.
| Name | Description | Default | Required | Priority
| *camel.source.path.templateId* | The Route Template ID | null | true | HIGH
| *camel.source.path.routeId* | The Route ID. Default value notice: The ID
will be auto-generated if not provided | null | false | MEDIUM
+| *camel.source.endpoint.location* | Location of the Kamelet to use which can
be specified as a resource from file system, classpath etc. The location cannot
use wildcards, and must refer to a file including extension, for example
file:/etc/foo-kamelet.xml | null | false | MEDIUM
| *camel.source.endpoint.bridgeErrorHandler* | Allows for bridging the
consumer to the Camel routing Error Handler, which mean any exceptions occurred
while the consumer is trying to pickup incoming messages, or the likes, will
now be processed as a message and handled by the routing Error Handler. By
default the consumer will use the org.apache.camel.spi.ExceptionHandler to deal
with exceptions, that will be logged at WARN or ERROR level and ignored. |
false | false | MEDIUM
| *camel.source.endpoint.exceptionHandler* | To let the consumer use a custom
ExceptionHandler. Notice if the option bridgeErrorHandler is enabled then this
option is not in use. By default the consumer will deal with exceptions, that
will be logged at WARN or ERROR level and ignored. | null | false | MEDIUM
| *camel.source.endpoint.exchangePattern* | Sets the exchange pattern when the
consumer creates an exchange. One of: [InOnly] [InOut] [InOptionalOut] | null |
false | MEDIUM
@@ -41,7 +42,7 @@ The camel-kamelet source connector supports 11 options, which
are listed below.
| *camel.component.kamelet.templateProperties* | Set template local
parameters. | null | false | MEDIUM
| *camel.component.kamelet.bridgeErrorHandler* | Allows for bridging the
consumer to the Camel routing Error Handler, which mean any exceptions occurred
while the consumer is trying to pickup incoming messages, or the likes, will
now be processed as a message and handled by the routing Error Handler. By
default the consumer will use the org.apache.camel.spi.ExceptionHandler to deal
with exceptions, that will be logged at WARN or ERROR level and ignored. |
false | false | MEDIUM
| *camel.component.kamelet.autowiredEnabled* | Whether autowiring is enabled.
This is used for automatic autowiring options (the option must be marked as
autowired) by looking up in the registry to find if there is a single instance
of matching type, which then gets configured on the component. This can be used
for automatic configuring JDBC data sources, JMS connection factories, AWS
Clients, etc. | true | false | MEDIUM
-| *camel.component.kamelet.kameletResourceLoader Listener* | To plugin a
custom listener for when the Kamelet component is loading Kamelets from
external resources. | null | false | MEDIUM
+| *camel.component.kamelet.routeTemplateLoader Listener* | To plugin a custom
listener for when the Kamelet component is loading Kamelets from external
resources. | null | false | MEDIUM
|===
@@ -59,8 +60,4 @@ The camel-kamelet source connector has no transforms out of
the box.
The camel-kamelet source connector has no aggregation strategies out of the
box.
-
-
-
-
// kafka-connector options: END
diff --git
a/docs/modules/ROOT/pages/connectors/camel-sql-kafka-sink-connector.adoc
b/docs/modules/ROOT/pages/connectors/camel-sql-kafka-sink-connector.adoc
index 5d33b62..52d2bb4 100644
--- a/docs/modules/ROOT/pages/connectors/camel-sql-kafka-sink-connector.adoc
+++ b/docs/modules/ROOT/pages/connectors/camel-sql-kafka-sink-connector.adoc
@@ -24,7 +24,7 @@
connector.class=org.apache.camel.kafkaconnector.sql.CamelSqlSinkConnector
----
-The camel-sql sink connector supports 22 options, which are listed below.
+The camel-sql sink connector supports 21 options, which are listed below.
@@ -33,8 +33,7 @@ The camel-sql sink connector supports 22 options, which are
listed below.
| Name | Description | Default | Required | Priority
| *camel.sink.path.query* | Sets the SQL query to perform. You can externalize
the query by using file: or classpath: as prefix and specify the location of
the file. | null | true | HIGH
| *camel.sink.endpoint.allowNamedParameters* | Whether to allow using named
parameters in the queries. | true | false | MEDIUM
-| *camel.sink.endpoint.dataSource* | Sets the DataSource to use to communicate
with the databaset at endpoint level. | null | false | MEDIUM
-| *camel.sink.endpoint.dataSourceRef* | Sets the reference to a DataSource to
lookup from the registry, to use for communicating with the database. | null |
false | LOW
+| *camel.sink.endpoint.dataSource* | Sets the DataSource to use to communicate
with the database at endpoint level. | null | false | MEDIUM
| *camel.sink.endpoint.outputClass* | Specify the full package and class name
to use as conversion when outputType=SelectOne. | null | false | MEDIUM
| *camel.sink.endpoint.outputHeader* | Store the query result in a header
instead of the message body. By default, outputHeader == null and the query
result is stored in the message body, any existing content in the message body
is discarded. If outputHeader is set, the value is used as the name of the
header to store the query result and the original message body is preserved. |
null | false | MEDIUM
| *camel.sink.endpoint.outputType* | Make the output of consumer or producer
to SelectList as List of Map, or SelectOne as single Java object in the
following way: a) If the query has only single column, then that JDBC Column
object is returned. (such as SELECT COUNT( ) FROM PROJECT will return a Long
object. b) If the query has more than one column, then it will return a Map of
that result. c) If the outputClass is set, then it will convert the query
result into an Java bean object by c [...]
@@ -70,8 +69,4 @@ The camel-sql sink connector has no transforms out of the box.
The camel-sql sink connector has no aggregation strategies out of the box.
-
-
-
-
// kafka-connector options: END
diff --git
a/docs/modules/ROOT/pages/connectors/camel-sql-kafka-source-connector.adoc
b/docs/modules/ROOT/pages/connectors/camel-sql-kafka-source-connector.adoc
index 1c5c68f..792419a 100644
--- a/docs/modules/ROOT/pages/connectors/camel-sql-kafka-source-connector.adoc
+++ b/docs/modules/ROOT/pages/connectors/camel-sql-kafka-source-connector.adoc
@@ -24,7 +24,7 @@
connector.class=org.apache.camel.kafkaconnector.sql.CamelSqlSourceConnector
----
-The camel-sql source connector supports 47 options, which are listed below.
+The camel-sql source connector supports 46 options, which are listed below.
@@ -33,8 +33,7 @@ The camel-sql source connector supports 47 options, which are
listed below.
| Name | Description | Default | Required | Priority
| *camel.source.path.query* | Sets the SQL query to perform. You can
externalize the query by using file: or classpath: as prefix and specify the
location of the file. | null | true | HIGH
| *camel.source.endpoint.allowNamedParameters* | Whether to allow using named
parameters in the queries. | true | false | MEDIUM
-| *camel.source.endpoint.dataSource* | Sets the DataSource to use to
communicate with the databaset at endpoint level. | null | false | MEDIUM
-| *camel.source.endpoint.dataSourceRef* | Sets the reference to a DataSource
to lookup from the registry, to use for communicating with the database. | null
| false | LOW
+| *camel.source.endpoint.dataSource* | Sets the DataSource to use to
communicate with the database at endpoint level. | null | false | MEDIUM
| *camel.source.endpoint.outputClass* | Specify the full package and class
name to use as conversion when outputType=SelectOne. | null | false | MEDIUM
| *camel.source.endpoint.outputHeader* | Store the query result in a header
instead of the message body. By default, outputHeader == null and the query
result is stored in the message body, any existing content in the message body
is discarded. If outputHeader is set, the value is used as the name of the
header to store the query result and the original message body is preserved. |
null | false | MEDIUM
| *camel.source.endpoint.outputType* | Make the output of consumer or producer
to SelectList as List of Map, or SelectOne as single Java object in the
following way: a) If the query has only single column, then that JDBC Column
object is returned. (such as SELECT COUNT( ) FROM PROJECT will return a Long
object. b) If the query has more than one column, then it will return a Map of
that result. c) If the outputClass is set, then it will convert the query
result into an Java bean object by [...]
@@ -95,8 +94,4 @@ The camel-sql source connector has no transforms out of the
box.
The camel-sql source connector has no aggregation strategies out of the box.
-
-
-
-
// kafka-connector options: END
