This is an automated email from the ASF dual-hosted git repository.
valdar 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 34c3b41 [create-pull-request] automated change
34c3b41 is described below
commit 34c3b418b5f993300b86cecefed84bf491ee1f48
Author: github-actions[bot]
<41898282+github-actions[bot]@users.noreply.github.com>
AuthorDate: Sat May 15 03:56:28 2021 +0000
[create-pull-request] automated change
---
.../resources/connectors/camel-aws2-cw-sink.json | 4 ++--
.../resources/connectors/camel-aws2-kms-sink.json | 14 ++++++++++++++
.../resources/connectors/camel-aws2-lambda-sink.json | 18 ++++++++++++++++--
.../resources/connectors/camel-mongodb-sink.json | 18 ++++++++++++++++++
.../resources/connectors/camel-mongodb-source.json | 18 ++++++++++++++++++
.../src/generated/resources/camel-aws2-cw-sink.json | 4 ++--
.../main/docs/camel-aws2-cw-kafka-sink-connector.adoc | 4 ++--
.../aws2cw/CamelAws2cwSinkConnectorConfig.java | 4 ++--
.../src/generated/resources/camel-aws2-kms-sink.json | 14 ++++++++++++++
.../main/docs/camel-aws2-kms-kafka-sink-connector.adoc | 4 +++-
.../aws2kms/CamelAws2kmsSinkConnectorConfig.java | 8 ++++++++
.../generated/resources/camel-aws2-lambda-sink.json | 18 ++++++++++++++++--
.../docs/camel-aws2-lambda-kafka-sink-connector.adoc | 8 +++++---
.../aws2lambda/CamelAws2lambdaSinkConnectorConfig.java | 12 ++++++++++--
.../src/generated/resources/camel-mongodb-sink.json | 18 ++++++++++++++++++
.../src/generated/resources/camel-mongodb-source.json | 18 ++++++++++++++++++
.../main/docs/camel-mongodb-kafka-sink-connector.adoc | 5 ++++-
.../docs/camel-mongodb-kafka-source-connector.adoc | 5 ++++-
.../mongodb/CamelMongodbSinkConnectorConfig.java | 12 ++++++++++++
.../mongodb/CamelMongodbSourceConnectorConfig.java | 12 ++++++++++++
.../connectors/camel-aws2-cw-kafka-sink-connector.adoc | 4 ++--
.../camel-aws2-kms-kafka-sink-connector.adoc | 4 +++-
.../camel-aws2-lambda-kafka-sink-connector.adoc | 8 +++++---
.../connectors/camel-mongodb-kafka-sink-connector.adoc | 5 ++++-
.../camel-mongodb-kafka-source-connector.adoc | 5 ++++-
25 files changed, 216 insertions(+), 28 deletions(-)
diff --git
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws2-cw-sink.json
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws2-cw-sink.json
index 8a94f96..841807d 100644
---
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws2-cw-sink.json
+++
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws2-cw-sink.json
@@ -66,7 +66,7 @@
},
"camel.sink.endpoint.region": {
"name": "camel.sink.endpoint.region",
- "description": "The region in which EKS client needs to
work. When using this parameter, the configuration will expect the lowercase
name of the region (for example ap-east-1) You'll need to use the name
Region.EU_WEST_1.id()",
+ "description": "The region in which CW client needs to
work. When using this parameter, the configuration will expect the lowercase
name of the region (for example ap-east-1) You'll need to use the name
Region.EU_WEST_1.id()",
"priority": "MEDIUM",
"required": "false"
},
@@ -177,7 +177,7 @@
},
"camel.component.aws2-cw.region": {
"name": "camel.component.aws2-cw.region",
- "description": "The region in which EKS client needs to
work. When using this parameter, the configuration will expect the lowercase
name of the region (for example ap-east-1) You'll need to use the name
Region.EU_WEST_1.id()",
+ "description": "The region in which CW client needs to
work. When using this parameter, the configuration will expect the lowercase
name of the region (for example ap-east-1) You'll need to use the name
Region.EU_WEST_1.id()",
"priority": "MEDIUM",
"required": "false"
},
diff --git
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws2-kms-sink.json
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws2-kms-sink.json
index 2fa387e..b689bfa 100644
---
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws2-kms-sink.json
+++
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws2-kms-sink.json
@@ -98,6 +98,13 @@
"priority": "MEDIUM",
"required": "false"
},
+ "camel.sink.endpoint.useDefaultCredentialsProvider": {
+ "name":
"camel.sink.endpoint.useDefaultCredentialsProvider",
+ "description": "Set whether the KMS client should
expect to load credentials through a default credentials provider or to expect
static credentials to be passed in.",
+ "defaultValue": "false",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
"camel.sink.endpoint.accessKey": {
"name": "camel.sink.endpoint.accessKey",
"description": "Amazon AWS Access Key",
@@ -199,6 +206,13 @@
"priority": "MEDIUM",
"required": "false"
},
+ "camel.component.aws2-kms.useDefaultCredentialsProvider": {
+ "name":
"camel.component.aws2-kms.useDefaultCredentialsProvider",
+ "description": "Set whether the KMS client should
expect to load credentials through a default credentials provider or to expect
static credentials to be passed in.",
+ "defaultValue": "false",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
"camel.component.aws2-kms.autowiredEnabled": {
"name": "camel.component.aws2-kms.autowiredEnabled",
"description": "Whether autowiring is enabled. This is
used for automatic autowiring options (the option must be marked as autowired)
by looking up in the registry to find if there is a single instance of matching
type, which then gets configured on the component. This can be used for
automatic configuring JDBC data sources, JMS connection factories, AWS Clients,
etc.",
diff --git
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws2-lambda-sink.json
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws2-lambda-sink.json
index f350892..36c57d8 100644
---
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws2-lambda-sink.json
+++
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws2-lambda-sink.json
@@ -65,7 +65,7 @@
},
"camel.sink.endpoint.region": {
"name": "camel.sink.endpoint.region",
- "description": "The region in which ECS client needs to
work. When using this parameter, the configuration will expect the lowercase
name of the region (for example ap-east-1) You'll need to use the name
Region.EU_WEST_1.id()",
+ "description": "The region in which Lambda client needs
to work. When using this parameter, the configuration will expect the lowercase
name of the region (for example ap-east-1) You'll need to use the name
Region.EU_WEST_1.id()",
"priority": "MEDIUM",
"required": "false"
},
@@ -82,6 +82,13 @@
"priority": "MEDIUM",
"required": "false"
},
+ "camel.sink.endpoint.useDefaultCredentialsProvider": {
+ "name":
"camel.sink.endpoint.useDefaultCredentialsProvider",
+ "description": "Set whether the Lambda client should
expect to load credentials through a default credentials provider or to expect
static credentials to be passed in.",
+ "defaultValue": "false",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
"camel.sink.endpoint.awsLambdaClient": {
"name": "camel.sink.endpoint.awsLambdaClient",
"description": "To use a existing configured
AwsLambdaClient as client",
@@ -179,7 +186,7 @@
},
"camel.component.aws2-lambda.region": {
"name": "camel.component.aws2-lambda.region",
- "description": "The region in which ECS client needs to
work. When using this parameter, the configuration will expect the lowercase
name of the region (for example ap-east-1) You'll need to use the name
Region.EU_WEST_1.id()",
+ "description": "The region in which Lambda client needs
to work. When using this parameter, the configuration will expect the lowercase
name of the region (for example ap-east-1) You'll need to use the name
Region.EU_WEST_1.id()",
"priority": "MEDIUM",
"required": "false"
},
@@ -196,6 +203,13 @@
"priority": "MEDIUM",
"required": "false"
},
+ "camel.component.aws2-lambda.useDefaultCredentialsProvider": {
+ "name":
"camel.component.aws2-lambda.useDefaultCredentialsProvider",
+ "description": "Set whether the Lambda client should
expect to load credentials through a default credentials provider or to expect
static credentials to be passed in.",
+ "defaultValue": "false",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
"camel.component.aws2-lambda.autowiredEnabled": {
"name": "camel.component.aws2-lambda.autowiredEnabled",
"description": "Whether autowiring is enabled. This is
used for automatic autowiring options (the option must be marked as autowired)
by looking up in the registry to find if there is a single instance of matching
type, which then gets configured on the component. This can be used for
automatic configuring JDBC data sources, JMS connection factories, AWS Clients,
etc.",
diff --git
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-mongodb-sink.json
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-mongodb-sink.json
index d100e07..7ac614f 100644
---
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-mongodb-sink.json
+++
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-mongodb-sink.json
@@ -40,6 +40,12 @@
"priority": "MEDIUM",
"required": "false"
},
+ "camel.sink.endpoint.hosts": {
+ "name": "camel.sink.endpoint.hosts",
+ "description": "Host address of mongodb server in
host:port format. It's possible also use more than one address, as comma
separated list of hosts: host1:port1,host2:port2. If hosts parameter is
specified, provided connectionBean is ignored.",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
"camel.sink.endpoint.mongoConnection": {
"name": "camel.sink.endpoint.mongoConnection",
"description": "Sets the connection bean used as a
client for connecting to a database.",
@@ -143,6 +149,18 @@
"priority": "MEDIUM",
"required": "false"
},
+ "camel.sink.endpoint.password": {
+ "name": "camel.sink.endpoint.password",
+ "description": "User password for mongodb connection",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
+ "camel.sink.endpoint.username": {
+ "name": "camel.sink.endpoint.username",
+ "description": "Username for mongodb connection",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
"camel.sink.endpoint.persistentId": {
"name": "camel.sink.endpoint.persistentId",
"description": "One tail tracking collection can host
many trackers for several tailable consumers. To keep them separate, each
tracker should have its own unique persistentId.",
diff --git
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-mongodb-source.json
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-mongodb-source.json
index 0c7eee6..b8abc47 100644
---
a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-mongodb-source.json
+++
b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-mongodb-source.json
@@ -40,6 +40,12 @@
"priority": "MEDIUM",
"required": "false"
},
+ "camel.source.endpoint.hosts": {
+ "name": "camel.source.endpoint.hosts",
+ "description": "Host address of mongodb server in
host:port format. It's possible also use more than one address, as comma
separated list of hosts: host1:port1,host2:port2. If hosts parameter is
specified, provided connectionBean is ignored.",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
"camel.source.endpoint.mongoConnection": {
"name": "camel.source.endpoint.mongoConnection",
"description": "Sets the connection bean used as a
client for connecting to a database.",
@@ -166,6 +172,18 @@
"priority": "MEDIUM",
"required": "false"
},
+ "camel.source.endpoint.password": {
+ "name": "camel.source.endpoint.password",
+ "description": "User password for mongodb connection",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
+ "camel.source.endpoint.username": {
+ "name": "camel.source.endpoint.username",
+ "description": "Username for mongodb connection",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
"camel.source.endpoint.persistentId": {
"name": "camel.source.endpoint.persistentId",
"description": "One tail tracking collection can host
many trackers for several tailable consumers. To keep them separate, each
tracker should have its own unique persistentId.",
diff --git
a/connectors/camel-aws2-cw-kafka-connector/src/generated/resources/camel-aws2-cw-sink.json
b/connectors/camel-aws2-cw-kafka-connector/src/generated/resources/camel-aws2-cw-sink.json
index 8a94f96..841807d 100644
---
a/connectors/camel-aws2-cw-kafka-connector/src/generated/resources/camel-aws2-cw-sink.json
+++
b/connectors/camel-aws2-cw-kafka-connector/src/generated/resources/camel-aws2-cw-sink.json
@@ -66,7 +66,7 @@
},
"camel.sink.endpoint.region": {
"name": "camel.sink.endpoint.region",
- "description": "The region in which EKS client needs to
work. When using this parameter, the configuration will expect the lowercase
name of the region (for example ap-east-1) You'll need to use the name
Region.EU_WEST_1.id()",
+ "description": "The region in which CW client needs to
work. When using this parameter, the configuration will expect the lowercase
name of the region (for example ap-east-1) You'll need to use the name
Region.EU_WEST_1.id()",
"priority": "MEDIUM",
"required": "false"
},
@@ -177,7 +177,7 @@
},
"camel.component.aws2-cw.region": {
"name": "camel.component.aws2-cw.region",
- "description": "The region in which EKS client needs to
work. When using this parameter, the configuration will expect the lowercase
name of the region (for example ap-east-1) You'll need to use the name
Region.EU_WEST_1.id()",
+ "description": "The region in which CW client needs to
work. When using this parameter, the configuration will expect the lowercase
name of the region (for example ap-east-1) You'll need to use the name
Region.EU_WEST_1.id()",
"priority": "MEDIUM",
"required": "false"
},
diff --git
a/connectors/camel-aws2-cw-kafka-connector/src/main/docs/camel-aws2-cw-kafka-sink-connector.adoc
b/connectors/camel-aws2-cw-kafka-connector/src/main/docs/camel-aws2-cw-kafka-sink-connector.adoc
index 4daf037..4d4ef6c 100644
---
a/connectors/camel-aws2-cw-kafka-connector/src/main/docs/camel-aws2-cw-kafka-sink-connector.adoc
+++
b/connectors/camel-aws2-cw-kafka-connector/src/main/docs/camel-aws2-cw-kafka-sink-connector.adoc
@@ -39,7 +39,7 @@ The camel-aws2-cw sink connector supports 35 options, which
are listed below.
| *camel.sink.endpoint.proxyHost* | To define a proxy host when instantiating
the CW client | null | false | MEDIUM
| *camel.sink.endpoint.proxyPort* | To define a proxy port when instantiating
the CW client | null | false | MEDIUM
| *camel.sink.endpoint.proxyProtocol* | To define a proxy protocol when
instantiating the CW client One of: [HTTP] [HTTPS] | "HTTPS" | false | MEDIUM
-| *camel.sink.endpoint.region* | The region in which EKS client needs to work.
When using this parameter, the configuration will expect the lowercase name of
the region (for example ap-east-1) You'll need to use the name
Region.EU_WEST_1.id() | null | false | MEDIUM
+| *camel.sink.endpoint.region* | The region in which CW client needs to work.
When using this parameter, the configuration will expect the lowercase name of
the region (for example ap-east-1) You'll need to use the name
Region.EU_WEST_1.id() | null | false | MEDIUM
| *camel.sink.endpoint.timestamp* | The metric timestamp | null | false |
MEDIUM
| *camel.sink.endpoint.trustAllCertificates* | If we want to trust all
certificates in case of overriding the endpoint | false | false | MEDIUM
| *camel.sink.endpoint.unit* | The metric unit | null | false | MEDIUM
@@ -56,7 +56,7 @@ The camel-aws2-cw sink connector supports 35 options, which
are listed below.
| *camel.component.aws2-cw.proxyHost* | To define a proxy host when
instantiating the CW client | null | false | MEDIUM
| *camel.component.aws2-cw.proxyPort* | To define a proxy port when
instantiating the CW client | null | false | MEDIUM
| *camel.component.aws2-cw.proxyProtocol* | To define a proxy protocol when
instantiating the CW client One of: [HTTP] [HTTPS] | "HTTPS" | false | MEDIUM
-| *camel.component.aws2-cw.region* | The region in which EKS client needs to
work. When using this parameter, the configuration will expect the lowercase
name of the region (for example ap-east-1) You'll need to use the name
Region.EU_WEST_1.id() | null | false | MEDIUM
+| *camel.component.aws2-cw.region* | The region in which CW client needs to
work. When using this parameter, the configuration will expect the lowercase
name of the region (for example ap-east-1) You'll need to use the name
Region.EU_WEST_1.id() | null | false | MEDIUM
| *camel.component.aws2-cw.timestamp* | The metric timestamp | null | false |
MEDIUM
| *camel.component.aws2-cw.trustAllCertificates* | If we want to trust all
certificates in case of overriding the endpoint | false | false | MEDIUM
| *camel.component.aws2-cw.unit* | The metric unit | null | false | MEDIUM
diff --git
a/connectors/camel-aws2-cw-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/aws2cw/CamelAws2cwSinkConnectorConfig.java
b/connectors/camel-aws2-cw-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/aws2cw/CamelAws2cwSinkConnectorConfig.java
index 06780f5..172f6ef 100644
---
a/connectors/camel-aws2-cw-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/aws2cw/CamelAws2cwSinkConnectorConfig.java
+++
b/connectors/camel-aws2-cw-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/aws2cw/CamelAws2cwSinkConnectorConfig.java
@@ -49,7 +49,7 @@ public class CamelAws2cwSinkConnectorConfig extends
CamelSinkConnectorConfig {
public static final String CAMEL_SINK_AWS2CW_ENDPOINT_PROXY_PROTOCOL_DOC =
"To define a proxy protocol when instantiating the CW client One of: [HTTP]
[HTTPS]";
public static final String
CAMEL_SINK_AWS2CW_ENDPOINT_PROXY_PROTOCOL_DEFAULT = "HTTPS";
public static final String CAMEL_SINK_AWS2CW_ENDPOINT_REGION_CONF =
"camel.sink.endpoint.region";
- public static final String CAMEL_SINK_AWS2CW_ENDPOINT_REGION_DOC = "The
region in which EKS client needs to work. When using this parameter, the
configuration will expect the lowercase name of the region (for example
ap-east-1) You'll need to use the name Region.EU_WEST_1.id()";
+ public static final String CAMEL_SINK_AWS2CW_ENDPOINT_REGION_DOC = "The
region in which CW client needs to work. When using this parameter, the
configuration will expect the lowercase name of the region (for example
ap-east-1) You'll need to use the name Region.EU_WEST_1.id()";
public static final String CAMEL_SINK_AWS2CW_ENDPOINT_REGION_DEFAULT =
null;
public static final String CAMEL_SINK_AWS2CW_ENDPOINT_TIMESTAMP_CONF =
"camel.sink.endpoint.timestamp";
public static final String CAMEL_SINK_AWS2CW_ENDPOINT_TIMESTAMP_DOC = "The
metric timestamp";
@@ -100,7 +100,7 @@ public class CamelAws2cwSinkConnectorConfig extends
CamelSinkConnectorConfig {
public static final String CAMEL_SINK_AWS2CW_COMPONENT_PROXY_PROTOCOL_DOC
= "To define a proxy protocol when instantiating the CW client One of: [HTTP]
[HTTPS]";
public static final String
CAMEL_SINK_AWS2CW_COMPONENT_PROXY_PROTOCOL_DEFAULT = "HTTPS";
public static final String CAMEL_SINK_AWS2CW_COMPONENT_REGION_CONF =
"camel.component.aws2-cw.region";
- public static final String CAMEL_SINK_AWS2CW_COMPONENT_REGION_DOC = "The
region in which EKS client needs to work. When using this parameter, the
configuration will expect the lowercase name of the region (for example
ap-east-1) You'll need to use the name Region.EU_WEST_1.id()";
+ public static final String CAMEL_SINK_AWS2CW_COMPONENT_REGION_DOC = "The
region in which CW client needs to work. When using this parameter, the
configuration will expect the lowercase name of the region (for example
ap-east-1) You'll need to use the name Region.EU_WEST_1.id()";
public static final String CAMEL_SINK_AWS2CW_COMPONENT_REGION_DEFAULT =
null;
public static final String CAMEL_SINK_AWS2CW_COMPONENT_TIMESTAMP_CONF =
"camel.component.aws2-cw.timestamp";
public static final String CAMEL_SINK_AWS2CW_COMPONENT_TIMESTAMP_DOC =
"The metric timestamp";
diff --git
a/connectors/camel-aws2-kms-kafka-connector/src/generated/resources/camel-aws2-kms-sink.json
b/connectors/camel-aws2-kms-kafka-connector/src/generated/resources/camel-aws2-kms-sink.json
index 2fa387e..b689bfa 100644
---
a/connectors/camel-aws2-kms-kafka-connector/src/generated/resources/camel-aws2-kms-sink.json
+++
b/connectors/camel-aws2-kms-kafka-connector/src/generated/resources/camel-aws2-kms-sink.json
@@ -98,6 +98,13 @@
"priority": "MEDIUM",
"required": "false"
},
+ "camel.sink.endpoint.useDefaultCredentialsProvider": {
+ "name":
"camel.sink.endpoint.useDefaultCredentialsProvider",
+ "description": "Set whether the KMS client should
expect to load credentials through a default credentials provider or to expect
static credentials to be passed in.",
+ "defaultValue": "false",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
"camel.sink.endpoint.accessKey": {
"name": "camel.sink.endpoint.accessKey",
"description": "Amazon AWS Access Key",
@@ -199,6 +206,13 @@
"priority": "MEDIUM",
"required": "false"
},
+ "camel.component.aws2-kms.useDefaultCredentialsProvider": {
+ "name":
"camel.component.aws2-kms.useDefaultCredentialsProvider",
+ "description": "Set whether the KMS client should
expect to load credentials through a default credentials provider or to expect
static credentials to be passed in.",
+ "defaultValue": "false",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
"camel.component.aws2-kms.autowiredEnabled": {
"name": "camel.component.aws2-kms.autowiredEnabled",
"description": "Whether autowiring is enabled. This is
used for automatic autowiring options (the option must be marked as autowired)
by looking up in the registry to find if there is a single instance of matching
type, which then gets configured on the component. This can be used for
automatic configuring JDBC data sources, JMS connection factories, AWS Clients,
etc.",
diff --git
a/connectors/camel-aws2-kms-kafka-connector/src/main/docs/camel-aws2-kms-kafka-sink-connector.adoc
b/connectors/camel-aws2-kms-kafka-connector/src/main/docs/camel-aws2-kms-kafka-sink-connector.adoc
index 7ecc13d..23e0ecf 100644
---
a/connectors/camel-aws2-kms-kafka-connector/src/main/docs/camel-aws2-kms-kafka-sink-connector.adoc
+++
b/connectors/camel-aws2-kms-kafka-connector/src/main/docs/camel-aws2-kms-kafka-sink-connector.adoc
@@ -24,7 +24,7 @@
connector.class=org.apache.camel.kafkaconnector.aws2kms.CamelAws2kmsSinkConnecto
----
-The camel-aws2-kms sink connector supports 29 options, which are listed below.
+The camel-aws2-kms sink connector supports 31 options, which are listed below.
@@ -43,6 +43,7 @@ The camel-aws2-kms sink connector supports 29 options, which
are listed below.
| *camel.sink.endpoint.region* | The region in which EKS client needs to work.
When using this parameter, the configuration will expect the lowercase name of
the region (for example ap-east-1) You'll need to use the name
Region.EU_WEST_1.id() | null | false | MEDIUM
| *camel.sink.endpoint.trustAllCertificates* | If we want to trust all
certificates in case of overriding the endpoint | false | false | MEDIUM
| *camel.sink.endpoint.uriEndpointOverride* | Set the overriding uri endpoint.
This option needs to be used in combination with overrideEndpoint option | null
| false | MEDIUM
+| *camel.sink.endpoint.useDefaultCredentialsProvider* | Set whether the KMS
client should expect to load credentials through a default credentials provider
or to expect static credentials to be passed in. | false | false | MEDIUM
| *camel.sink.endpoint.accessKey* | Amazon AWS Access Key | null | false |
MEDIUM
| *camel.sink.endpoint.secretKey* | Amazon AWS Secret Key | null | false |
MEDIUM
| *camel.component.aws2-kms.configuration* | Component configuration | null |
false | MEDIUM
@@ -57,6 +58,7 @@ The camel-aws2-kms sink connector supports 29 options, which
are listed below.
| *camel.component.aws2-kms.region* | The region in which EKS client needs to
work. When using this parameter, the configuration will expect the lowercase
name of the region (for example ap-east-1) You'll need to use the name
Region.EU_WEST_1.id() | null | false | MEDIUM
| *camel.component.aws2-kms.trustAllCertificates* | If we want to trust all
certificates in case of overriding the endpoint | false | false | MEDIUM
| *camel.component.aws2-kms.uriEndpointOverride* | Set the overriding uri
endpoint. This option needs to be used in combination with overrideEndpoint
option | null | false | MEDIUM
+| *camel.component.aws2-kms.useDefaultCredentials Provider* | Set whether the
KMS client should expect to load credentials through a default credentials
provider or to expect static credentials to be passed in. | false | false |
MEDIUM
| *camel.component.aws2-kms.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.aws2-kms.accessKey* | Amazon AWS Access Key | null | false
| MEDIUM
| *camel.component.aws2-kms.secretKey* | Amazon AWS Secret Key | null | false
| MEDIUM
diff --git
a/connectors/camel-aws2-kms-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/aws2kms/CamelAws2kmsSinkConnectorConfig.java
b/connectors/camel-aws2-kms-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/aws2kms/CamelAws2kmsSinkConnectorConfig.java
index 613f380..3aa67f7 100644
---
a/connectors/camel-aws2-kms-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/aws2kms/CamelAws2kmsSinkConnectorConfig.java
+++
b/connectors/camel-aws2-kms-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/aws2kms/CamelAws2kmsSinkConnectorConfig.java
@@ -60,6 +60,9 @@ public class CamelAws2kmsSinkConnectorConfig extends
CamelSinkConnectorConfig {
public static final String
CAMEL_SINK_AWS2KMS_ENDPOINT_URI_ENDPOINT_OVERRIDE_CONF =
"camel.sink.endpoint.uriEndpointOverride";
public static final String
CAMEL_SINK_AWS2KMS_ENDPOINT_URI_ENDPOINT_OVERRIDE_DOC = "Set the overriding uri
endpoint. This option needs to be used in combination with overrideEndpoint
option";
public static final String
CAMEL_SINK_AWS2KMS_ENDPOINT_URI_ENDPOINT_OVERRIDE_DEFAULT = null;
+ public static final String
CAMEL_SINK_AWS2KMS_ENDPOINT_USE_DEFAULT_CREDENTIALS_PROVIDER_CONF =
"camel.sink.endpoint.useDefaultCredentialsProvider";
+ public static final String
CAMEL_SINK_AWS2KMS_ENDPOINT_USE_DEFAULT_CREDENTIALS_PROVIDER_DOC = "Set whether
the KMS client should expect to load credentials through a default credentials
provider or to expect static credentials to be passed in.";
+ public static final Boolean
CAMEL_SINK_AWS2KMS_ENDPOINT_USE_DEFAULT_CREDENTIALS_PROVIDER_DEFAULT = false;
public static final String CAMEL_SINK_AWS2KMS_ENDPOINT_ACCESS_KEY_CONF =
"camel.sink.endpoint.accessKey";
public static final String CAMEL_SINK_AWS2KMS_ENDPOINT_ACCESS_KEY_DOC =
"Amazon AWS Access Key";
public static final String CAMEL_SINK_AWS2KMS_ENDPOINT_ACCESS_KEY_DEFAULT
= null;
@@ -102,6 +105,9 @@ public class CamelAws2kmsSinkConnectorConfig extends
CamelSinkConnectorConfig {
public static final String
CAMEL_SINK_AWS2KMS_COMPONENT_URI_ENDPOINT_OVERRIDE_CONF =
"camel.component.aws2-kms.uriEndpointOverride";
public static final String
CAMEL_SINK_AWS2KMS_COMPONENT_URI_ENDPOINT_OVERRIDE_DOC = "Set the overriding
uri endpoint. This option needs to be used in combination with overrideEndpoint
option";
public static final String
CAMEL_SINK_AWS2KMS_COMPONENT_URI_ENDPOINT_OVERRIDE_DEFAULT = null;
+ public static final String
CAMEL_SINK_AWS2KMS_COMPONENT_USE_DEFAULT_CREDENTIALS_PROVIDER_CONF =
"camel.component.aws2-kms.useDefaultCredentialsProvider";
+ public static final String
CAMEL_SINK_AWS2KMS_COMPONENT_USE_DEFAULT_CREDENTIALS_PROVIDER_DOC = "Set
whether the KMS client should expect to load credentials through a default
credentials provider or to expect static credentials to be passed in.";
+ public static final Boolean
CAMEL_SINK_AWS2KMS_COMPONENT_USE_DEFAULT_CREDENTIALS_PROVIDER_DEFAULT = false;
public static final String
CAMEL_SINK_AWS2KMS_COMPONENT_AUTOWIRED_ENABLED_CONF =
"camel.component.aws2-kms.autowiredEnabled";
public static final String
CAMEL_SINK_AWS2KMS_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_AWS2KMS_COMPONENT_AUTOWIRED_ENABLED_DEFAULT = true;
@@ -136,6 +142,7 @@ public class CamelAws2kmsSinkConnectorConfig extends
CamelSinkConnectorConfig {
conf.define(CAMEL_SINK_AWS2KMS_ENDPOINT_REGION_CONF,
ConfigDef.Type.STRING, CAMEL_SINK_AWS2KMS_ENDPOINT_REGION_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_AWS2KMS_ENDPOINT_REGION_DOC);
conf.define(CAMEL_SINK_AWS2KMS_ENDPOINT_TRUST_ALL_CERTIFICATES_CONF,
ConfigDef.Type.BOOLEAN,
CAMEL_SINK_AWS2KMS_ENDPOINT_TRUST_ALL_CERTIFICATES_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SINK_AWS2KMS_ENDPOINT_TRUST_ALL_CERTIFICATES_DOC);
conf.define(CAMEL_SINK_AWS2KMS_ENDPOINT_URI_ENDPOINT_OVERRIDE_CONF,
ConfigDef.Type.STRING,
CAMEL_SINK_AWS2KMS_ENDPOINT_URI_ENDPOINT_OVERRIDE_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SINK_AWS2KMS_ENDPOINT_URI_ENDPOINT_OVERRIDE_DOC);
+
conf.define(CAMEL_SINK_AWS2KMS_ENDPOINT_USE_DEFAULT_CREDENTIALS_PROVIDER_CONF,
ConfigDef.Type.BOOLEAN,
CAMEL_SINK_AWS2KMS_ENDPOINT_USE_DEFAULT_CREDENTIALS_PROVIDER_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SINK_AWS2KMS_ENDPOINT_USE_DEFAULT_CREDENTIALS_PROVIDER_DOC);
conf.define(CAMEL_SINK_AWS2KMS_ENDPOINT_ACCESS_KEY_CONF,
ConfigDef.Type.PASSWORD, CAMEL_SINK_AWS2KMS_ENDPOINT_ACCESS_KEY_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_AWS2KMS_ENDPOINT_ACCESS_KEY_DOC);
conf.define(CAMEL_SINK_AWS2KMS_ENDPOINT_SECRET_KEY_CONF,
ConfigDef.Type.PASSWORD, CAMEL_SINK_AWS2KMS_ENDPOINT_SECRET_KEY_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_AWS2KMS_ENDPOINT_SECRET_KEY_DOC);
conf.define(CAMEL_SINK_AWS2KMS_COMPONENT_CONFIGURATION_CONF,
ConfigDef.Type.STRING, CAMEL_SINK_AWS2KMS_COMPONENT_CONFIGURATION_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_AWS2KMS_COMPONENT_CONFIGURATION_DOC);
@@ -150,6 +157,7 @@ public class CamelAws2kmsSinkConnectorConfig extends
CamelSinkConnectorConfig {
conf.define(CAMEL_SINK_AWS2KMS_COMPONENT_REGION_CONF,
ConfigDef.Type.STRING, CAMEL_SINK_AWS2KMS_COMPONENT_REGION_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_AWS2KMS_COMPONENT_REGION_DOC);
conf.define(CAMEL_SINK_AWS2KMS_COMPONENT_TRUST_ALL_CERTIFICATES_CONF,
ConfigDef.Type.BOOLEAN,
CAMEL_SINK_AWS2KMS_COMPONENT_TRUST_ALL_CERTIFICATES_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SINK_AWS2KMS_COMPONENT_TRUST_ALL_CERTIFICATES_DOC);
conf.define(CAMEL_SINK_AWS2KMS_COMPONENT_URI_ENDPOINT_OVERRIDE_CONF,
ConfigDef.Type.STRING,
CAMEL_SINK_AWS2KMS_COMPONENT_URI_ENDPOINT_OVERRIDE_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SINK_AWS2KMS_COMPONENT_URI_ENDPOINT_OVERRIDE_DOC);
+
conf.define(CAMEL_SINK_AWS2KMS_COMPONENT_USE_DEFAULT_CREDENTIALS_PROVIDER_CONF,
ConfigDef.Type.BOOLEAN,
CAMEL_SINK_AWS2KMS_COMPONENT_USE_DEFAULT_CREDENTIALS_PROVIDER_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SINK_AWS2KMS_COMPONENT_USE_DEFAULT_CREDENTIALS_PROVIDER_DOC);
conf.define(CAMEL_SINK_AWS2KMS_COMPONENT_AUTOWIRED_ENABLED_CONF,
ConfigDef.Type.BOOLEAN, CAMEL_SINK_AWS2KMS_COMPONENT_AUTOWIRED_ENABLED_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SINK_AWS2KMS_COMPONENT_AUTOWIRED_ENABLED_DOC);
conf.define(CAMEL_SINK_AWS2KMS_COMPONENT_ACCESS_KEY_CONF,
ConfigDef.Type.PASSWORD, CAMEL_SINK_AWS2KMS_COMPONENT_ACCESS_KEY_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_AWS2KMS_COMPONENT_ACCESS_KEY_DOC);
conf.define(CAMEL_SINK_AWS2KMS_COMPONENT_SECRET_KEY_CONF,
ConfigDef.Type.PASSWORD, CAMEL_SINK_AWS2KMS_COMPONENT_SECRET_KEY_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_AWS2KMS_COMPONENT_SECRET_KEY_DOC);
diff --git
a/connectors/camel-aws2-lambda-kafka-connector/src/generated/resources/camel-aws2-lambda-sink.json
b/connectors/camel-aws2-lambda-kafka-connector/src/generated/resources/camel-aws2-lambda-sink.json
index f350892..36c57d8 100644
---
a/connectors/camel-aws2-lambda-kafka-connector/src/generated/resources/camel-aws2-lambda-sink.json
+++
b/connectors/camel-aws2-lambda-kafka-connector/src/generated/resources/camel-aws2-lambda-sink.json
@@ -65,7 +65,7 @@
},
"camel.sink.endpoint.region": {
"name": "camel.sink.endpoint.region",
- "description": "The region in which ECS client needs to
work. When using this parameter, the configuration will expect the lowercase
name of the region (for example ap-east-1) You'll need to use the name
Region.EU_WEST_1.id()",
+ "description": "The region in which Lambda client needs
to work. When using this parameter, the configuration will expect the lowercase
name of the region (for example ap-east-1) You'll need to use the name
Region.EU_WEST_1.id()",
"priority": "MEDIUM",
"required": "false"
},
@@ -82,6 +82,13 @@
"priority": "MEDIUM",
"required": "false"
},
+ "camel.sink.endpoint.useDefaultCredentialsProvider": {
+ "name":
"camel.sink.endpoint.useDefaultCredentialsProvider",
+ "description": "Set whether the Lambda client should
expect to load credentials through a default credentials provider or to expect
static credentials to be passed in.",
+ "defaultValue": "false",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
"camel.sink.endpoint.awsLambdaClient": {
"name": "camel.sink.endpoint.awsLambdaClient",
"description": "To use a existing configured
AwsLambdaClient as client",
@@ -179,7 +186,7 @@
},
"camel.component.aws2-lambda.region": {
"name": "camel.component.aws2-lambda.region",
- "description": "The region in which ECS client needs to
work. When using this parameter, the configuration will expect the lowercase
name of the region (for example ap-east-1) You'll need to use the name
Region.EU_WEST_1.id()",
+ "description": "The region in which Lambda client needs
to work. When using this parameter, the configuration will expect the lowercase
name of the region (for example ap-east-1) You'll need to use the name
Region.EU_WEST_1.id()",
"priority": "MEDIUM",
"required": "false"
},
@@ -196,6 +203,13 @@
"priority": "MEDIUM",
"required": "false"
},
+ "camel.component.aws2-lambda.useDefaultCredentialsProvider": {
+ "name":
"camel.component.aws2-lambda.useDefaultCredentialsProvider",
+ "description": "Set whether the Lambda client should
expect to load credentials through a default credentials provider or to expect
static credentials to be passed in.",
+ "defaultValue": "false",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
"camel.component.aws2-lambda.autowiredEnabled": {
"name": "camel.component.aws2-lambda.autowiredEnabled",
"description": "Whether autowiring is enabled. This is
used for automatic autowiring options (the option must be marked as autowired)
by looking up in the registry to find if there is a single instance of matching
type, which then gets configured on the component. This can be used for
automatic configuring JDBC data sources, JMS connection factories, AWS Clients,
etc.",
diff --git
a/connectors/camel-aws2-lambda-kafka-connector/src/main/docs/camel-aws2-lambda-kafka-sink-connector.adoc
b/connectors/camel-aws2-lambda-kafka-connector/src/main/docs/camel-aws2-lambda-kafka-sink-connector.adoc
index 703ff97..1c39c89 100644
---
a/connectors/camel-aws2-lambda-kafka-connector/src/main/docs/camel-aws2-lambda-kafka-sink-connector.adoc
+++
b/connectors/camel-aws2-lambda-kafka-connector/src/main/docs/camel-aws2-lambda-kafka-sink-connector.adoc
@@ -24,7 +24,7 @@
connector.class=org.apache.camel.kafkaconnector.aws2lambda.CamelAws2lambdaSinkCo
----
-The camel-aws2-lambda sink connector supports 29 options, which are listed
below.
+The camel-aws2-lambda sink connector supports 31 options, which are listed
below.
@@ -36,9 +36,10 @@ The camel-aws2-lambda sink connector supports 29 options,
which are listed below
| *camel.sink.endpoint.operation* | The operation to perform. It can be
listFunctions, getFunction, createFunction, deleteFunction or invokeFunction
One of: [listFunctions] [getFunction] [createAlias] [deleteAlias] [getAlias]
[listAliases] [createFunction] [deleteFunction] [invokeFunction]
[updateFunction] [createEventSourceMapping] [deleteEventSourceMapping]
[listEventSourceMapping] [listTags] [tagResource] [untagResource]
[publishVersion] [listVersions] | "invokeFunction" | false | MEDIUM
| *camel.sink.endpoint.overrideEndpoint* | Set the need for overidding the
endpoint. This option needs to be used in combination with uriEndpointOverride
option | false | false | MEDIUM
| *camel.sink.endpoint.pojoRequest* | If we want to use a POJO request as body
or not | false | false | MEDIUM
-| *camel.sink.endpoint.region* | The region in which ECS client needs to work.
When using this parameter, the configuration will expect the lowercase name of
the region (for example ap-east-1) You'll need to use the name
Region.EU_WEST_1.id() | null | false | MEDIUM
+| *camel.sink.endpoint.region* | The region in which Lambda client needs to
work. When using this parameter, the configuration will expect the lowercase
name of the region (for example ap-east-1) You'll need to use the name
Region.EU_WEST_1.id() | null | false | MEDIUM
| *camel.sink.endpoint.trustAllCertificates* | If we want to trust all
certificates in case of overriding the endpoint | false | false | MEDIUM
| *camel.sink.endpoint.uriEndpointOverride* | Set the overriding uri endpoint.
This option needs to be used in combination with overrideEndpoint option | null
| false | MEDIUM
+| *camel.sink.endpoint.useDefaultCredentialsProvider* | Set whether the Lambda
client should expect to load credentials through a default credentials provider
or to expect static credentials to be passed in. | false | false | MEDIUM
| *camel.sink.endpoint.awsLambdaClient* | To use a existing configured
AwsLambdaClient as client | null | false | MEDIUM
| *camel.sink.endpoint.proxyHost* | To define a proxy host when instantiating
the Lambda client | null | false | MEDIUM
| *camel.sink.endpoint.proxyPort* | To define a proxy port when instantiating
the Lambda client | null | false | MEDIUM
@@ -50,9 +51,10 @@ The camel-aws2-lambda sink connector supports 29 options,
which are listed below
| *camel.component.aws2-lambda.operation* | The operation to perform. It can
be listFunctions, getFunction, createFunction, deleteFunction or invokeFunction
One of: [listFunctions] [getFunction] [createAlias] [deleteAlias] [getAlias]
[listAliases] [createFunction] [deleteFunction] [invokeFunction]
[updateFunction] [createEventSourceMapping] [deleteEventSourceMapping]
[listEventSourceMapping] [listTags] [tagResource] [untagResource]
[publishVersion] [listVersions] | "invokeFunction" | fal [...]
| *camel.component.aws2-lambda.overrideEndpoint* | Set the need for overidding
the endpoint. This option needs to be used in combination with
uriEndpointOverride option | false | false | MEDIUM
| *camel.component.aws2-lambda.pojoRequest* | If we want to use a POJO request
as body or not | false | false | MEDIUM
-| *camel.component.aws2-lambda.region* | The region in which ECS client needs
to work. When using this parameter, the configuration will expect the lowercase
name of the region (for example ap-east-1) You'll need to use the name
Region.EU_WEST_1.id() | null | false | MEDIUM
+| *camel.component.aws2-lambda.region* | The region in which Lambda client
needs to work. When using this parameter, the configuration will expect the
lowercase name of the region (for example ap-east-1) You'll need to use the
name Region.EU_WEST_1.id() | null | false | MEDIUM
| *camel.component.aws2-lambda.trustAllCertificates* | If we want to trust all
certificates in case of overriding the endpoint | false | false | MEDIUM
| *camel.component.aws2-lambda.uriEndpointOverride* | Set the overriding uri
endpoint. This option needs to be used in combination with overrideEndpoint
option | null | false | MEDIUM
+| *camel.component.aws2-lambda.useDefaultCredentials Provider* | Set whether
the Lambda client should expect to load credentials through a default
credentials provider or to expect static credentials to be passed in. | false |
false | MEDIUM
| *camel.component.aws2-lambda.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.aws2-lambda.awsLambdaClient* | To use a existing configured
AwsLambdaClient as client | null | false | MEDIUM
| *camel.component.aws2-lambda.proxyHost* | To define a proxy host when
instantiating the Lambda client | null | false | MEDIUM
diff --git
a/connectors/camel-aws2-lambda-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/aws2lambda/CamelAws2lambdaSinkConnectorConfig.java
b/connectors/camel-aws2-lambda-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/aws2lambda/CamelAws2lambdaSinkConnectorConfig.java
index 1e29d1a..031fec7 100644
---
a/connectors/camel-aws2-lambda-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/aws2lambda/CamelAws2lambdaSinkConnectorConfig.java
+++
b/connectors/camel-aws2-lambda-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/aws2lambda/CamelAws2lambdaSinkConnectorConfig.java
@@ -42,7 +42,7 @@ public class CamelAws2lambdaSinkConnectorConfig
public static final String CAMEL_SINK_AWS2LAMBDA_ENDPOINT_POJO_REQUEST_DOC
= "If we want to use a POJO request as body or not";
public static final Boolean
CAMEL_SINK_AWS2LAMBDA_ENDPOINT_POJO_REQUEST_DEFAULT = false;
public static final String CAMEL_SINK_AWS2LAMBDA_ENDPOINT_REGION_CONF =
"camel.sink.endpoint.region";
- public static final String CAMEL_SINK_AWS2LAMBDA_ENDPOINT_REGION_DOC =
"The region in which ECS client needs to work. When using this parameter, the
configuration will expect the lowercase name of the region (for example
ap-east-1) You'll need to use the name Region.EU_WEST_1.id()";
+ public static final String CAMEL_SINK_AWS2LAMBDA_ENDPOINT_REGION_DOC =
"The region in which Lambda client needs to work. When using this parameter,
the configuration will expect the lowercase name of the region (for example
ap-east-1) You'll need to use the name Region.EU_WEST_1.id()";
public static final String CAMEL_SINK_AWS2LAMBDA_ENDPOINT_REGION_DEFAULT =
null;
public static final String
CAMEL_SINK_AWS2LAMBDA_ENDPOINT_TRUST_ALL_CERTIFICATES_CONF =
"camel.sink.endpoint.trustAllCertificates";
public static final String
CAMEL_SINK_AWS2LAMBDA_ENDPOINT_TRUST_ALL_CERTIFICATES_DOC = "If we want to
trust all certificates in case of overriding the endpoint";
@@ -50,6 +50,9 @@ public class CamelAws2lambdaSinkConnectorConfig
public static final String
CAMEL_SINK_AWS2LAMBDA_ENDPOINT_URI_ENDPOINT_OVERRIDE_CONF =
"camel.sink.endpoint.uriEndpointOverride";
public static final String
CAMEL_SINK_AWS2LAMBDA_ENDPOINT_URI_ENDPOINT_OVERRIDE_DOC = "Set the overriding
uri endpoint. This option needs to be used in combination with overrideEndpoint
option";
public static final String
CAMEL_SINK_AWS2LAMBDA_ENDPOINT_URI_ENDPOINT_OVERRIDE_DEFAULT = null;
+ public static final String
CAMEL_SINK_AWS2LAMBDA_ENDPOINT_USE_DEFAULT_CREDENTIALS_PROVIDER_CONF =
"camel.sink.endpoint.useDefaultCredentialsProvider";
+ public static final String
CAMEL_SINK_AWS2LAMBDA_ENDPOINT_USE_DEFAULT_CREDENTIALS_PROVIDER_DOC = "Set
whether the Lambda client should expect to load credentials through a default
credentials provider or to expect static credentials to be passed in.";
+ public static final Boolean
CAMEL_SINK_AWS2LAMBDA_ENDPOINT_USE_DEFAULT_CREDENTIALS_PROVIDER_DEFAULT = false;
public static final String
CAMEL_SINK_AWS2LAMBDA_ENDPOINT_AWS_LAMBDA_CLIENT_CONF =
"camel.sink.endpoint.awsLambdaClient";
public static final String
CAMEL_SINK_AWS2LAMBDA_ENDPOINT_AWS_LAMBDA_CLIENT_DOC = "To use a existing
configured AwsLambdaClient as client";
public static final String
CAMEL_SINK_AWS2LAMBDA_ENDPOINT_AWS_LAMBDA_CLIENT_DEFAULT = null;
@@ -84,7 +87,7 @@ public class CamelAws2lambdaSinkConnectorConfig
public static final String
CAMEL_SINK_AWS2LAMBDA_COMPONENT_POJO_REQUEST_DOC = "If we want to use a POJO
request as body or not";
public static final Boolean
CAMEL_SINK_AWS2LAMBDA_COMPONENT_POJO_REQUEST_DEFAULT = false;
public static final String CAMEL_SINK_AWS2LAMBDA_COMPONENT_REGION_CONF =
"camel.component.aws2-lambda.region";
- public static final String CAMEL_SINK_AWS2LAMBDA_COMPONENT_REGION_DOC =
"The region in which ECS client needs to work. When using this parameter, the
configuration will expect the lowercase name of the region (for example
ap-east-1) You'll need to use the name Region.EU_WEST_1.id()";
+ public static final String CAMEL_SINK_AWS2LAMBDA_COMPONENT_REGION_DOC =
"The region in which Lambda client needs to work. When using this parameter,
the configuration will expect the lowercase name of the region (for example
ap-east-1) You'll need to use the name Region.EU_WEST_1.id()";
public static final String CAMEL_SINK_AWS2LAMBDA_COMPONENT_REGION_DEFAULT
= null;
public static final String
CAMEL_SINK_AWS2LAMBDA_COMPONENT_TRUST_ALL_CERTIFICATES_CONF =
"camel.component.aws2-lambda.trustAllCertificates";
public static final String
CAMEL_SINK_AWS2LAMBDA_COMPONENT_TRUST_ALL_CERTIFICATES_DOC = "If we want to
trust all certificates in case of overriding the endpoint";
@@ -92,6 +95,9 @@ public class CamelAws2lambdaSinkConnectorConfig
public static final String
CAMEL_SINK_AWS2LAMBDA_COMPONENT_URI_ENDPOINT_OVERRIDE_CONF =
"camel.component.aws2-lambda.uriEndpointOverride";
public static final String
CAMEL_SINK_AWS2LAMBDA_COMPONENT_URI_ENDPOINT_OVERRIDE_DOC = "Set the overriding
uri endpoint. This option needs to be used in combination with overrideEndpoint
option";
public static final String
CAMEL_SINK_AWS2LAMBDA_COMPONENT_URI_ENDPOINT_OVERRIDE_DEFAULT = null;
+ public static final String
CAMEL_SINK_AWS2LAMBDA_COMPONENT_USE_DEFAULT_CREDENTIALS_PROVIDER_CONF =
"camel.component.aws2-lambda.useDefaultCredentialsProvider";
+ public static final String
CAMEL_SINK_AWS2LAMBDA_COMPONENT_USE_DEFAULT_CREDENTIALS_PROVIDER_DOC = "Set
whether the Lambda client should expect to load credentials through a default
credentials provider or to expect static credentials to be passed in.";
+ public static final Boolean
CAMEL_SINK_AWS2LAMBDA_COMPONENT_USE_DEFAULT_CREDENTIALS_PROVIDER_DEFAULT =
false;
public static final String
CAMEL_SINK_AWS2LAMBDA_COMPONENT_AUTOWIRED_ENABLED_CONF =
"camel.component.aws2-lambda.autowiredEnabled";
public static final String
CAMEL_SINK_AWS2LAMBDA_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_AWS2LAMBDA_COMPONENT_AUTOWIRED_ENABLED_DEFAULT = true;
@@ -134,6 +140,7 @@ public class CamelAws2lambdaSinkConnectorConfig
conf.define(CAMEL_SINK_AWS2LAMBDA_ENDPOINT_REGION_CONF,
ConfigDef.Type.STRING, CAMEL_SINK_AWS2LAMBDA_ENDPOINT_REGION_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_AWS2LAMBDA_ENDPOINT_REGION_DOC);
conf.define(CAMEL_SINK_AWS2LAMBDA_ENDPOINT_TRUST_ALL_CERTIFICATES_CONF,
ConfigDef.Type.BOOLEAN,
CAMEL_SINK_AWS2LAMBDA_ENDPOINT_TRUST_ALL_CERTIFICATES_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SINK_AWS2LAMBDA_ENDPOINT_TRUST_ALL_CERTIFICATES_DOC);
conf.define(CAMEL_SINK_AWS2LAMBDA_ENDPOINT_URI_ENDPOINT_OVERRIDE_CONF,
ConfigDef.Type.STRING,
CAMEL_SINK_AWS2LAMBDA_ENDPOINT_URI_ENDPOINT_OVERRIDE_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SINK_AWS2LAMBDA_ENDPOINT_URI_ENDPOINT_OVERRIDE_DOC);
+
conf.define(CAMEL_SINK_AWS2LAMBDA_ENDPOINT_USE_DEFAULT_CREDENTIALS_PROVIDER_CONF,
ConfigDef.Type.BOOLEAN,
CAMEL_SINK_AWS2LAMBDA_ENDPOINT_USE_DEFAULT_CREDENTIALS_PROVIDER_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SINK_AWS2LAMBDA_ENDPOINT_USE_DEFAULT_CREDENTIALS_PROVIDER_DOC);
conf.define(CAMEL_SINK_AWS2LAMBDA_ENDPOINT_AWS_LAMBDA_CLIENT_CONF,
ConfigDef.Type.STRING,
CAMEL_SINK_AWS2LAMBDA_ENDPOINT_AWS_LAMBDA_CLIENT_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SINK_AWS2LAMBDA_ENDPOINT_AWS_LAMBDA_CLIENT_DOC);
conf.define(CAMEL_SINK_AWS2LAMBDA_ENDPOINT_PROXY_HOST_CONF,
ConfigDef.Type.STRING, CAMEL_SINK_AWS2LAMBDA_ENDPOINT_PROXY_HOST_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_AWS2LAMBDA_ENDPOINT_PROXY_HOST_DOC);
conf.define(CAMEL_SINK_AWS2LAMBDA_ENDPOINT_PROXY_PORT_CONF,
ConfigDef.Type.STRING, CAMEL_SINK_AWS2LAMBDA_ENDPOINT_PROXY_PORT_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_AWS2LAMBDA_ENDPOINT_PROXY_PORT_DOC);
@@ -148,6 +155,7 @@ public class CamelAws2lambdaSinkConnectorConfig
conf.define(CAMEL_SINK_AWS2LAMBDA_COMPONENT_REGION_CONF,
ConfigDef.Type.STRING, CAMEL_SINK_AWS2LAMBDA_COMPONENT_REGION_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_AWS2LAMBDA_COMPONENT_REGION_DOC);
conf.define(CAMEL_SINK_AWS2LAMBDA_COMPONENT_TRUST_ALL_CERTIFICATES_CONF,
ConfigDef.Type.BOOLEAN,
CAMEL_SINK_AWS2LAMBDA_COMPONENT_TRUST_ALL_CERTIFICATES_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SINK_AWS2LAMBDA_COMPONENT_TRUST_ALL_CERTIFICATES_DOC);
conf.define(CAMEL_SINK_AWS2LAMBDA_COMPONENT_URI_ENDPOINT_OVERRIDE_CONF,
ConfigDef.Type.STRING,
CAMEL_SINK_AWS2LAMBDA_COMPONENT_URI_ENDPOINT_OVERRIDE_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SINK_AWS2LAMBDA_COMPONENT_URI_ENDPOINT_OVERRIDE_DOC);
+
conf.define(CAMEL_SINK_AWS2LAMBDA_COMPONENT_USE_DEFAULT_CREDENTIALS_PROVIDER_CONF,
ConfigDef.Type.BOOLEAN,
CAMEL_SINK_AWS2LAMBDA_COMPONENT_USE_DEFAULT_CREDENTIALS_PROVIDER_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SINK_AWS2LAMBDA_COMPONENT_USE_DEFAULT_CREDENTIALS_PROVIDER_DOC);
conf.define(CAMEL_SINK_AWS2LAMBDA_COMPONENT_AUTOWIRED_ENABLED_CONF,
ConfigDef.Type.BOOLEAN,
CAMEL_SINK_AWS2LAMBDA_COMPONENT_AUTOWIRED_ENABLED_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SINK_AWS2LAMBDA_COMPONENT_AUTOWIRED_ENABLED_DOC);
conf.define(CAMEL_SINK_AWS2LAMBDA_COMPONENT_AWS_LAMBDA_CLIENT_CONF,
ConfigDef.Type.STRING,
CAMEL_SINK_AWS2LAMBDA_COMPONENT_AWS_LAMBDA_CLIENT_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SINK_AWS2LAMBDA_COMPONENT_AWS_LAMBDA_CLIENT_DOC);
conf.define(CAMEL_SINK_AWS2LAMBDA_COMPONENT_PROXY_HOST_CONF,
ConfigDef.Type.STRING, CAMEL_SINK_AWS2LAMBDA_COMPONENT_PROXY_HOST_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_AWS2LAMBDA_COMPONENT_PROXY_HOST_DOC);
diff --git
a/connectors/camel-mongodb-kafka-connector/src/generated/resources/camel-mongodb-sink.json
b/connectors/camel-mongodb-kafka-connector/src/generated/resources/camel-mongodb-sink.json
index d100e07..7ac614f 100644
---
a/connectors/camel-mongodb-kafka-connector/src/generated/resources/camel-mongodb-sink.json
+++
b/connectors/camel-mongodb-kafka-connector/src/generated/resources/camel-mongodb-sink.json
@@ -40,6 +40,12 @@
"priority": "MEDIUM",
"required": "false"
},
+ "camel.sink.endpoint.hosts": {
+ "name": "camel.sink.endpoint.hosts",
+ "description": "Host address of mongodb server in
host:port format. It's possible also use more than one address, as comma
separated list of hosts: host1:port1,host2:port2. If hosts parameter is
specified, provided connectionBean is ignored.",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
"camel.sink.endpoint.mongoConnection": {
"name": "camel.sink.endpoint.mongoConnection",
"description": "Sets the connection bean used as a
client for connecting to a database.",
@@ -143,6 +149,18 @@
"priority": "MEDIUM",
"required": "false"
},
+ "camel.sink.endpoint.password": {
+ "name": "camel.sink.endpoint.password",
+ "description": "User password for mongodb connection",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
+ "camel.sink.endpoint.username": {
+ "name": "camel.sink.endpoint.username",
+ "description": "Username for mongodb connection",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
"camel.sink.endpoint.persistentId": {
"name": "camel.sink.endpoint.persistentId",
"description": "One tail tracking collection can host
many trackers for several tailable consumers. To keep them separate, each
tracker should have its own unique persistentId.",
diff --git
a/connectors/camel-mongodb-kafka-connector/src/generated/resources/camel-mongodb-source.json
b/connectors/camel-mongodb-kafka-connector/src/generated/resources/camel-mongodb-source.json
index 0c7eee6..b8abc47 100644
---
a/connectors/camel-mongodb-kafka-connector/src/generated/resources/camel-mongodb-source.json
+++
b/connectors/camel-mongodb-kafka-connector/src/generated/resources/camel-mongodb-source.json
@@ -40,6 +40,12 @@
"priority": "MEDIUM",
"required": "false"
},
+ "camel.source.endpoint.hosts": {
+ "name": "camel.source.endpoint.hosts",
+ "description": "Host address of mongodb server in
host:port format. It's possible also use more than one address, as comma
separated list of hosts: host1:port1,host2:port2. If hosts parameter is
specified, provided connectionBean is ignored.",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
"camel.source.endpoint.mongoConnection": {
"name": "camel.source.endpoint.mongoConnection",
"description": "Sets the connection bean used as a
client for connecting to a database.",
@@ -166,6 +172,18 @@
"priority": "MEDIUM",
"required": "false"
},
+ "camel.source.endpoint.password": {
+ "name": "camel.source.endpoint.password",
+ "description": "User password for mongodb connection",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
+ "camel.source.endpoint.username": {
+ "name": "camel.source.endpoint.username",
+ "description": "Username for mongodb connection",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
"camel.source.endpoint.persistentId": {
"name": "camel.source.endpoint.persistentId",
"description": "One tail tracking collection can host
many trackers for several tailable consumers. To keep them separate, each
tracker should have its own unique persistentId.",
diff --git
a/connectors/camel-mongodb-kafka-connector/src/main/docs/camel-mongodb-kafka-sink-connector.adoc
b/connectors/camel-mongodb-kafka-connector/src/main/docs/camel-mongodb-kafka-sink-connector.adoc
index 3d84569..63599c7 100644
---
a/connectors/camel-mongodb-kafka-connector/src/main/docs/camel-mongodb-kafka-sink-connector.adoc
+++
b/connectors/camel-mongodb-kafka-connector/src/main/docs/camel-mongodb-kafka-sink-connector.adoc
@@ -24,7 +24,7 @@
connector.class=org.apache.camel.kafkaconnector.mongodb.CamelMongodbSinkConnecto
----
-The camel-mongodb sink connector supports 24 options, which are listed below.
+The camel-mongodb sink connector supports 27 options, which are listed below.
@@ -36,6 +36,7 @@ The camel-mongodb sink connector supports 24 options, which
are listed below.
| *camel.sink.endpoint.collectionIndex* | Sets the collection index (JSON
FORMAT : { field1 : order1, field2 : order2}) | null | false | MEDIUM
| *camel.sink.endpoint.createCollection* | Create collection during
initialisation if it doesn't exist. Default is true. | true | false | MEDIUM
| *camel.sink.endpoint.database* | Sets the name of the MongoDB database to
target | null | false | MEDIUM
+| *camel.sink.endpoint.hosts* | Host address of mongodb server in host:port
format. It's possible also use more than one address, as comma separated list
of hosts: host1:port1,host2:port2. If hosts parameter is specified, provided
connectionBean is ignored. | null | false | MEDIUM
| *camel.sink.endpoint.mongoConnection* | Sets the connection bean used as a
client for connecting to a database. | null | false | MEDIUM
| *camel.sink.endpoint.operation* | Sets the operation this endpoint will
execute against MongoDB. One of: [findById] [findOneByQuery] [findAll]
[findDistinct] [insert] [save] [update] [remove] [bulkWrite] [aggregate]
[getDbStats] [getColStats] [count] [command] | null | false | MEDIUM
| *camel.sink.endpoint.outputType* | Convert the output of the producer to the
selected type : DocumentList Document or MongoIterable. DocumentList or
MongoIterable applies to findAll and aggregate. Document applies to all other
operations. One of: [DocumentList] [Document] [MongoIterable] | null | false |
MEDIUM
@@ -46,6 +47,8 @@ The camel-mongodb sink connector supports 24 options, which
are listed below.
| *camel.sink.endpoint.writeConcern* | Configure the connection bean with the
level of acknowledgment requested from MongoDB for write operations to a
standalone mongod, replicaset or cluster. Possible values are ACKNOWLEDGED, W1,
W2, W3, UNACKNOWLEDGED, JOURNALED or MAJORITY. One of: [ACKNOWLEDGED] [W1] [W2]
[W3] [UNACKNOWLEDGED] [JOURNALED] [MAJORITY] | "ACKNOWLEDGED" | false | MEDIUM
| *camel.sink.endpoint.writeResultAsHeader* | In write operations, it
determines whether instead of returning WriteResult as the body of the OUT
message, we transfer the IN message to the OUT and attach the WriteResult as a
header. | false | false | MEDIUM
| *camel.sink.endpoint.streamFilter* | Filter condition for change streams
consumer. | null | false | MEDIUM
+| *camel.sink.endpoint.password* | User password for mongodb connection | null
| false | MEDIUM
+| *camel.sink.endpoint.username* | Username for mongodb connection | null |
false | MEDIUM
| *camel.sink.endpoint.persistentId* | One tail tracking collection can host
many trackers for several tailable consumers. To keep them separate, each
tracker should have its own unique persistentId. | null | false | MEDIUM
| *camel.sink.endpoint.persistentTailTracking* | Enable persistent tail
tracking, which is a mechanism to keep track of the last consumed message
across system restarts. The next time the system is up, the endpoint will
recover the cursor from the point where it last stopped slurping records. |
false | false | MEDIUM
| *camel.sink.endpoint.tailTrackCollection* | Collection where tail tracking
information will be persisted. If not specified,
MongoDbTailTrackingConfig#DEFAULT_COLLECTION will be used by default. | null |
false | MEDIUM
diff --git
a/connectors/camel-mongodb-kafka-connector/src/main/docs/camel-mongodb-kafka-source-connector.adoc
b/connectors/camel-mongodb-kafka-connector/src/main/docs/camel-mongodb-kafka-source-connector.adoc
index c5feba9..3670697 100644
---
a/connectors/camel-mongodb-kafka-connector/src/main/docs/camel-mongodb-kafka-source-connector.adoc
+++
b/connectors/camel-mongodb-kafka-connector/src/main/docs/camel-mongodb-kafka-source-connector.adoc
@@ -24,7 +24,7 @@
connector.class=org.apache.camel.kafkaconnector.mongodb.CamelMongodbSourceConnec
----
-The camel-mongodb source connector supports 27 options, which are listed below.
+The camel-mongodb source connector supports 30 options, which are listed below.
@@ -36,6 +36,7 @@ The camel-mongodb source connector supports 27 options, which
are listed below.
| *camel.source.endpoint.collectionIndex* | Sets the collection index (JSON
FORMAT : { field1 : order1, field2 : order2}) | null | false | MEDIUM
| *camel.source.endpoint.createCollection* | Create collection during
initialisation if it doesn't exist. Default is true. | true | false | MEDIUM
| *camel.source.endpoint.database* | Sets the name of the MongoDB database to
target | null | false | MEDIUM
+| *camel.source.endpoint.hosts* | Host address of mongodb server in host:port
format. It's possible also use more than one address, as comma separated list
of hosts: host1:port1,host2:port2. If hosts parameter is specified, provided
connectionBean is ignored. | null | false | MEDIUM
| *camel.source.endpoint.mongoConnection* | Sets the connection bean used as a
client for connecting to a database. | null | false | MEDIUM
| *camel.source.endpoint.operation* | Sets the operation this endpoint will
execute against MongoDB. One of: [findById] [findOneByQuery] [findAll]
[findDistinct] [insert] [save] [update] [remove] [bulkWrite] [aggregate]
[getDbStats] [getColStats] [count] [command] | null | false | MEDIUM
| *camel.source.endpoint.outputType* | Convert the output of the producer to
the selected type : DocumentList Document or MongoIterable. DocumentList or
MongoIterable applies to findAll and aggregate. Document applies to all other
operations. One of: [DocumentList] [Document] [MongoIterable] | null | false |
MEDIUM
@@ -49,6 +50,8 @@ The camel-mongodb source connector supports 27 options, which
are listed below.
| *camel.source.endpoint.writeConcern* | Configure the connection bean with
the level of acknowledgment requested from MongoDB for write operations to a
standalone mongod, replicaset or cluster. Possible values are ACKNOWLEDGED, W1,
W2, W3, UNACKNOWLEDGED, JOURNALED or MAJORITY. One of: [ACKNOWLEDGED] [W1] [W2]
[W3] [UNACKNOWLEDGED] [JOURNALED] [MAJORITY] | "ACKNOWLEDGED" | false | MEDIUM
| *camel.source.endpoint.writeResultAsHeader* | In write operations, it
determines whether instead of returning WriteResult as the body of the OUT
message, we transfer the IN message to the OUT and attach the WriteResult as a
header. | false | false | MEDIUM
| *camel.source.endpoint.streamFilter* | Filter condition for change streams
consumer. | null | false | MEDIUM
+| *camel.source.endpoint.password* | User password for mongodb connection |
null | false | MEDIUM
+| *camel.source.endpoint.username* | Username for mongodb connection | null |
false | MEDIUM
| *camel.source.endpoint.persistentId* | One tail tracking collection can host
many trackers for several tailable consumers. To keep them separate, each
tracker should have its own unique persistentId. | null | false | MEDIUM
| *camel.source.endpoint.persistentTailTracking* | Enable persistent tail
tracking, which is a mechanism to keep track of the last consumed message
across system restarts. The next time the system is up, the endpoint will
recover the cursor from the point where it last stopped slurping records. |
false | false | MEDIUM
| *camel.source.endpoint.tailTrackCollection* | Collection where tail tracking
information will be persisted. If not specified,
MongoDbTailTrackingConfig#DEFAULT_COLLECTION will be used by default. | null |
false | MEDIUM
diff --git
a/connectors/camel-mongodb-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/mongodb/CamelMongodbSinkConnectorConfig.java
b/connectors/camel-mongodb-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/mongodb/CamelMongodbSinkConnectorConfig.java
index cf36a28..ff3e1b3 100644
---
a/connectors/camel-mongodb-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/mongodb/CamelMongodbSinkConnectorConfig.java
+++
b/connectors/camel-mongodb-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/mongodb/CamelMongodbSinkConnectorConfig.java
@@ -39,6 +39,9 @@ public class CamelMongodbSinkConnectorConfig extends
CamelSinkConnectorConfig {
public static final String CAMEL_SINK_MONGODB_ENDPOINT_DATABASE_CONF =
"camel.sink.endpoint.database";
public static final String CAMEL_SINK_MONGODB_ENDPOINT_DATABASE_DOC =
"Sets the name of the MongoDB database to target";
public static final String CAMEL_SINK_MONGODB_ENDPOINT_DATABASE_DEFAULT =
null;
+ public static final String CAMEL_SINK_MONGODB_ENDPOINT_HOSTS_CONF =
"camel.sink.endpoint.hosts";
+ public static final String CAMEL_SINK_MONGODB_ENDPOINT_HOSTS_DOC = "Host
address of mongodb server in host:port format. It's possible also use more than
one address, as comma separated list of hosts: host1:port1,host2:port2. If
hosts parameter is specified, provided connectionBean is ignored.";
+ public static final String CAMEL_SINK_MONGODB_ENDPOINT_HOSTS_DEFAULT =
null;
public static final String
CAMEL_SINK_MONGODB_ENDPOINT_MONGO_CONNECTION_CONF =
"camel.sink.endpoint.mongoConnection";
public static final String
CAMEL_SINK_MONGODB_ENDPOINT_MONGO_CONNECTION_DOC = "Sets the connection bean
used as a client for connecting to a database.";
public static final String
CAMEL_SINK_MONGODB_ENDPOINT_MONGO_CONNECTION_DEFAULT = null;
@@ -69,6 +72,12 @@ public class CamelMongodbSinkConnectorConfig extends
CamelSinkConnectorConfig {
public static final String CAMEL_SINK_MONGODB_ENDPOINT_STREAM_FILTER_CONF
= "camel.sink.endpoint.streamFilter";
public static final String CAMEL_SINK_MONGODB_ENDPOINT_STREAM_FILTER_DOC =
"Filter condition for change streams consumer.";
public static final String
CAMEL_SINK_MONGODB_ENDPOINT_STREAM_FILTER_DEFAULT = null;
+ public static final String CAMEL_SINK_MONGODB_ENDPOINT_PASSWORD_CONF =
"camel.sink.endpoint.password";
+ public static final String CAMEL_SINK_MONGODB_ENDPOINT_PASSWORD_DOC =
"User password for mongodb connection";
+ public static final String CAMEL_SINK_MONGODB_ENDPOINT_PASSWORD_DEFAULT =
null;
+ public static final String CAMEL_SINK_MONGODB_ENDPOINT_USERNAME_CONF =
"camel.sink.endpoint.username";
+ public static final String CAMEL_SINK_MONGODB_ENDPOINT_USERNAME_DOC =
"Username for mongodb connection";
+ public static final String CAMEL_SINK_MONGODB_ENDPOINT_USERNAME_DEFAULT =
null;
public static final String CAMEL_SINK_MONGODB_ENDPOINT_PERSISTENT_ID_CONF
= "camel.sink.endpoint.persistentId";
public static final String CAMEL_SINK_MONGODB_ENDPOINT_PERSISTENT_ID_DOC =
"One tail tracking collection can host many trackers for several tailable
consumers. To keep them separate, each tracker should have its own unique
persistentId.";
public static final String
CAMEL_SINK_MONGODB_ENDPOINT_PERSISTENT_ID_DEFAULT = null;
@@ -114,6 +123,7 @@ public class CamelMongodbSinkConnectorConfig extends
CamelSinkConnectorConfig {
conf.define(CAMEL_SINK_MONGODB_ENDPOINT_COLLECTION_INDEX_CONF,
ConfigDef.Type.STRING, CAMEL_SINK_MONGODB_ENDPOINT_COLLECTION_INDEX_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_MONGODB_ENDPOINT_COLLECTION_INDEX_DOC);
conf.define(CAMEL_SINK_MONGODB_ENDPOINT_CREATE_COLLECTION_CONF,
ConfigDef.Type.BOOLEAN, CAMEL_SINK_MONGODB_ENDPOINT_CREATE_COLLECTION_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_MONGODB_ENDPOINT_CREATE_COLLECTION_DOC);
conf.define(CAMEL_SINK_MONGODB_ENDPOINT_DATABASE_CONF,
ConfigDef.Type.STRING, CAMEL_SINK_MONGODB_ENDPOINT_DATABASE_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_MONGODB_ENDPOINT_DATABASE_DOC);
+ conf.define(CAMEL_SINK_MONGODB_ENDPOINT_HOSTS_CONF,
ConfigDef.Type.STRING, CAMEL_SINK_MONGODB_ENDPOINT_HOSTS_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_MONGODB_ENDPOINT_HOSTS_DOC);
conf.define(CAMEL_SINK_MONGODB_ENDPOINT_MONGO_CONNECTION_CONF,
ConfigDef.Type.STRING, CAMEL_SINK_MONGODB_ENDPOINT_MONGO_CONNECTION_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_MONGODB_ENDPOINT_MONGO_CONNECTION_DOC);
conf.define(CAMEL_SINK_MONGODB_ENDPOINT_OPERATION_CONF,
ConfigDef.Type.STRING, CAMEL_SINK_MONGODB_ENDPOINT_OPERATION_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_MONGODB_ENDPOINT_OPERATION_DOC);
conf.define(CAMEL_SINK_MONGODB_ENDPOINT_OUTPUT_TYPE_CONF,
ConfigDef.Type.STRING, CAMEL_SINK_MONGODB_ENDPOINT_OUTPUT_TYPE_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_MONGODB_ENDPOINT_OUTPUT_TYPE_DOC);
@@ -124,6 +134,8 @@ public class CamelMongodbSinkConnectorConfig extends
CamelSinkConnectorConfig {
conf.define(CAMEL_SINK_MONGODB_ENDPOINT_WRITE_CONCERN_CONF,
ConfigDef.Type.STRING, CAMEL_SINK_MONGODB_ENDPOINT_WRITE_CONCERN_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_MONGODB_ENDPOINT_WRITE_CONCERN_DOC);
conf.define(CAMEL_SINK_MONGODB_ENDPOINT_WRITE_RESULT_AS_HEADER_CONF,
ConfigDef.Type.BOOLEAN,
CAMEL_SINK_MONGODB_ENDPOINT_WRITE_RESULT_AS_HEADER_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SINK_MONGODB_ENDPOINT_WRITE_RESULT_AS_HEADER_DOC);
conf.define(CAMEL_SINK_MONGODB_ENDPOINT_STREAM_FILTER_CONF,
ConfigDef.Type.STRING, CAMEL_SINK_MONGODB_ENDPOINT_STREAM_FILTER_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_MONGODB_ENDPOINT_STREAM_FILTER_DOC);
+ conf.define(CAMEL_SINK_MONGODB_ENDPOINT_PASSWORD_CONF,
ConfigDef.Type.PASSWORD, CAMEL_SINK_MONGODB_ENDPOINT_PASSWORD_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_MONGODB_ENDPOINT_PASSWORD_DOC);
+ conf.define(CAMEL_SINK_MONGODB_ENDPOINT_USERNAME_CONF,
ConfigDef.Type.PASSWORD, CAMEL_SINK_MONGODB_ENDPOINT_USERNAME_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_MONGODB_ENDPOINT_USERNAME_DOC);
conf.define(CAMEL_SINK_MONGODB_ENDPOINT_PERSISTENT_ID_CONF,
ConfigDef.Type.STRING, CAMEL_SINK_MONGODB_ENDPOINT_PERSISTENT_ID_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_MONGODB_ENDPOINT_PERSISTENT_ID_DOC);
conf.define(CAMEL_SINK_MONGODB_ENDPOINT_PERSISTENT_TAIL_TRACKING_CONF,
ConfigDef.Type.BOOLEAN,
CAMEL_SINK_MONGODB_ENDPOINT_PERSISTENT_TAIL_TRACKING_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SINK_MONGODB_ENDPOINT_PERSISTENT_TAIL_TRACKING_DOC);
conf.define(CAMEL_SINK_MONGODB_ENDPOINT_TAIL_TRACK_COLLECTION_CONF,
ConfigDef.Type.STRING,
CAMEL_SINK_MONGODB_ENDPOINT_TAIL_TRACK_COLLECTION_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SINK_MONGODB_ENDPOINT_TAIL_TRACK_COLLECTION_DOC);
diff --git
a/connectors/camel-mongodb-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/mongodb/CamelMongodbSourceConnectorConfig.java
b/connectors/camel-mongodb-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/mongodb/CamelMongodbSourceConnectorConfig.java
index a8e1b7c..2a140c2 100644
---
a/connectors/camel-mongodb-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/mongodb/CamelMongodbSourceConnectorConfig.java
+++
b/connectors/camel-mongodb-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/mongodb/CamelMongodbSourceConnectorConfig.java
@@ -41,6 +41,9 @@ public class CamelMongodbSourceConnectorConfig
public static final String CAMEL_SOURCE_MONGODB_ENDPOINT_DATABASE_CONF =
"camel.source.endpoint.database";
public static final String CAMEL_SOURCE_MONGODB_ENDPOINT_DATABASE_DOC =
"Sets the name of the MongoDB database to target";
public static final String CAMEL_SOURCE_MONGODB_ENDPOINT_DATABASE_DEFAULT
= null;
+ public static final String CAMEL_SOURCE_MONGODB_ENDPOINT_HOSTS_CONF =
"camel.source.endpoint.hosts";
+ public static final String CAMEL_SOURCE_MONGODB_ENDPOINT_HOSTS_DOC = "Host
address of mongodb server in host:port format. It's possible also use more than
one address, as comma separated list of hosts: host1:port1,host2:port2. If
hosts parameter is specified, provided connectionBean is ignored.";
+ public static final String CAMEL_SOURCE_MONGODB_ENDPOINT_HOSTS_DEFAULT =
null;
public static final String
CAMEL_SOURCE_MONGODB_ENDPOINT_MONGO_CONNECTION_CONF =
"camel.source.endpoint.mongoConnection";
public static final String
CAMEL_SOURCE_MONGODB_ENDPOINT_MONGO_CONNECTION_DOC = "Sets the connection bean
used as a client for connecting to a database.";
public static final String
CAMEL_SOURCE_MONGODB_ENDPOINT_MONGO_CONNECTION_DEFAULT = null;
@@ -80,6 +83,12 @@ public class CamelMongodbSourceConnectorConfig
public static final String
CAMEL_SOURCE_MONGODB_ENDPOINT_STREAM_FILTER_CONF =
"camel.source.endpoint.streamFilter";
public static final String CAMEL_SOURCE_MONGODB_ENDPOINT_STREAM_FILTER_DOC
= "Filter condition for change streams consumer.";
public static final String
CAMEL_SOURCE_MONGODB_ENDPOINT_STREAM_FILTER_DEFAULT = null;
+ public static final String CAMEL_SOURCE_MONGODB_ENDPOINT_PASSWORD_CONF =
"camel.source.endpoint.password";
+ public static final String CAMEL_SOURCE_MONGODB_ENDPOINT_PASSWORD_DOC =
"User password for mongodb connection";
+ public static final String CAMEL_SOURCE_MONGODB_ENDPOINT_PASSWORD_DEFAULT
= null;
+ public static final String CAMEL_SOURCE_MONGODB_ENDPOINT_USERNAME_CONF =
"camel.source.endpoint.username";
+ public static final String CAMEL_SOURCE_MONGODB_ENDPOINT_USERNAME_DOC =
"Username for mongodb connection";
+ public static final String CAMEL_SOURCE_MONGODB_ENDPOINT_USERNAME_DEFAULT
= null;
public static final String
CAMEL_SOURCE_MONGODB_ENDPOINT_PERSISTENT_ID_CONF =
"camel.source.endpoint.persistentId";
public static final String CAMEL_SOURCE_MONGODB_ENDPOINT_PERSISTENT_ID_DOC
= "One tail tracking collection can host many trackers for several tailable
consumers. To keep them separate, each tracker should have its own unique
persistentId.";
public static final String
CAMEL_SOURCE_MONGODB_ENDPOINT_PERSISTENT_ID_DEFAULT = null;
@@ -125,6 +134,7 @@ public class CamelMongodbSourceConnectorConfig
conf.define(CAMEL_SOURCE_MONGODB_ENDPOINT_COLLECTION_INDEX_CONF,
ConfigDef.Type.STRING, CAMEL_SOURCE_MONGODB_ENDPOINT_COLLECTION_INDEX_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SOURCE_MONGODB_ENDPOINT_COLLECTION_INDEX_DOC);
conf.define(CAMEL_SOURCE_MONGODB_ENDPOINT_CREATE_COLLECTION_CONF,
ConfigDef.Type.BOOLEAN,
CAMEL_SOURCE_MONGODB_ENDPOINT_CREATE_COLLECTION_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SOURCE_MONGODB_ENDPOINT_CREATE_COLLECTION_DOC);
conf.define(CAMEL_SOURCE_MONGODB_ENDPOINT_DATABASE_CONF,
ConfigDef.Type.STRING, CAMEL_SOURCE_MONGODB_ENDPOINT_DATABASE_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_MONGODB_ENDPOINT_DATABASE_DOC);
+ conf.define(CAMEL_SOURCE_MONGODB_ENDPOINT_HOSTS_CONF,
ConfigDef.Type.STRING, CAMEL_SOURCE_MONGODB_ENDPOINT_HOSTS_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_MONGODB_ENDPOINT_HOSTS_DOC);
conf.define(CAMEL_SOURCE_MONGODB_ENDPOINT_MONGO_CONNECTION_CONF,
ConfigDef.Type.STRING, CAMEL_SOURCE_MONGODB_ENDPOINT_MONGO_CONNECTION_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SOURCE_MONGODB_ENDPOINT_MONGO_CONNECTION_DOC);
conf.define(CAMEL_SOURCE_MONGODB_ENDPOINT_OPERATION_CONF,
ConfigDef.Type.STRING, CAMEL_SOURCE_MONGODB_ENDPOINT_OPERATION_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_MONGODB_ENDPOINT_OPERATION_DOC);
conf.define(CAMEL_SOURCE_MONGODB_ENDPOINT_OUTPUT_TYPE_CONF,
ConfigDef.Type.STRING, CAMEL_SOURCE_MONGODB_ENDPOINT_OUTPUT_TYPE_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_MONGODB_ENDPOINT_OUTPUT_TYPE_DOC);
@@ -138,6 +148,8 @@ public class CamelMongodbSourceConnectorConfig
conf.define(CAMEL_SOURCE_MONGODB_ENDPOINT_WRITE_CONCERN_CONF,
ConfigDef.Type.STRING, CAMEL_SOURCE_MONGODB_ENDPOINT_WRITE_CONCERN_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_MONGODB_ENDPOINT_WRITE_CONCERN_DOC);
conf.define(CAMEL_SOURCE_MONGODB_ENDPOINT_WRITE_RESULT_AS_HEADER_CONF,
ConfigDef.Type.BOOLEAN,
CAMEL_SOURCE_MONGODB_ENDPOINT_WRITE_RESULT_AS_HEADER_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SOURCE_MONGODB_ENDPOINT_WRITE_RESULT_AS_HEADER_DOC);
conf.define(CAMEL_SOURCE_MONGODB_ENDPOINT_STREAM_FILTER_CONF,
ConfigDef.Type.STRING, CAMEL_SOURCE_MONGODB_ENDPOINT_STREAM_FILTER_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_MONGODB_ENDPOINT_STREAM_FILTER_DOC);
+ conf.define(CAMEL_SOURCE_MONGODB_ENDPOINT_PASSWORD_CONF,
ConfigDef.Type.PASSWORD, CAMEL_SOURCE_MONGODB_ENDPOINT_PASSWORD_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_MONGODB_ENDPOINT_PASSWORD_DOC);
+ conf.define(CAMEL_SOURCE_MONGODB_ENDPOINT_USERNAME_CONF,
ConfigDef.Type.PASSWORD, CAMEL_SOURCE_MONGODB_ENDPOINT_USERNAME_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_MONGODB_ENDPOINT_USERNAME_DOC);
conf.define(CAMEL_SOURCE_MONGODB_ENDPOINT_PERSISTENT_ID_CONF,
ConfigDef.Type.STRING, CAMEL_SOURCE_MONGODB_ENDPOINT_PERSISTENT_ID_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_MONGODB_ENDPOINT_PERSISTENT_ID_DOC);
conf.define(CAMEL_SOURCE_MONGODB_ENDPOINT_PERSISTENT_TAIL_TRACKING_CONF,
ConfigDef.Type.BOOLEAN,
CAMEL_SOURCE_MONGODB_ENDPOINT_PERSISTENT_TAIL_TRACKING_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SOURCE_MONGODB_ENDPOINT_PERSISTENT_TAIL_TRACKING_DOC);
conf.define(CAMEL_SOURCE_MONGODB_ENDPOINT_TAIL_TRACK_COLLECTION_CONF,
ConfigDef.Type.STRING,
CAMEL_SOURCE_MONGODB_ENDPOINT_TAIL_TRACK_COLLECTION_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SOURCE_MONGODB_ENDPOINT_TAIL_TRACK_COLLECTION_DOC);
diff --git
a/docs/modules/ROOT/pages/connectors/camel-aws2-cw-kafka-sink-connector.adoc
b/docs/modules/ROOT/pages/connectors/camel-aws2-cw-kafka-sink-connector.adoc
index 4daf037..4d4ef6c 100644
--- a/docs/modules/ROOT/pages/connectors/camel-aws2-cw-kafka-sink-connector.adoc
+++ b/docs/modules/ROOT/pages/connectors/camel-aws2-cw-kafka-sink-connector.adoc
@@ -39,7 +39,7 @@ The camel-aws2-cw sink connector supports 35 options, which
are listed below.
| *camel.sink.endpoint.proxyHost* | To define a proxy host when instantiating
the CW client | null | false | MEDIUM
| *camel.sink.endpoint.proxyPort* | To define a proxy port when instantiating
the CW client | null | false | MEDIUM
| *camel.sink.endpoint.proxyProtocol* | To define a proxy protocol when
instantiating the CW client One of: [HTTP] [HTTPS] | "HTTPS" | false | MEDIUM
-| *camel.sink.endpoint.region* | The region in which EKS client needs to work.
When using this parameter, the configuration will expect the lowercase name of
the region (for example ap-east-1) You'll need to use the name
Region.EU_WEST_1.id() | null | false | MEDIUM
+| *camel.sink.endpoint.region* | The region in which CW client needs to work.
When using this parameter, the configuration will expect the lowercase name of
the region (for example ap-east-1) You'll need to use the name
Region.EU_WEST_1.id() | null | false | MEDIUM
| *camel.sink.endpoint.timestamp* | The metric timestamp | null | false |
MEDIUM
| *camel.sink.endpoint.trustAllCertificates* | If we want to trust all
certificates in case of overriding the endpoint | false | false | MEDIUM
| *camel.sink.endpoint.unit* | The metric unit | null | false | MEDIUM
@@ -56,7 +56,7 @@ The camel-aws2-cw sink connector supports 35 options, which
are listed below.
| *camel.component.aws2-cw.proxyHost* | To define a proxy host when
instantiating the CW client | null | false | MEDIUM
| *camel.component.aws2-cw.proxyPort* | To define a proxy port when
instantiating the CW client | null | false | MEDIUM
| *camel.component.aws2-cw.proxyProtocol* | To define a proxy protocol when
instantiating the CW client One of: [HTTP] [HTTPS] | "HTTPS" | false | MEDIUM
-| *camel.component.aws2-cw.region* | The region in which EKS client needs to
work. When using this parameter, the configuration will expect the lowercase
name of the region (for example ap-east-1) You'll need to use the name
Region.EU_WEST_1.id() | null | false | MEDIUM
+| *camel.component.aws2-cw.region* | The region in which CW client needs to
work. When using this parameter, the configuration will expect the lowercase
name of the region (for example ap-east-1) You'll need to use the name
Region.EU_WEST_1.id() | null | false | MEDIUM
| *camel.component.aws2-cw.timestamp* | The metric timestamp | null | false |
MEDIUM
| *camel.component.aws2-cw.trustAllCertificates* | If we want to trust all
certificates in case of overriding the endpoint | false | false | MEDIUM
| *camel.component.aws2-cw.unit* | The metric unit | null | false | MEDIUM
diff --git
a/docs/modules/ROOT/pages/connectors/camel-aws2-kms-kafka-sink-connector.adoc
b/docs/modules/ROOT/pages/connectors/camel-aws2-kms-kafka-sink-connector.adoc
index 7ecc13d..23e0ecf 100644
---
a/docs/modules/ROOT/pages/connectors/camel-aws2-kms-kafka-sink-connector.adoc
+++
b/docs/modules/ROOT/pages/connectors/camel-aws2-kms-kafka-sink-connector.adoc
@@ -24,7 +24,7 @@
connector.class=org.apache.camel.kafkaconnector.aws2kms.CamelAws2kmsSinkConnecto
----
-The camel-aws2-kms sink connector supports 29 options, which are listed below.
+The camel-aws2-kms sink connector supports 31 options, which are listed below.
@@ -43,6 +43,7 @@ The camel-aws2-kms sink connector supports 29 options, which
are listed below.
| *camel.sink.endpoint.region* | The region in which EKS client needs to work.
When using this parameter, the configuration will expect the lowercase name of
the region (for example ap-east-1) You'll need to use the name
Region.EU_WEST_1.id() | null | false | MEDIUM
| *camel.sink.endpoint.trustAllCertificates* | If we want to trust all
certificates in case of overriding the endpoint | false | false | MEDIUM
| *camel.sink.endpoint.uriEndpointOverride* | Set the overriding uri endpoint.
This option needs to be used in combination with overrideEndpoint option | null
| false | MEDIUM
+| *camel.sink.endpoint.useDefaultCredentialsProvider* | Set whether the KMS
client should expect to load credentials through a default credentials provider
or to expect static credentials to be passed in. | false | false | MEDIUM
| *camel.sink.endpoint.accessKey* | Amazon AWS Access Key | null | false |
MEDIUM
| *camel.sink.endpoint.secretKey* | Amazon AWS Secret Key | null | false |
MEDIUM
| *camel.component.aws2-kms.configuration* | Component configuration | null |
false | MEDIUM
@@ -57,6 +58,7 @@ The camel-aws2-kms sink connector supports 29 options, which
are listed below.
| *camel.component.aws2-kms.region* | The region in which EKS client needs to
work. When using this parameter, the configuration will expect the lowercase
name of the region (for example ap-east-1) You'll need to use the name
Region.EU_WEST_1.id() | null | false | MEDIUM
| *camel.component.aws2-kms.trustAllCertificates* | If we want to trust all
certificates in case of overriding the endpoint | false | false | MEDIUM
| *camel.component.aws2-kms.uriEndpointOverride* | Set the overriding uri
endpoint. This option needs to be used in combination with overrideEndpoint
option | null | false | MEDIUM
+| *camel.component.aws2-kms.useDefaultCredentials Provider* | Set whether the
KMS client should expect to load credentials through a default credentials
provider or to expect static credentials to be passed in. | false | false |
MEDIUM
| *camel.component.aws2-kms.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.aws2-kms.accessKey* | Amazon AWS Access Key | null | false
| MEDIUM
| *camel.component.aws2-kms.secretKey* | Amazon AWS Secret Key | null | false
| MEDIUM
diff --git
a/docs/modules/ROOT/pages/connectors/camel-aws2-lambda-kafka-sink-connector.adoc
b/docs/modules/ROOT/pages/connectors/camel-aws2-lambda-kafka-sink-connector.adoc
index 703ff97..1c39c89 100644
---
a/docs/modules/ROOT/pages/connectors/camel-aws2-lambda-kafka-sink-connector.adoc
+++
b/docs/modules/ROOT/pages/connectors/camel-aws2-lambda-kafka-sink-connector.adoc
@@ -24,7 +24,7 @@
connector.class=org.apache.camel.kafkaconnector.aws2lambda.CamelAws2lambdaSinkCo
----
-The camel-aws2-lambda sink connector supports 29 options, which are listed
below.
+The camel-aws2-lambda sink connector supports 31 options, which are listed
below.
@@ -36,9 +36,10 @@ The camel-aws2-lambda sink connector supports 29 options,
which are listed below
| *camel.sink.endpoint.operation* | The operation to perform. It can be
listFunctions, getFunction, createFunction, deleteFunction or invokeFunction
One of: [listFunctions] [getFunction] [createAlias] [deleteAlias] [getAlias]
[listAliases] [createFunction] [deleteFunction] [invokeFunction]
[updateFunction] [createEventSourceMapping] [deleteEventSourceMapping]
[listEventSourceMapping] [listTags] [tagResource] [untagResource]
[publishVersion] [listVersions] | "invokeFunction" | false | MEDIUM
| *camel.sink.endpoint.overrideEndpoint* | Set the need for overidding the
endpoint. This option needs to be used in combination with uriEndpointOverride
option | false | false | MEDIUM
| *camel.sink.endpoint.pojoRequest* | If we want to use a POJO request as body
or not | false | false | MEDIUM
-| *camel.sink.endpoint.region* | The region in which ECS client needs to work.
When using this parameter, the configuration will expect the lowercase name of
the region (for example ap-east-1) You'll need to use the name
Region.EU_WEST_1.id() | null | false | MEDIUM
+| *camel.sink.endpoint.region* | The region in which Lambda client needs to
work. When using this parameter, the configuration will expect the lowercase
name of the region (for example ap-east-1) You'll need to use the name
Region.EU_WEST_1.id() | null | false | MEDIUM
| *camel.sink.endpoint.trustAllCertificates* | If we want to trust all
certificates in case of overriding the endpoint | false | false | MEDIUM
| *camel.sink.endpoint.uriEndpointOverride* | Set the overriding uri endpoint.
This option needs to be used in combination with overrideEndpoint option | null
| false | MEDIUM
+| *camel.sink.endpoint.useDefaultCredentialsProvider* | Set whether the Lambda
client should expect to load credentials through a default credentials provider
or to expect static credentials to be passed in. | false | false | MEDIUM
| *camel.sink.endpoint.awsLambdaClient* | To use a existing configured
AwsLambdaClient as client | null | false | MEDIUM
| *camel.sink.endpoint.proxyHost* | To define a proxy host when instantiating
the Lambda client | null | false | MEDIUM
| *camel.sink.endpoint.proxyPort* | To define a proxy port when instantiating
the Lambda client | null | false | MEDIUM
@@ -50,9 +51,10 @@ The camel-aws2-lambda sink connector supports 29 options,
which are listed below
| *camel.component.aws2-lambda.operation* | The operation to perform. It can
be listFunctions, getFunction, createFunction, deleteFunction or invokeFunction
One of: [listFunctions] [getFunction] [createAlias] [deleteAlias] [getAlias]
[listAliases] [createFunction] [deleteFunction] [invokeFunction]
[updateFunction] [createEventSourceMapping] [deleteEventSourceMapping]
[listEventSourceMapping] [listTags] [tagResource] [untagResource]
[publishVersion] [listVersions] | "invokeFunction" | fal [...]
| *camel.component.aws2-lambda.overrideEndpoint* | Set the need for overidding
the endpoint. This option needs to be used in combination with
uriEndpointOverride option | false | false | MEDIUM
| *camel.component.aws2-lambda.pojoRequest* | If we want to use a POJO request
as body or not | false | false | MEDIUM
-| *camel.component.aws2-lambda.region* | The region in which ECS client needs
to work. When using this parameter, the configuration will expect the lowercase
name of the region (for example ap-east-1) You'll need to use the name
Region.EU_WEST_1.id() | null | false | MEDIUM
+| *camel.component.aws2-lambda.region* | The region in which Lambda client
needs to work. When using this parameter, the configuration will expect the
lowercase name of the region (for example ap-east-1) You'll need to use the
name Region.EU_WEST_1.id() | null | false | MEDIUM
| *camel.component.aws2-lambda.trustAllCertificates* | If we want to trust all
certificates in case of overriding the endpoint | false | false | MEDIUM
| *camel.component.aws2-lambda.uriEndpointOverride* | Set the overriding uri
endpoint. This option needs to be used in combination with overrideEndpoint
option | null | false | MEDIUM
+| *camel.component.aws2-lambda.useDefaultCredentials Provider* | Set whether
the Lambda client should expect to load credentials through a default
credentials provider or to expect static credentials to be passed in. | false |
false | MEDIUM
| *camel.component.aws2-lambda.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.aws2-lambda.awsLambdaClient* | To use a existing configured
AwsLambdaClient as client | null | false | MEDIUM
| *camel.component.aws2-lambda.proxyHost* | To define a proxy host when
instantiating the Lambda client | null | false | MEDIUM
diff --git
a/docs/modules/ROOT/pages/connectors/camel-mongodb-kafka-sink-connector.adoc
b/docs/modules/ROOT/pages/connectors/camel-mongodb-kafka-sink-connector.adoc
index 5de5898..2e83782 100644
--- a/docs/modules/ROOT/pages/connectors/camel-mongodb-kafka-sink-connector.adoc
+++ b/docs/modules/ROOT/pages/connectors/camel-mongodb-kafka-sink-connector.adoc
@@ -24,7 +24,7 @@
connector.class=org.apache.camel.kafkaconnector.mongodb.CamelMongodbSinkConnecto
----
-The camel-mongodb sink connector supports 24 options, which are listed below.
+The camel-mongodb sink connector supports 27 options, which are listed below.
@@ -36,6 +36,7 @@ The camel-mongodb sink connector supports 24 options, which
are listed below.
| *camel.sink.endpoint.collectionIndex* | Sets the collection index (JSON
FORMAT : { field1 : order1, field2 : order2}) | null | false | MEDIUM
| *camel.sink.endpoint.createCollection* | Create collection during
initialisation if it doesn't exist. Default is true. | true | false | MEDIUM
| *camel.sink.endpoint.database* | Sets the name of the MongoDB database to
target | null | false | MEDIUM
+| *camel.sink.endpoint.hosts* | Host address of mongodb server in host:port
format. It's possible also use more than one address, as comma separated list
of hosts: host1:port1,host2:port2. If hosts parameter is specified, provided
connectionBean is ignored. | null | false | MEDIUM
| *camel.sink.endpoint.mongoConnection* | Sets the connection bean used as a
client for connecting to a database. | null | false | MEDIUM
| *camel.sink.endpoint.operation* | Sets the operation this endpoint will
execute against MongoDB. One of: [findById] [findOneByQuery] [findAll]
[findDistinct] [insert] [save] [update] [remove] [bulkWrite] [aggregate]
[getDbStats] [getColStats] [count] [command] | null | false | MEDIUM
| *camel.sink.endpoint.outputType* | Convert the output of the producer to the
selected type : DocumentList Document or MongoIterable. DocumentList or
MongoIterable applies to findAll and aggregate. Document applies to all other
operations. One of: [DocumentList] [Document] [MongoIterable] | null | false |
MEDIUM
@@ -46,6 +47,8 @@ The camel-mongodb sink connector supports 24 options, which
are listed below.
| *camel.sink.endpoint.writeConcern* | Configure the connection bean with the
level of acknowledgment requested from MongoDB for write operations to a
standalone mongod, replicaset or cluster. Possible values are ACKNOWLEDGED, W1,
W2, W3, UNACKNOWLEDGED, JOURNALED or MAJORITY. One of: [ACKNOWLEDGED] [W1] [W2]
[W3] [UNACKNOWLEDGED] [JOURNALED] [MAJORITY] | "ACKNOWLEDGED" | false | MEDIUM
| *camel.sink.endpoint.writeResultAsHeader* | In write operations, it
determines whether instead of returning WriteResult as the body of the OUT
message, we transfer the IN message to the OUT and attach the WriteResult as a
header. | false | false | MEDIUM
| *camel.sink.endpoint.streamFilter* | Filter condition for change streams
consumer. | null | false | MEDIUM
+| *camel.sink.endpoint.password* | User password for mongodb connection | null
| false | MEDIUM
+| *camel.sink.endpoint.username* | Username for mongodb connection | null |
false | MEDIUM
| *camel.sink.endpoint.persistentId* | One tail tracking collection can host
many trackers for several tailable consumers. To keep them separate, each
tracker should have its own unique persistentId. | null | false | MEDIUM
| *camel.sink.endpoint.persistentTailTracking* | Enable persistent tail
tracking, which is a mechanism to keep track of the last consumed message
across system restarts. The next time the system is up, the endpoint will
recover the cursor from the point where it last stopped slurping records. |
false | false | MEDIUM
| *camel.sink.endpoint.tailTrackCollection* | Collection where tail tracking
information will be persisted. If not specified,
MongoDbTailTrackingConfig#DEFAULT_COLLECTION will be used by default. | null |
false | MEDIUM
diff --git
a/docs/modules/ROOT/pages/connectors/camel-mongodb-kafka-source-connector.adoc
b/docs/modules/ROOT/pages/connectors/camel-mongodb-kafka-source-connector.adoc
index c5feba9..3670697 100644
---
a/docs/modules/ROOT/pages/connectors/camel-mongodb-kafka-source-connector.adoc
+++
b/docs/modules/ROOT/pages/connectors/camel-mongodb-kafka-source-connector.adoc
@@ -24,7 +24,7 @@
connector.class=org.apache.camel.kafkaconnector.mongodb.CamelMongodbSourceConnec
----
-The camel-mongodb source connector supports 27 options, which are listed below.
+The camel-mongodb source connector supports 30 options, which are listed below.
@@ -36,6 +36,7 @@ The camel-mongodb source connector supports 27 options, which
are listed below.
| *camel.source.endpoint.collectionIndex* | Sets the collection index (JSON
FORMAT : { field1 : order1, field2 : order2}) | null | false | MEDIUM
| *camel.source.endpoint.createCollection* | Create collection during
initialisation if it doesn't exist. Default is true. | true | false | MEDIUM
| *camel.source.endpoint.database* | Sets the name of the MongoDB database to
target | null | false | MEDIUM
+| *camel.source.endpoint.hosts* | Host address of mongodb server in host:port
format. It's possible also use more than one address, as comma separated list
of hosts: host1:port1,host2:port2. If hosts parameter is specified, provided
connectionBean is ignored. | null | false | MEDIUM
| *camel.source.endpoint.mongoConnection* | Sets the connection bean used as a
client for connecting to a database. | null | false | MEDIUM
| *camel.source.endpoint.operation* | Sets the operation this endpoint will
execute against MongoDB. One of: [findById] [findOneByQuery] [findAll]
[findDistinct] [insert] [save] [update] [remove] [bulkWrite] [aggregate]
[getDbStats] [getColStats] [count] [command] | null | false | MEDIUM
| *camel.source.endpoint.outputType* | Convert the output of the producer to
the selected type : DocumentList Document or MongoIterable. DocumentList or
MongoIterable applies to findAll and aggregate. Document applies to all other
operations. One of: [DocumentList] [Document] [MongoIterable] | null | false |
MEDIUM
@@ -49,6 +50,8 @@ The camel-mongodb source connector supports 27 options, which
are listed below.
| *camel.source.endpoint.writeConcern* | Configure the connection bean with
the level of acknowledgment requested from MongoDB for write operations to a
standalone mongod, replicaset or cluster. Possible values are ACKNOWLEDGED, W1,
W2, W3, UNACKNOWLEDGED, JOURNALED or MAJORITY. One of: [ACKNOWLEDGED] [W1] [W2]
[W3] [UNACKNOWLEDGED] [JOURNALED] [MAJORITY] | "ACKNOWLEDGED" | false | MEDIUM
| *camel.source.endpoint.writeResultAsHeader* | In write operations, it
determines whether instead of returning WriteResult as the body of the OUT
message, we transfer the IN message to the OUT and attach the WriteResult as a
header. | false | false | MEDIUM
| *camel.source.endpoint.streamFilter* | Filter condition for change streams
consumer. | null | false | MEDIUM
+| *camel.source.endpoint.password* | User password for mongodb connection |
null | false | MEDIUM
+| *camel.source.endpoint.username* | Username for mongodb connection | null |
false | MEDIUM
| *camel.source.endpoint.persistentId* | One tail tracking collection can host
many trackers for several tailable consumers. To keep them separate, each
tracker should have its own unique persistentId. | null | false | MEDIUM
| *camel.source.endpoint.persistentTailTracking* | Enable persistent tail
tracking, which is a mechanism to keep track of the last consumed message
across system restarts. The next time the system is up, the endpoint will
recover the cursor from the point where it last stopped slurping records. |
false | false | MEDIUM
| *camel.source.endpoint.tailTrackCollection* | Collection where tail tracking
information will be persisted. If not specified,
MongoDbTailTrackingConfig#DEFAULT_COLLECTION will be used by default. | null |
false | MEDIUM
