This is an automated email from the ASF dual-hosted git repository.
github-bot pushed a commit to branch camel-master
in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git
commit 099f56e1f0319e87b7c6455e71e86f6594cfd409
Author: Andrea Cosentino <anco...@gmail.com>
AuthorDate: Tue Nov 24 07:24:37 2020 +0100
Regen and fixed compilation
---
.../generated/resources/camel-aws2-s3-sink.json | 24 ++++++++++++++++------
.../generated/resources/camel-aws2-s3-source.json | 24 ++++++++++++++++------
.../docs/camel-aws2-s3-kafka-sink-connector.adoc | 8 +++++---
.../docs/camel-aws2-s3-kafka-source-connector.adoc | 8 +++++---
.../aws2s3/CamelAws2s3SinkConnectorConfig.java | 24 ++++++++++++++--------
.../aws2s3/CamelAws2s3SourceConnectorConfig.java | 24 ++++++++++++++--------
.../generated/resources/camel-aws2-sns-sink.json | 8 ++++----
.../docs/camel-aws2-sns-kafka-sink-connector.adoc | 4 ++--
.../aws2sns/CamelAws2snsSinkConnectorConfig.java | 16 +++++++--------
.../generated/resources/camel-aws2-sqs-sink.json | 8 ++++----
.../generated/resources/camel-aws2-sqs-source.json | 8 ++++----
.../docs/camel-aws2-sqs-kafka-sink-connector.adoc | 4 ++--
.../camel-aws2-sqs-kafka-source-connector.adoc | 4 ++--
.../aws2sqs/CamelAws2sqsSinkConnectorConfig.java | 16 +++++++--------
.../aws2sqs/CamelAws2sqsSourceConnectorConfig.java | 16 +++++++--------
.../generated/resources/camel-graphql-sink.json | 7 +++++++
.../docs/camel-graphql-kafka-sink-connector.adoc | 3 ++-
.../graphql/CamelGraphqlSinkConnectorConfig.java | 4 ++++
.../generated/resources/camel-salesforce-sink.json | 4 ++--
.../resources/camel-salesforce-source.json | 4 ++--
.../camel-salesforce-kafka-sink-connector.adoc | 4 ++--
.../camel-salesforce-kafka-source-connector.adoc | 4 ++--
.../CamelSalesforceSinkConnectorConfig.java | 4 ++--
.../CamelSalesforceSourceConnectorConfig.java | 4 ++--
.../SourcePojoToSchemaAndStructTransformTest.java | 8 +++++---
.../camel-aws2-s3-kafka-sink-connector.adoc | 8 +++++---
.../camel-aws2-s3-kafka-source-connector.adoc | 8 +++++---
.../camel-aws2-sns-kafka-sink-connector.adoc | 4 ++--
.../camel-aws2-sqs-kafka-sink-connector.adoc | 4 ++--
.../camel-aws2-sqs-kafka-source-connector.adoc | 4 ++--
.../camel-graphql-kafka-sink-connector.adoc | 3 ++-
.../camel-salesforce-kafka-sink-connector.adoc | 4 ++--
.../camel-salesforce-kafka-source-connector.adoc | 4 ++--
33 files changed, 172 insertions(+), 109 deletions(-)
diff --git
a/connectors/camel-aws2-s3-kafka-connector/src/generated/resources/camel-aws2-s3-sink.json
b/connectors/camel-aws2-s3-kafka-connector/src/generated/resources/camel-aws2-s3-sink.json
index 498bb23..f3ac579 100644
---
a/connectors/camel-aws2-s3-kafka-connector/src/generated/resources/camel-aws2-s3-sink.json
+++
b/connectors/camel-aws2-s3-kafka-connector/src/generated/resources/camel-aws2-s3-sink.json
@@ -21,6 +21,12 @@
"priority": "MEDIUM",
"required": "false"
},
+ "camel.sink.endpoint.amazonS3Presigner": {
+ "name": "camel.sink.endpoint.amazonS3Presigner",
+ "description": "An S3 Presigner for Request, used
mainly in createDownloadLink operation",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
"camel.sink.endpoint.autoCreateBucket": {
"name": "camel.sink.endpoint.autoCreateBucket",
"description": "Setting the autocreation of the S3
bucket bucketName. This will apply also in case of moveAfterRead option enabled
and it will create the destinationBucket if it doesn't exist already.",
@@ -86,9 +92,9 @@
"priority": "MEDIUM",
"required": "false"
},
- "camel.sink.endpoint.useIAMCredentials": {
- "name": "camel.sink.endpoint.useIAMCredentials",
- "description": "Set whether the S3 client should expect
to load credentials on an EC2 instance or to expect static credentials to be
passed in.",
+ "camel.sink.endpoint.useDefaultCredentialsProvider": {
+ "name":
"camel.sink.endpoint.useDefaultCredentialsProvider",
+ "description": "Set whether the S3 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"
@@ -202,6 +208,12 @@
"priority": "MEDIUM",
"required": "false"
},
+ "camel.component.aws2-s3.amazonS3Presigner": {
+ "name": "camel.component.aws2-s3.amazonS3Presigner",
+ "description": "An S3 Presigner for Request, used
mainly in createDownloadLink operation",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
"camel.component.aws2-s3.autoCreateBucket": {
"name": "camel.component.aws2-s3.autoCreateBucket",
"description": "Setting the autocreation of the S3
bucket bucketName. This will apply also in case of moveAfterRead option enabled
and it will create the destinationBucket if it doesn't exist already.",
@@ -273,9 +285,9 @@
"priority": "MEDIUM",
"required": "false"
},
- "camel.component.aws2-s3.useIAMCredentials": {
- "name": "camel.component.aws2-s3.useIAMCredentials",
- "description": "Set whether the S3 client should expect
to load credentials on an EC2 instance or to expect static credentials to be
passed in.",
+ "camel.component.aws2-s3.useDefaultCredentialsProvider": {
+ "name":
"camel.component.aws2-s3.useDefaultCredentialsProvider",
+ "description": "Set whether the S3 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"
diff --git
a/connectors/camel-aws2-s3-kafka-connector/src/generated/resources/camel-aws2-s3-source.json
b/connectors/camel-aws2-s3-kafka-connector/src/generated/resources/camel-aws2-s3-source.json
index b79d280..6233e34 100644
---
a/connectors/camel-aws2-s3-kafka-connector/src/generated/resources/camel-aws2-s3-source.json
+++
b/connectors/camel-aws2-s3-kafka-connector/src/generated/resources/camel-aws2-s3-source.json
@@ -21,6 +21,12 @@
"priority": "MEDIUM",
"required": "false"
},
+ "camel.source.endpoint.amazonS3Presigner": {
+ "name": "camel.source.endpoint.amazonS3Presigner",
+ "description": "An S3 Presigner for Request, used
mainly in createDownloadLink operation",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
"camel.source.endpoint.autoCreateBucket": {
"name": "camel.source.endpoint.autoCreateBucket",
"description": "Setting the autocreation of the S3
bucket bucketName. This will apply also in case of moveAfterRead option enabled
and it will create the destinationBucket if it doesn't exist already.",
@@ -86,9 +92,9 @@
"priority": "MEDIUM",
"required": "false"
},
- "camel.source.endpoint.useIAMCredentials": {
- "name": "camel.source.endpoint.useIAMCredentials",
- "description": "Set whether the S3 client should expect
to load credentials on an EC2 instance or to expect static credentials to be
passed in.",
+ "camel.source.endpoint.useDefaultCredentialsProvider": {
+ "name":
"camel.source.endpoint.useDefaultCredentialsProvider",
+ "description": "Set whether the S3 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"
@@ -346,6 +352,12 @@
"priority": "MEDIUM",
"required": "false"
},
+ "camel.component.aws2-s3.amazonS3Presigner": {
+ "name": "camel.component.aws2-s3.amazonS3Presigner",
+ "description": "An S3 Presigner for Request, used
mainly in createDownloadLink operation",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
"camel.component.aws2-s3.autoCreateBucket": {
"name": "camel.component.aws2-s3.autoCreateBucket",
"description": "Setting the autocreation of the S3
bucket bucketName. This will apply also in case of moveAfterRead option enabled
and it will create the destinationBucket if it doesn't exist already.",
@@ -417,9 +429,9 @@
"priority": "MEDIUM",
"required": "false"
},
- "camel.component.aws2-s3.useIAMCredentials": {
- "name": "camel.component.aws2-s3.useIAMCredentials",
- "description": "Set whether the S3 client should expect
to load credentials on an EC2 instance or to expect static credentials to be
passed in.",
+ "camel.component.aws2-s3.useDefaultCredentialsProvider": {
+ "name":
"camel.component.aws2-s3.useDefaultCredentialsProvider",
+ "description": "Set whether the S3 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"
diff --git
a/connectors/camel-aws2-s3-kafka-connector/src/main/docs/camel-aws2-s3-kafka-sink-connector.adoc
b/connectors/camel-aws2-s3-kafka-connector/src/main/docs/camel-aws2-s3-kafka-sink-connector.adoc
index ffe0bd0..18a7c1a 100644
---
a/connectors/camel-aws2-s3-kafka-connector/src/main/docs/camel-aws2-s3-kafka-sink-connector.adoc
+++
b/connectors/camel-aws2-s3-kafka-connector/src/main/docs/camel-aws2-s3-kafka-sink-connector.adoc
@@ -22,7 +22,7 @@
connector.class=org.apache.camel.kafkaconnector.aws2s3.CamelAws2s3SinkConnector
----
-The camel-aws2-s3 sink connector supports 58 options, which are listed below.
+The camel-aws2-s3 sink connector supports 60 options, which are listed below.
@@ -31,6 +31,7 @@ The camel-aws2-s3 sink connector supports 58 options, which
are listed below.
| Name | Description | Default | Required | Priority
| *camel.sink.path.bucketNameOrArn* | Bucket name or ARN | null | true | HIGH
| *camel.sink.endpoint.amazonS3Client* | Reference to a
com.amazonaws.services.s3.AmazonS3 in the registry. | null | false | MEDIUM
+| *camel.sink.endpoint.amazonS3Presigner* | An S3 Presigner for Request, used
mainly in createDownloadLink operation | null | false | MEDIUM
| *camel.sink.endpoint.autoCreateBucket* | Setting the autocreation of the S3
bucket bucketName. This will apply also in case of moveAfterRead option enabled
and it will create the destinationBucket if it doesn't exist already. | true |
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
@@ -41,7 +42,7 @@ The camel-aws2-s3 sink connector supports 58 options, which
are listed below.
| *camel.sink.endpoint.region* | The region in which S3 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.useIAMCredentials* | Set whether the S3 client should
expect to load credentials on an EC2 instance or to expect static credentials
to be passed in. | false | false | MEDIUM
+| *camel.sink.endpoint.useDefaultCredentialsProvider* | Set whether the S3
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.customerAlgorithm* | Define the customer algorithm to
use in case CustomerKey is enabled | null | false | MEDIUM
| *camel.sink.endpoint.customerKeyId* | Define the id of Customer key to use
in case CustomerKey is enabled | null | false | MEDIUM
| *camel.sink.endpoint.customerKeyMD5* | Define the MD5 of Customer key to use
in case CustomerKey is enabled | null | false | MEDIUM
@@ -59,6 +60,7 @@ The camel-aws2-s3 sink connector supports 58 options, which
are listed below.
| *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-s3.amazonS3Client* | Reference to a
com.amazonaws.services.s3.AmazonS3 in the registry. | null | false | MEDIUM
+| *camel.component.aws2-s3.amazonS3Presigner* | An S3 Presigner for Request,
used mainly in createDownloadLink operation | null | false | MEDIUM
| *camel.component.aws2-s3.autoCreateBucket* | Setting the autocreation of the
S3 bucket bucketName. This will apply also in case of moveAfterRead option
enabled and it will create the destinationBucket if it doesn't exist already. |
true | false | MEDIUM
| *camel.component.aws2-s3.configuration* | The component configuration | null
| false | MEDIUM
| *camel.component.aws2-s3.overrideEndpoint* | Set the need for overidding the
endpoint. This option needs to be used in combination with uriEndpointOverride
option | false | false | MEDIUM
@@ -70,7 +72,7 @@ The camel-aws2-s3 sink connector supports 58 options, which
are listed below.
| *camel.component.aws2-s3.region* | The region in which S3 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-s3.trustAllCertificates* | If we want to trust all
certificates in case of overriding the endpoint | false | false | MEDIUM
| *camel.component.aws2-s3.uriEndpointOverride* | Set the overriding uri
endpoint. This option needs to be used in combination with overrideEndpoint
option | null | false | MEDIUM
-| *camel.component.aws2-s3.useIAMCredentials* | Set whether the S3 client
should expect to load credentials on an EC2 instance or to expect static
credentials to be passed in. | false | false | MEDIUM
+| *camel.component.aws2-s3.useDefaultCredentials Provider* | Set whether the
S3 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-s3.customerAlgorithm* | Define the customer algorithm
to use in case CustomerKey is enabled | null | false | MEDIUM
| *camel.component.aws2-s3.customerKeyId* | Define the id of Customer key to
use in case CustomerKey is enabled | null | false | MEDIUM
| *camel.component.aws2-s3.customerKeyMD5* | Define the MD5 of Customer key to
use in case CustomerKey is enabled | null | false | MEDIUM
diff --git
a/connectors/camel-aws2-s3-kafka-connector/src/main/docs/camel-aws2-s3-kafka-source-connector.adoc
b/connectors/camel-aws2-s3-kafka-connector/src/main/docs/camel-aws2-s3-kafka-source-connector.adoc
index 0c67013..466b485 100644
---
a/connectors/camel-aws2-s3-kafka-connector/src/main/docs/camel-aws2-s3-kafka-source-connector.adoc
+++
b/connectors/camel-aws2-s3-kafka-connector/src/main/docs/camel-aws2-s3-kafka-source-connector.adoc
@@ -22,7 +22,7 @@
connector.class=org.apache.camel.kafkaconnector.aws2s3.CamelAws2s3SourceConnecto
----
-The camel-aws2-s3 source connector supports 82 options, which are listed below.
+The camel-aws2-s3 source connector supports 84 options, which are listed below.
@@ -31,6 +31,7 @@ The camel-aws2-s3 source connector supports 82 options, which
are listed below.
| Name | Description | Default | Required | Priority
| *camel.source.path.bucketNameOrArn* | Bucket name or ARN | null | true | HIGH
| *camel.source.endpoint.amazonS3Client* | Reference to a
com.amazonaws.services.s3.AmazonS3 in the registry. | null | false | MEDIUM
+| *camel.source.endpoint.amazonS3Presigner* | An S3 Presigner for Request,
used mainly in createDownloadLink operation | null | false | MEDIUM
| *camel.source.endpoint.autoCreateBucket* | Setting the autocreation of the
S3 bucket bucketName. This will apply also in case of moveAfterRead option
enabled and it will create the destinationBucket if it doesn't exist already. |
true | false | MEDIUM
| *camel.source.endpoint.overrideEndpoint* | Set the need for overidding the
endpoint. This option needs to be used in combination with uriEndpointOverride
option | false | false | MEDIUM
| *camel.source.endpoint.pojoRequest* | If we want to use a POJO request as
body or not | false | false | MEDIUM
@@ -41,7 +42,7 @@ The camel-aws2-s3 source connector supports 82 options, which
are listed below.
| *camel.source.endpoint.region* | The region in which S3 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.source.endpoint.trustAllCertificates* | If we want to trust all
certificates in case of overriding the endpoint | false | false | MEDIUM
| *camel.source.endpoint.uriEndpointOverride* | Set the overriding uri
endpoint. This option needs to be used in combination with overrideEndpoint
option | null | false | MEDIUM
-| *camel.source.endpoint.useIAMCredentials* | Set whether the S3 client should
expect to load credentials on an EC2 instance or to expect static credentials
to be passed in. | false | false | MEDIUM
+| *camel.source.endpoint.useDefaultCredentials Provider* | Set whether the S3
client should expect to load credentials through a default credentials provider
or to expect static credentials to be passed in. | false | false | MEDIUM
| *camel.source.endpoint.customerAlgorithm* | Define the customer algorithm to
use in case CustomerKey is enabled | null | false | MEDIUM
| *camel.source.endpoint.customerKeyId* | Define the id of Customer key to use
in case CustomerKey is enabled | null | false | MEDIUM
| *camel.source.endpoint.customerKeyMD5* | Define the MD5 of Customer key to
use in case CustomerKey is enabled | null | false | MEDIUM
@@ -81,6 +82,7 @@ The camel-aws2-s3 source connector supports 82 options, which
are listed below.
| *camel.source.endpoint.accessKey* | Amazon AWS Access Key | null | false |
MEDIUM
| *camel.source.endpoint.secretKey* | Amazon AWS Secret Key | null | false |
MEDIUM
| *camel.component.aws2-s3.amazonS3Client* | Reference to a
com.amazonaws.services.s3.AmazonS3 in the registry. | null | false | MEDIUM
+| *camel.component.aws2-s3.amazonS3Presigner* | An S3 Presigner for Request,
used mainly in createDownloadLink operation | null | false | MEDIUM
| *camel.component.aws2-s3.autoCreateBucket* | Setting the autocreation of the
S3 bucket bucketName. This will apply also in case of moveAfterRead option
enabled and it will create the destinationBucket if it doesn't exist already. |
true | false | MEDIUM
| *camel.component.aws2-s3.configuration* | The component configuration | null
| false | MEDIUM
| *camel.component.aws2-s3.overrideEndpoint* | Set the need for overidding the
endpoint. This option needs to be used in combination with uriEndpointOverride
option | false | false | MEDIUM
@@ -92,7 +94,7 @@ The camel-aws2-s3 source connector supports 82 options, which
are listed below.
| *camel.component.aws2-s3.region* | The region in which S3 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-s3.trustAllCertificates* | If we want to trust all
certificates in case of overriding the endpoint | false | false | MEDIUM
| *camel.component.aws2-s3.uriEndpointOverride* | Set the overriding uri
endpoint. This option needs to be used in combination with overrideEndpoint
option | null | false | MEDIUM
-| *camel.component.aws2-s3.useIAMCredentials* | Set whether the S3 client
should expect to load credentials on an EC2 instance or to expect static
credentials to be passed in. | false | false | MEDIUM
+| *camel.component.aws2-s3.useDefaultCredentials Provider* | Set whether the
S3 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-s3.customerAlgorithm* | Define the customer algorithm
to use in case CustomerKey is enabled | null | false | MEDIUM
| *camel.component.aws2-s3.customerKeyId* | Define the id of Customer key to
use in case CustomerKey is enabled | null | false | MEDIUM
| *camel.component.aws2-s3.customerKeyMD5* | Define the MD5 of Customer key to
use in case CustomerKey is enabled | null | false | MEDIUM
diff --git
a/connectors/camel-aws2-s3-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/aws2s3/CamelAws2s3SinkConnectorConfig.java
b/connectors/camel-aws2-s3-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/aws2s3/CamelAws2s3SinkConnectorConfig.java
index a764431..4a09e94 100644
---
a/connectors/camel-aws2-s3-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/aws2s3/CamelAws2s3SinkConnectorConfig.java
+++
b/connectors/camel-aws2-s3-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/aws2s3/CamelAws2s3SinkConnectorConfig.java
@@ -30,6 +30,9 @@ public class CamelAws2s3SinkConnectorConfig extends
CamelSinkConnectorConfig {
public static final String CAMEL_SINK_AWS2S3_ENDPOINT_AMAZON_S3CLIENT_CONF
= "camel.sink.endpoint.amazonS3Client";
public static final String CAMEL_SINK_AWS2S3_ENDPOINT_AMAZON_S3CLIENT_DOC
= "Reference to a com.amazonaws.services.s3.AmazonS3 in the registry.";
public static final String
CAMEL_SINK_AWS2S3_ENDPOINT_AMAZON_S3CLIENT_DEFAULT = null;
+ public static final String
CAMEL_SINK_AWS2S3_ENDPOINT_AMAZON_S3PRESIGNER_CONF =
"camel.sink.endpoint.amazonS3Presigner";
+ public static final String
CAMEL_SINK_AWS2S3_ENDPOINT_AMAZON_S3PRESIGNER_DOC = "An S3 Presigner for
Request, used mainly in createDownloadLink operation";
+ public static final String
CAMEL_SINK_AWS2S3_ENDPOINT_AMAZON_S3PRESIGNER_DEFAULT = null;
public static final String
CAMEL_SINK_AWS2S3_ENDPOINT_AUTO_CREATE_BUCKET_CONF =
"camel.sink.endpoint.autoCreateBucket";
public static final String
CAMEL_SINK_AWS2S3_ENDPOINT_AUTO_CREATE_BUCKET_DOC = "Setting the autocreation
of the S3 bucket bucketName. This will apply also in case of moveAfterRead
option enabled and it will create the destinationBucket if it doesn't exist
already.";
public static final Boolean
CAMEL_SINK_AWS2S3_ENDPOINT_AUTO_CREATE_BUCKET_DEFAULT = true;
@@ -60,9 +63,9 @@ public class CamelAws2s3SinkConnectorConfig extends
CamelSinkConnectorConfig {
public static final String
CAMEL_SINK_AWS2S3_ENDPOINT_URI_ENDPOINT_OVERRIDE_CONF =
"camel.sink.endpoint.uriEndpointOverride";
public static final String
CAMEL_SINK_AWS2S3_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_AWS2S3_ENDPOINT_URI_ENDPOINT_OVERRIDE_DEFAULT = null;
- public static final String
CAMEL_SINK_AWS2S3_ENDPOINT_USE_IAMCREDENTIALS_CONF =
"camel.sink.endpoint.useIAMCredentials";
- public static final String
CAMEL_SINK_AWS2S3_ENDPOINT_USE_IAMCREDENTIALS_DOC = "Set whether the S3 client
should expect to load credentials on an EC2 instance or to expect static
credentials to be passed in.";
- public static final Boolean
CAMEL_SINK_AWS2S3_ENDPOINT_USE_IAMCREDENTIALS_DEFAULT = false;
+ public static final String
CAMEL_SINK_AWS2S3_ENDPOINT_USE_DEFAULT_CREDENTIALS_PROVIDER_CONF =
"camel.sink.endpoint.useDefaultCredentialsProvider";
+ public static final String
CAMEL_SINK_AWS2S3_ENDPOINT_USE_DEFAULT_CREDENTIALS_PROVIDER_DOC = "Set whether
the S3 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_AWS2S3_ENDPOINT_USE_DEFAULT_CREDENTIALS_PROVIDER_DEFAULT = false;
public static final String
CAMEL_SINK_AWS2S3_ENDPOINT_CUSTOMER_ALGORITHM_CONF =
"camel.sink.endpoint.customerAlgorithm";
public static final String
CAMEL_SINK_AWS2S3_ENDPOINT_CUSTOMER_ALGORITHM_DOC = "Define the customer
algorithm to use in case CustomerKey is enabled";
public static final String
CAMEL_SINK_AWS2S3_ENDPOINT_CUSTOMER_ALGORITHM_DEFAULT = null;
@@ -114,6 +117,9 @@ public class CamelAws2s3SinkConnectorConfig extends
CamelSinkConnectorConfig {
public static final String
CAMEL_SINK_AWS2S3_COMPONENT_AMAZON_S3CLIENT_CONF =
"camel.component.aws2-s3.amazonS3Client";
public static final String CAMEL_SINK_AWS2S3_COMPONENT_AMAZON_S3CLIENT_DOC
= "Reference to a com.amazonaws.services.s3.AmazonS3 in the registry.";
public static final String
CAMEL_SINK_AWS2S3_COMPONENT_AMAZON_S3CLIENT_DEFAULT = null;
+ public static final String
CAMEL_SINK_AWS2S3_COMPONENT_AMAZON_S3PRESIGNER_CONF =
"camel.component.aws2-s3.amazonS3Presigner";
+ public static final String
CAMEL_SINK_AWS2S3_COMPONENT_AMAZON_S3PRESIGNER_DOC = "An S3 Presigner for
Request, used mainly in createDownloadLink operation";
+ public static final String
CAMEL_SINK_AWS2S3_COMPONENT_AMAZON_S3PRESIGNER_DEFAULT = null;
public static final String
CAMEL_SINK_AWS2S3_COMPONENT_AUTO_CREATE_BUCKET_CONF =
"camel.component.aws2-s3.autoCreateBucket";
public static final String
CAMEL_SINK_AWS2S3_COMPONENT_AUTO_CREATE_BUCKET_DOC = "Setting the autocreation
of the S3 bucket bucketName. This will apply also in case of moveAfterRead
option enabled and it will create the destinationBucket if it doesn't exist
already.";
public static final Boolean
CAMEL_SINK_AWS2S3_COMPONENT_AUTO_CREATE_BUCKET_DEFAULT = true;
@@ -147,9 +153,9 @@ public class CamelAws2s3SinkConnectorConfig extends
CamelSinkConnectorConfig {
public static final String
CAMEL_SINK_AWS2S3_COMPONENT_URI_ENDPOINT_OVERRIDE_CONF =
"camel.component.aws2-s3.uriEndpointOverride";
public static final String
CAMEL_SINK_AWS2S3_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_AWS2S3_COMPONENT_URI_ENDPOINT_OVERRIDE_DEFAULT = null;
- public static final String
CAMEL_SINK_AWS2S3_COMPONENT_USE_IAMCREDENTIALS_CONF =
"camel.component.aws2-s3.useIAMCredentials";
- public static final String
CAMEL_SINK_AWS2S3_COMPONENT_USE_IAMCREDENTIALS_DOC = "Set whether the S3 client
should expect to load credentials on an EC2 instance or to expect static
credentials to be passed in.";
- public static final Boolean
CAMEL_SINK_AWS2S3_COMPONENT_USE_IAMCREDENTIALS_DEFAULT = false;
+ public static final String
CAMEL_SINK_AWS2S3_COMPONENT_USE_DEFAULT_CREDENTIALS_PROVIDER_CONF =
"camel.component.aws2-s3.useDefaultCredentialsProvider";
+ public static final String
CAMEL_SINK_AWS2S3_COMPONENT_USE_DEFAULT_CREDENTIALS_PROVIDER_DOC = "Set whether
the S3 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_AWS2S3_COMPONENT_USE_DEFAULT_CREDENTIALS_PROVIDER_DEFAULT = false;
public static final String
CAMEL_SINK_AWS2S3_COMPONENT_CUSTOMER_ALGORITHM_CONF =
"camel.component.aws2-s3.customerAlgorithm";
public static final String
CAMEL_SINK_AWS2S3_COMPONENT_CUSTOMER_ALGORITHM_DOC = "Define the customer
algorithm to use in case CustomerKey is enabled";
public static final String
CAMEL_SINK_AWS2S3_COMPONENT_CUSTOMER_ALGORITHM_DEFAULT = null;
@@ -213,6 +219,7 @@ public class CamelAws2s3SinkConnectorConfig extends
CamelSinkConnectorConfig {
ConfigDef conf = new ConfigDef(CamelSinkConnectorConfig.conf());
conf.define(CAMEL_SINK_AWS2S3_PATH_BUCKET_NAME_OR_ARN_CONF,
ConfigDef.Type.STRING, CAMEL_SINK_AWS2S3_PATH_BUCKET_NAME_OR_ARN_DEFAULT,
ConfigDef.Importance.HIGH, CAMEL_SINK_AWS2S3_PATH_BUCKET_NAME_OR_ARN_DOC);
conf.define(CAMEL_SINK_AWS2S3_ENDPOINT_AMAZON_S3CLIENT_CONF,
ConfigDef.Type.STRING, CAMEL_SINK_AWS2S3_ENDPOINT_AMAZON_S3CLIENT_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_AWS2S3_ENDPOINT_AMAZON_S3CLIENT_DOC);
+ conf.define(CAMEL_SINK_AWS2S3_ENDPOINT_AMAZON_S3PRESIGNER_CONF,
ConfigDef.Type.STRING, CAMEL_SINK_AWS2S3_ENDPOINT_AMAZON_S3PRESIGNER_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_AWS2S3_ENDPOINT_AMAZON_S3PRESIGNER_DOC);
conf.define(CAMEL_SINK_AWS2S3_ENDPOINT_AUTO_CREATE_BUCKET_CONF,
ConfigDef.Type.BOOLEAN, CAMEL_SINK_AWS2S3_ENDPOINT_AUTO_CREATE_BUCKET_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_AWS2S3_ENDPOINT_AUTO_CREATE_BUCKET_DOC);
conf.define(CAMEL_SINK_AWS2S3_ENDPOINT_OVERRIDE_ENDPOINT_CONF,
ConfigDef.Type.BOOLEAN, CAMEL_SINK_AWS2S3_ENDPOINT_OVERRIDE_ENDPOINT_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_AWS2S3_ENDPOINT_OVERRIDE_ENDPOINT_DOC);
conf.define(CAMEL_SINK_AWS2S3_ENDPOINT_POJO_REQUEST_CONF,
ConfigDef.Type.BOOLEAN, CAMEL_SINK_AWS2S3_ENDPOINT_POJO_REQUEST_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_AWS2S3_ENDPOINT_POJO_REQUEST_DOC);
@@ -223,7 +230,7 @@ public class CamelAws2s3SinkConnectorConfig extends
CamelSinkConnectorConfig {
conf.define(CAMEL_SINK_AWS2S3_ENDPOINT_REGION_CONF,
ConfigDef.Type.STRING, CAMEL_SINK_AWS2S3_ENDPOINT_REGION_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_AWS2S3_ENDPOINT_REGION_DOC);
conf.define(CAMEL_SINK_AWS2S3_ENDPOINT_TRUST_ALL_CERTIFICATES_CONF,
ConfigDef.Type.BOOLEAN,
CAMEL_SINK_AWS2S3_ENDPOINT_TRUST_ALL_CERTIFICATES_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SINK_AWS2S3_ENDPOINT_TRUST_ALL_CERTIFICATES_DOC);
conf.define(CAMEL_SINK_AWS2S3_ENDPOINT_URI_ENDPOINT_OVERRIDE_CONF,
ConfigDef.Type.STRING,
CAMEL_SINK_AWS2S3_ENDPOINT_URI_ENDPOINT_OVERRIDE_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SINK_AWS2S3_ENDPOINT_URI_ENDPOINT_OVERRIDE_DOC);
- conf.define(CAMEL_SINK_AWS2S3_ENDPOINT_USE_IAMCREDENTIALS_CONF,
ConfigDef.Type.BOOLEAN, CAMEL_SINK_AWS2S3_ENDPOINT_USE_IAMCREDENTIALS_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_AWS2S3_ENDPOINT_USE_IAMCREDENTIALS_DOC);
+
conf.define(CAMEL_SINK_AWS2S3_ENDPOINT_USE_DEFAULT_CREDENTIALS_PROVIDER_CONF,
ConfigDef.Type.BOOLEAN,
CAMEL_SINK_AWS2S3_ENDPOINT_USE_DEFAULT_CREDENTIALS_PROVIDER_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SINK_AWS2S3_ENDPOINT_USE_DEFAULT_CREDENTIALS_PROVIDER_DOC);
conf.define(CAMEL_SINK_AWS2S3_ENDPOINT_CUSTOMER_ALGORITHM_CONF,
ConfigDef.Type.STRING, CAMEL_SINK_AWS2S3_ENDPOINT_CUSTOMER_ALGORITHM_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_AWS2S3_ENDPOINT_CUSTOMER_ALGORITHM_DOC);
conf.define(CAMEL_SINK_AWS2S3_ENDPOINT_CUSTOMER_KEY_ID_CONF,
ConfigDef.Type.STRING, CAMEL_SINK_AWS2S3_ENDPOINT_CUSTOMER_KEY_ID_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_AWS2S3_ENDPOINT_CUSTOMER_KEY_ID_DOC);
conf.define(CAMEL_SINK_AWS2S3_ENDPOINT_CUSTOMER_KEY_MD5CONF,
ConfigDef.Type.STRING, CAMEL_SINK_AWS2S3_ENDPOINT_CUSTOMER_KEY_MD5DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_AWS2S3_ENDPOINT_CUSTOMER_KEY_MD5DOC);
@@ -241,6 +248,7 @@ public class CamelAws2s3SinkConnectorConfig extends
CamelSinkConnectorConfig {
conf.define(CAMEL_SINK_AWS2S3_ENDPOINT_ACCESS_KEY_CONF,
ConfigDef.Type.STRING, CAMEL_SINK_AWS2S3_ENDPOINT_ACCESS_KEY_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_AWS2S3_ENDPOINT_ACCESS_KEY_DOC);
conf.define(CAMEL_SINK_AWS2S3_ENDPOINT_SECRET_KEY_CONF,
ConfigDef.Type.STRING, CAMEL_SINK_AWS2S3_ENDPOINT_SECRET_KEY_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_AWS2S3_ENDPOINT_SECRET_KEY_DOC);
conf.define(CAMEL_SINK_AWS2S3_COMPONENT_AMAZON_S3CLIENT_CONF,
ConfigDef.Type.STRING, CAMEL_SINK_AWS2S3_COMPONENT_AMAZON_S3CLIENT_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_AWS2S3_COMPONENT_AMAZON_S3CLIENT_DOC);
+ conf.define(CAMEL_SINK_AWS2S3_COMPONENT_AMAZON_S3PRESIGNER_CONF,
ConfigDef.Type.STRING, CAMEL_SINK_AWS2S3_COMPONENT_AMAZON_S3PRESIGNER_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SINK_AWS2S3_COMPONENT_AMAZON_S3PRESIGNER_DOC);
conf.define(CAMEL_SINK_AWS2S3_COMPONENT_AUTO_CREATE_BUCKET_CONF,
ConfigDef.Type.BOOLEAN, CAMEL_SINK_AWS2S3_COMPONENT_AUTO_CREATE_BUCKET_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SINK_AWS2S3_COMPONENT_AUTO_CREATE_BUCKET_DOC);
conf.define(CAMEL_SINK_AWS2S3_COMPONENT_CONFIGURATION_CONF,
ConfigDef.Type.STRING, CAMEL_SINK_AWS2S3_COMPONENT_CONFIGURATION_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_AWS2S3_COMPONENT_CONFIGURATION_DOC);
conf.define(CAMEL_SINK_AWS2S3_COMPONENT_OVERRIDE_ENDPOINT_CONF,
ConfigDef.Type.BOOLEAN, CAMEL_SINK_AWS2S3_COMPONENT_OVERRIDE_ENDPOINT_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_AWS2S3_COMPONENT_OVERRIDE_ENDPOINT_DOC);
@@ -252,7 +260,7 @@ public class CamelAws2s3SinkConnectorConfig extends
CamelSinkConnectorConfig {
conf.define(CAMEL_SINK_AWS2S3_COMPONENT_REGION_CONF,
ConfigDef.Type.STRING, CAMEL_SINK_AWS2S3_COMPONENT_REGION_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_AWS2S3_COMPONENT_REGION_DOC);
conf.define(CAMEL_SINK_AWS2S3_COMPONENT_TRUST_ALL_CERTIFICATES_CONF,
ConfigDef.Type.BOOLEAN,
CAMEL_SINK_AWS2S3_COMPONENT_TRUST_ALL_CERTIFICATES_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SINK_AWS2S3_COMPONENT_TRUST_ALL_CERTIFICATES_DOC);
conf.define(CAMEL_SINK_AWS2S3_COMPONENT_URI_ENDPOINT_OVERRIDE_CONF,
ConfigDef.Type.STRING,
CAMEL_SINK_AWS2S3_COMPONENT_URI_ENDPOINT_OVERRIDE_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SINK_AWS2S3_COMPONENT_URI_ENDPOINT_OVERRIDE_DOC);
- conf.define(CAMEL_SINK_AWS2S3_COMPONENT_USE_IAMCREDENTIALS_CONF,
ConfigDef.Type.BOOLEAN, CAMEL_SINK_AWS2S3_COMPONENT_USE_IAMCREDENTIALS_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SINK_AWS2S3_COMPONENT_USE_IAMCREDENTIALS_DOC);
+
conf.define(CAMEL_SINK_AWS2S3_COMPONENT_USE_DEFAULT_CREDENTIALS_PROVIDER_CONF,
ConfigDef.Type.BOOLEAN,
CAMEL_SINK_AWS2S3_COMPONENT_USE_DEFAULT_CREDENTIALS_PROVIDER_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SINK_AWS2S3_COMPONENT_USE_DEFAULT_CREDENTIALS_PROVIDER_DOC);
conf.define(CAMEL_SINK_AWS2S3_COMPONENT_CUSTOMER_ALGORITHM_CONF,
ConfigDef.Type.STRING, CAMEL_SINK_AWS2S3_COMPONENT_CUSTOMER_ALGORITHM_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SINK_AWS2S3_COMPONENT_CUSTOMER_ALGORITHM_DOC);
conf.define(CAMEL_SINK_AWS2S3_COMPONENT_CUSTOMER_KEY_ID_CONF,
ConfigDef.Type.STRING, CAMEL_SINK_AWS2S3_COMPONENT_CUSTOMER_KEY_ID_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_AWS2S3_COMPONENT_CUSTOMER_KEY_ID_DOC);
conf.define(CAMEL_SINK_AWS2S3_COMPONENT_CUSTOMER_KEY_MD5CONF,
ConfigDef.Type.STRING, CAMEL_SINK_AWS2S3_COMPONENT_CUSTOMER_KEY_MD5DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_AWS2S3_COMPONENT_CUSTOMER_KEY_MD5DOC);
diff --git
a/connectors/camel-aws2-s3-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/aws2s3/CamelAws2s3SourceConnectorConfig.java
b/connectors/camel-aws2-s3-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/aws2s3/CamelAws2s3SourceConnectorConfig.java
index afd7b97..a881ba4 100644
---
a/connectors/camel-aws2-s3-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/aws2s3/CamelAws2s3SourceConnectorConfig.java
+++
b/connectors/camel-aws2-s3-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/aws2s3/CamelAws2s3SourceConnectorConfig.java
@@ -32,6 +32,9 @@ public class CamelAws2s3SourceConnectorConfig
public static final String
CAMEL_SOURCE_AWS2S3_ENDPOINT_AMAZON_S3CLIENT_CONF =
"camel.source.endpoint.amazonS3Client";
public static final String
CAMEL_SOURCE_AWS2S3_ENDPOINT_AMAZON_S3CLIENT_DOC = "Reference to a
com.amazonaws.services.s3.AmazonS3 in the registry.";
public static final String
CAMEL_SOURCE_AWS2S3_ENDPOINT_AMAZON_S3CLIENT_DEFAULT = null;
+ public static final String
CAMEL_SOURCE_AWS2S3_ENDPOINT_AMAZON_S3PRESIGNER_CONF =
"camel.source.endpoint.amazonS3Presigner";
+ public static final String
CAMEL_SOURCE_AWS2S3_ENDPOINT_AMAZON_S3PRESIGNER_DOC = "An S3 Presigner for
Request, used mainly in createDownloadLink operation";
+ public static final String
CAMEL_SOURCE_AWS2S3_ENDPOINT_AMAZON_S3PRESIGNER_DEFAULT = null;
public static final String
CAMEL_SOURCE_AWS2S3_ENDPOINT_AUTO_CREATE_BUCKET_CONF =
"camel.source.endpoint.autoCreateBucket";
public static final String
CAMEL_SOURCE_AWS2S3_ENDPOINT_AUTO_CREATE_BUCKET_DOC = "Setting the autocreation
of the S3 bucket bucketName. This will apply also in case of moveAfterRead
option enabled and it will create the destinationBucket if it doesn't exist
already.";
public static final Boolean
CAMEL_SOURCE_AWS2S3_ENDPOINT_AUTO_CREATE_BUCKET_DEFAULT = true;
@@ -62,9 +65,9 @@ public class CamelAws2s3SourceConnectorConfig
public static final String
CAMEL_SOURCE_AWS2S3_ENDPOINT_URI_ENDPOINT_OVERRIDE_CONF =
"camel.source.endpoint.uriEndpointOverride";
public static final String
CAMEL_SOURCE_AWS2S3_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_SOURCE_AWS2S3_ENDPOINT_URI_ENDPOINT_OVERRIDE_DEFAULT = null;
- public static final String
CAMEL_SOURCE_AWS2S3_ENDPOINT_USE_IAMCREDENTIALS_CONF =
"camel.source.endpoint.useIAMCredentials";
- public static final String
CAMEL_SOURCE_AWS2S3_ENDPOINT_USE_IAMCREDENTIALS_DOC = "Set whether the S3
client should expect to load credentials on an EC2 instance or to expect static
credentials to be passed in.";
- public static final Boolean
CAMEL_SOURCE_AWS2S3_ENDPOINT_USE_IAMCREDENTIALS_DEFAULT = false;
+ public static final String
CAMEL_SOURCE_AWS2S3_ENDPOINT_USE_DEFAULT_CREDENTIALS_PROVIDER_CONF =
"camel.source.endpoint.useDefaultCredentialsProvider";
+ public static final String
CAMEL_SOURCE_AWS2S3_ENDPOINT_USE_DEFAULT_CREDENTIALS_PROVIDER_DOC = "Set
whether the S3 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_SOURCE_AWS2S3_ENDPOINT_USE_DEFAULT_CREDENTIALS_PROVIDER_DEFAULT = false;
public static final String
CAMEL_SOURCE_AWS2S3_ENDPOINT_CUSTOMER_ALGORITHM_CONF =
"camel.source.endpoint.customerAlgorithm";
public static final String
CAMEL_SOURCE_AWS2S3_ENDPOINT_CUSTOMER_ALGORITHM_DOC = "Define the customer
algorithm to use in case CustomerKey is enabled";
public static final String
CAMEL_SOURCE_AWS2S3_ENDPOINT_CUSTOMER_ALGORITHM_DEFAULT = null;
@@ -182,6 +185,9 @@ public class CamelAws2s3SourceConnectorConfig
public static final String
CAMEL_SOURCE_AWS2S3_COMPONENT_AMAZON_S3CLIENT_CONF =
"camel.component.aws2-s3.amazonS3Client";
public static final String
CAMEL_SOURCE_AWS2S3_COMPONENT_AMAZON_S3CLIENT_DOC = "Reference to a
com.amazonaws.services.s3.AmazonS3 in the registry.";
public static final String
CAMEL_SOURCE_AWS2S3_COMPONENT_AMAZON_S3CLIENT_DEFAULT = null;
+ public static final String
CAMEL_SOURCE_AWS2S3_COMPONENT_AMAZON_S3PRESIGNER_CONF =
"camel.component.aws2-s3.amazonS3Presigner";
+ public static final String
CAMEL_SOURCE_AWS2S3_COMPONENT_AMAZON_S3PRESIGNER_DOC = "An S3 Presigner for
Request, used mainly in createDownloadLink operation";
+ public static final String
CAMEL_SOURCE_AWS2S3_COMPONENT_AMAZON_S3PRESIGNER_DEFAULT = null;
public static final String
CAMEL_SOURCE_AWS2S3_COMPONENT_AUTO_CREATE_BUCKET_CONF =
"camel.component.aws2-s3.autoCreateBucket";
public static final String
CAMEL_SOURCE_AWS2S3_COMPONENT_AUTO_CREATE_BUCKET_DOC = "Setting the
autocreation of the S3 bucket bucketName. This will apply also in case of
moveAfterRead option enabled and it will create the destinationBucket if it
doesn't exist already.";
public static final Boolean
CAMEL_SOURCE_AWS2S3_COMPONENT_AUTO_CREATE_BUCKET_DEFAULT = true;
@@ -215,9 +221,9 @@ public class CamelAws2s3SourceConnectorConfig
public static final String
CAMEL_SOURCE_AWS2S3_COMPONENT_URI_ENDPOINT_OVERRIDE_CONF =
"camel.component.aws2-s3.uriEndpointOverride";
public static final String
CAMEL_SOURCE_AWS2S3_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_SOURCE_AWS2S3_COMPONENT_URI_ENDPOINT_OVERRIDE_DEFAULT = null;
- public static final String
CAMEL_SOURCE_AWS2S3_COMPONENT_USE_IAMCREDENTIALS_CONF =
"camel.component.aws2-s3.useIAMCredentials";
- public static final String
CAMEL_SOURCE_AWS2S3_COMPONENT_USE_IAMCREDENTIALS_DOC = "Set whether the S3
client should expect to load credentials on an EC2 instance or to expect static
credentials to be passed in.";
- public static final Boolean
CAMEL_SOURCE_AWS2S3_COMPONENT_USE_IAMCREDENTIALS_DEFAULT = false;
+ public static final String
CAMEL_SOURCE_AWS2S3_COMPONENT_USE_DEFAULT_CREDENTIALS_PROVIDER_CONF =
"camel.component.aws2-s3.useDefaultCredentialsProvider";
+ public static final String
CAMEL_SOURCE_AWS2S3_COMPONENT_USE_DEFAULT_CREDENTIALS_PROVIDER_DOC = "Set
whether the S3 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_SOURCE_AWS2S3_COMPONENT_USE_DEFAULT_CREDENTIALS_PROVIDER_DEFAULT = false;
public static final String
CAMEL_SOURCE_AWS2S3_COMPONENT_CUSTOMER_ALGORITHM_CONF =
"camel.component.aws2-s3.customerAlgorithm";
public static final String
CAMEL_SOURCE_AWS2S3_COMPONENT_CUSTOMER_ALGORITHM_DOC = "Define the customer
algorithm to use in case CustomerKey is enabled";
public static final String
CAMEL_SOURCE_AWS2S3_COMPONENT_CUSTOMER_ALGORITHM_DEFAULT = null;
@@ -287,6 +293,7 @@ public class CamelAws2s3SourceConnectorConfig
ConfigDef conf = new ConfigDef(CamelSourceConnectorConfig.conf());
conf.define(CAMEL_SOURCE_AWS2S3_PATH_BUCKET_NAME_OR_ARN_CONF,
ConfigDef.Type.STRING, CAMEL_SOURCE_AWS2S3_PATH_BUCKET_NAME_OR_ARN_DEFAULT,
ConfigDef.Importance.HIGH, CAMEL_SOURCE_AWS2S3_PATH_BUCKET_NAME_OR_ARN_DOC);
conf.define(CAMEL_SOURCE_AWS2S3_ENDPOINT_AMAZON_S3CLIENT_CONF,
ConfigDef.Type.STRING, CAMEL_SOURCE_AWS2S3_ENDPOINT_AMAZON_S3CLIENT_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_AWS2S3_ENDPOINT_AMAZON_S3CLIENT_DOC);
+ conf.define(CAMEL_SOURCE_AWS2S3_ENDPOINT_AMAZON_S3PRESIGNER_CONF,
ConfigDef.Type.STRING, CAMEL_SOURCE_AWS2S3_ENDPOINT_AMAZON_S3PRESIGNER_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SOURCE_AWS2S3_ENDPOINT_AMAZON_S3PRESIGNER_DOC);
conf.define(CAMEL_SOURCE_AWS2S3_ENDPOINT_AUTO_CREATE_BUCKET_CONF,
ConfigDef.Type.BOOLEAN,
CAMEL_SOURCE_AWS2S3_ENDPOINT_AUTO_CREATE_BUCKET_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SOURCE_AWS2S3_ENDPOINT_AUTO_CREATE_BUCKET_DOC);
conf.define(CAMEL_SOURCE_AWS2S3_ENDPOINT_OVERRIDE_ENDPOINT_CONF,
ConfigDef.Type.BOOLEAN, CAMEL_SOURCE_AWS2S3_ENDPOINT_OVERRIDE_ENDPOINT_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SOURCE_AWS2S3_ENDPOINT_OVERRIDE_ENDPOINT_DOC);
conf.define(CAMEL_SOURCE_AWS2S3_ENDPOINT_POJO_REQUEST_CONF,
ConfigDef.Type.BOOLEAN, CAMEL_SOURCE_AWS2S3_ENDPOINT_POJO_REQUEST_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_AWS2S3_ENDPOINT_POJO_REQUEST_DOC);
@@ -297,7 +304,7 @@ public class CamelAws2s3SourceConnectorConfig
conf.define(CAMEL_SOURCE_AWS2S3_ENDPOINT_REGION_CONF,
ConfigDef.Type.STRING, CAMEL_SOURCE_AWS2S3_ENDPOINT_REGION_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_AWS2S3_ENDPOINT_REGION_DOC);
conf.define(CAMEL_SOURCE_AWS2S3_ENDPOINT_TRUST_ALL_CERTIFICATES_CONF,
ConfigDef.Type.BOOLEAN,
CAMEL_SOURCE_AWS2S3_ENDPOINT_TRUST_ALL_CERTIFICATES_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SOURCE_AWS2S3_ENDPOINT_TRUST_ALL_CERTIFICATES_DOC);
conf.define(CAMEL_SOURCE_AWS2S3_ENDPOINT_URI_ENDPOINT_OVERRIDE_CONF,
ConfigDef.Type.STRING,
CAMEL_SOURCE_AWS2S3_ENDPOINT_URI_ENDPOINT_OVERRIDE_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SOURCE_AWS2S3_ENDPOINT_URI_ENDPOINT_OVERRIDE_DOC);
- conf.define(CAMEL_SOURCE_AWS2S3_ENDPOINT_USE_IAMCREDENTIALS_CONF,
ConfigDef.Type.BOOLEAN,
CAMEL_SOURCE_AWS2S3_ENDPOINT_USE_IAMCREDENTIALS_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SOURCE_AWS2S3_ENDPOINT_USE_IAMCREDENTIALS_DOC);
+
conf.define(CAMEL_SOURCE_AWS2S3_ENDPOINT_USE_DEFAULT_CREDENTIALS_PROVIDER_CONF,
ConfigDef.Type.BOOLEAN,
CAMEL_SOURCE_AWS2S3_ENDPOINT_USE_DEFAULT_CREDENTIALS_PROVIDER_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SOURCE_AWS2S3_ENDPOINT_USE_DEFAULT_CREDENTIALS_PROVIDER_DOC);
conf.define(CAMEL_SOURCE_AWS2S3_ENDPOINT_CUSTOMER_ALGORITHM_CONF,
ConfigDef.Type.STRING, CAMEL_SOURCE_AWS2S3_ENDPOINT_CUSTOMER_ALGORITHM_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SOURCE_AWS2S3_ENDPOINT_CUSTOMER_ALGORITHM_DOC);
conf.define(CAMEL_SOURCE_AWS2S3_ENDPOINT_CUSTOMER_KEY_ID_CONF,
ConfigDef.Type.STRING, CAMEL_SOURCE_AWS2S3_ENDPOINT_CUSTOMER_KEY_ID_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_AWS2S3_ENDPOINT_CUSTOMER_KEY_ID_DOC);
conf.define(CAMEL_SOURCE_AWS2S3_ENDPOINT_CUSTOMER_KEY_MD5CONF,
ConfigDef.Type.STRING, CAMEL_SOURCE_AWS2S3_ENDPOINT_CUSTOMER_KEY_MD5DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_AWS2S3_ENDPOINT_CUSTOMER_KEY_MD5DOC);
@@ -337,6 +344,7 @@ public class CamelAws2s3SourceConnectorConfig
conf.define(CAMEL_SOURCE_AWS2S3_ENDPOINT_ACCESS_KEY_CONF,
ConfigDef.Type.STRING, CAMEL_SOURCE_AWS2S3_ENDPOINT_ACCESS_KEY_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_AWS2S3_ENDPOINT_ACCESS_KEY_DOC);
conf.define(CAMEL_SOURCE_AWS2S3_ENDPOINT_SECRET_KEY_CONF,
ConfigDef.Type.STRING, CAMEL_SOURCE_AWS2S3_ENDPOINT_SECRET_KEY_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_AWS2S3_ENDPOINT_SECRET_KEY_DOC);
conf.define(CAMEL_SOURCE_AWS2S3_COMPONENT_AMAZON_S3CLIENT_CONF,
ConfigDef.Type.STRING, CAMEL_SOURCE_AWS2S3_COMPONENT_AMAZON_S3CLIENT_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_AWS2S3_COMPONENT_AMAZON_S3CLIENT_DOC);
+ conf.define(CAMEL_SOURCE_AWS2S3_COMPONENT_AMAZON_S3PRESIGNER_CONF,
ConfigDef.Type.STRING,
CAMEL_SOURCE_AWS2S3_COMPONENT_AMAZON_S3PRESIGNER_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SOURCE_AWS2S3_COMPONENT_AMAZON_S3PRESIGNER_DOC);
conf.define(CAMEL_SOURCE_AWS2S3_COMPONENT_AUTO_CREATE_BUCKET_CONF,
ConfigDef.Type.BOOLEAN,
CAMEL_SOURCE_AWS2S3_COMPONENT_AUTO_CREATE_BUCKET_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SOURCE_AWS2S3_COMPONENT_AUTO_CREATE_BUCKET_DOC);
conf.define(CAMEL_SOURCE_AWS2S3_COMPONENT_CONFIGURATION_CONF,
ConfigDef.Type.STRING, CAMEL_SOURCE_AWS2S3_COMPONENT_CONFIGURATION_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_AWS2S3_COMPONENT_CONFIGURATION_DOC);
conf.define(CAMEL_SOURCE_AWS2S3_COMPONENT_OVERRIDE_ENDPOINT_CONF,
ConfigDef.Type.BOOLEAN,
CAMEL_SOURCE_AWS2S3_COMPONENT_OVERRIDE_ENDPOINT_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SOURCE_AWS2S3_COMPONENT_OVERRIDE_ENDPOINT_DOC);
@@ -348,7 +356,7 @@ public class CamelAws2s3SourceConnectorConfig
conf.define(CAMEL_SOURCE_AWS2S3_COMPONENT_REGION_CONF,
ConfigDef.Type.STRING, CAMEL_SOURCE_AWS2S3_COMPONENT_REGION_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_AWS2S3_COMPONENT_REGION_DOC);
conf.define(CAMEL_SOURCE_AWS2S3_COMPONENT_TRUST_ALL_CERTIFICATES_CONF,
ConfigDef.Type.BOOLEAN,
CAMEL_SOURCE_AWS2S3_COMPONENT_TRUST_ALL_CERTIFICATES_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SOURCE_AWS2S3_COMPONENT_TRUST_ALL_CERTIFICATES_DOC);
conf.define(CAMEL_SOURCE_AWS2S3_COMPONENT_URI_ENDPOINT_OVERRIDE_CONF,
ConfigDef.Type.STRING,
CAMEL_SOURCE_AWS2S3_COMPONENT_URI_ENDPOINT_OVERRIDE_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SOURCE_AWS2S3_COMPONENT_URI_ENDPOINT_OVERRIDE_DOC);
- conf.define(CAMEL_SOURCE_AWS2S3_COMPONENT_USE_IAMCREDENTIALS_CONF,
ConfigDef.Type.BOOLEAN,
CAMEL_SOURCE_AWS2S3_COMPONENT_USE_IAMCREDENTIALS_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SOURCE_AWS2S3_COMPONENT_USE_IAMCREDENTIALS_DOC);
+
conf.define(CAMEL_SOURCE_AWS2S3_COMPONENT_USE_DEFAULT_CREDENTIALS_PROVIDER_CONF,
ConfigDef.Type.BOOLEAN,
CAMEL_SOURCE_AWS2S3_COMPONENT_USE_DEFAULT_CREDENTIALS_PROVIDER_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SOURCE_AWS2S3_COMPONENT_USE_DEFAULT_CREDENTIALS_PROVIDER_DOC);
conf.define(CAMEL_SOURCE_AWS2S3_COMPONENT_CUSTOMER_ALGORITHM_CONF,
ConfigDef.Type.STRING,
CAMEL_SOURCE_AWS2S3_COMPONENT_CUSTOMER_ALGORITHM_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SOURCE_AWS2S3_COMPONENT_CUSTOMER_ALGORITHM_DOC);
conf.define(CAMEL_SOURCE_AWS2S3_COMPONENT_CUSTOMER_KEY_ID_CONF,
ConfigDef.Type.STRING, CAMEL_SOURCE_AWS2S3_COMPONENT_CUSTOMER_KEY_ID_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_AWS2S3_COMPONENT_CUSTOMER_KEY_ID_DOC);
conf.define(CAMEL_SOURCE_AWS2S3_COMPONENT_CUSTOMER_KEY_MD5CONF,
ConfigDef.Type.STRING, CAMEL_SOURCE_AWS2S3_COMPONENT_CUSTOMER_KEY_MD5DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_AWS2S3_COMPONENT_CUSTOMER_KEY_MD5DOC);
diff --git
a/connectors/camel-aws2-sns-kafka-connector/src/generated/resources/camel-aws2-sns-sink.json
b/connectors/camel-aws2-sns-kafka-connector/src/generated/resources/camel-aws2-sns-sink.json
index ac73001..49fb584 100644
---
a/connectors/camel-aws2-sns-kafka-connector/src/generated/resources/camel-aws2-sns-sink.json
+++
b/connectors/camel-aws2-sns-kafka-connector/src/generated/resources/camel-aws2-sns-sink.json
@@ -117,8 +117,8 @@
"priority": "MEDIUM",
"required": "false"
},
- "camel.sink.endpoint.useIAMCredentials": {
- "name": "camel.sink.endpoint.useIAMCredentials",
+ "camel.sink.endpoint.useDefaultCredentialsProvider": {
+ "name":
"camel.sink.endpoint.useDefaultCredentialsProvider",
"description": "Set whether the SQS client should
expect to load credentials on an AWS infra instance or to expect static
credentials to be passed in.",
"defaultValue": "false",
"priority": "MEDIUM",
@@ -245,8 +245,8 @@
"priority": "MEDIUM",
"required": "false"
},
- "camel.component.aws2-sns.useIAMCredentials": {
- "name": "camel.component.aws2-sns.useIAMCredentials",
+ "camel.component.aws2-sns.useDefaultCredentialsProvider": {
+ "name":
"camel.component.aws2-sns.useDefaultCredentialsProvider",
"description": "Set whether the SQS client should
expect to load credentials on an AWS infra instance or to expect static
credentials to be passed in.",
"defaultValue": "false",
"priority": "MEDIUM",
diff --git
a/connectors/camel-aws2-sns-kafka-connector/src/main/docs/camel-aws2-sns-kafka-sink-connector.adoc
b/connectors/camel-aws2-sns-kafka-connector/src/main/docs/camel-aws2-sns-kafka-sink-connector.adoc
index a3cd361..ab19b95 100644
---
a/connectors/camel-aws2-sns-kafka-connector/src/main/docs/camel-aws2-sns-kafka-sink-connector.adoc
+++
b/connectors/camel-aws2-sns-kafka-connector/src/main/docs/camel-aws2-sns-kafka-sink-connector.adoc
@@ -46,7 +46,7 @@ The camel-aws2-sns sink connector supports 41 options, which
are listed below.
| *camel.sink.endpoint.subject* | The subject which is used if the message
header 'CamelAwsSnsSubject' is not present. | null | false | MEDIUM
| *camel.sink.endpoint.subscribeSNStoSQS* | Define if the subscription between
SNS Topic and SQS must be done or not | false | 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.useIAMCredentials* | Set whether the SQS client should
expect to load credentials on an AWS infra instance or to expect static
credentials to be passed in. | false | false | MEDIUM
+| *camel.sink.endpoint.useDefaultCredentialsProvider* | Set whether the SQS
client should expect to load credentials on an AWS infra instance or to expect
static credentials to be passed in. | false | false | MEDIUM
| *camel.sink.endpoint.synchronous* | Sets whether synchronous processing
should be strictly used, or Camel is allowed to use asynchronous processing (if
supported). | 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
@@ -66,7 +66,7 @@ The camel-aws2-sns sink connector supports 41 options, which
are listed below.
| *camel.component.aws2-sns.subject* | The subject which is used if the
message header 'CamelAwsSnsSubject' is not present. | null | false | MEDIUM
| *camel.component.aws2-sns.subscribeSNStoSQS* | Define if the subscription
between SNS Topic and SQS must be done or not | false | false | MEDIUM
| *camel.component.aws2-sns.trustAllCertificates* | If we want to trust all
certificates in case of overriding the endpoint | false | false | MEDIUM
-| *camel.component.aws2-sns.useIAMCredentials* | Set whether the SQS client
should expect to load credentials on an AWS infra instance or to expect static
credentials to be passed in. | false | false | MEDIUM
+| *camel.component.aws2-sns.useDefaultCredentials Provider* | Set whether the
SQS client should expect to load credentials on an AWS infra instance or to
expect static credentials to be passed in. | false | false | MEDIUM
| *camel.component.aws2-sns.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-sns.accessKey* | Amazon AWS Access Key | null | false
| MEDIUM
| *camel.component.aws2-sns.secretKey* | Amazon AWS Secret Key | null | false
| MEDIUM
diff --git
a/connectors/camel-aws2-sns-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/aws2sns/CamelAws2snsSinkConnectorConfig.java
b/connectors/camel-aws2-sns-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/aws2sns/CamelAws2snsSinkConnectorConfig.java
index a3b957d..8756009 100644
---
a/connectors/camel-aws2-sns-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/aws2sns/CamelAws2snsSinkConnectorConfig.java
+++
b/connectors/camel-aws2-sns-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/aws2sns/CamelAws2snsSinkConnectorConfig.java
@@ -75,9 +75,9 @@ public class CamelAws2snsSinkConnectorConfig extends
CamelSinkConnectorConfig {
public static final String
CAMEL_SINK_AWS2SNS_ENDPOINT_TRUST_ALL_CERTIFICATES_CONF =
"camel.sink.endpoint.trustAllCertificates";
public static final String
CAMEL_SINK_AWS2SNS_ENDPOINT_TRUST_ALL_CERTIFICATES_DOC = "If we want to trust
all certificates in case of overriding the endpoint";
public static final Boolean
CAMEL_SINK_AWS2SNS_ENDPOINT_TRUST_ALL_CERTIFICATES_DEFAULT = false;
- public static final String
CAMEL_SINK_AWS2SNS_ENDPOINT_USE_IAMCREDENTIALS_CONF =
"camel.sink.endpoint.useIAMCredentials";
- public static final String
CAMEL_SINK_AWS2SNS_ENDPOINT_USE_IAMCREDENTIALS_DOC = "Set whether the SQS
client should expect to load credentials on an AWS infra instance or to expect
static credentials to be passed in.";
- public static final Boolean
CAMEL_SINK_AWS2SNS_ENDPOINT_USE_IAMCREDENTIALS_DEFAULT = false;
+ public static final String
CAMEL_SINK_AWS2SNS_ENDPOINT_USE_DEFAULT_CREDENTIALS_PROVIDER_CONF =
"camel.sink.endpoint.useDefaultCredentialsProvider";
+ public static final String
CAMEL_SINK_AWS2SNS_ENDPOINT_USE_DEFAULT_CREDENTIALS_PROVIDER_DOC = "Set whether
the SQS client should expect to load credentials on an AWS infra instance or to
expect static credentials to be passed in.";
+ public static final Boolean
CAMEL_SINK_AWS2SNS_ENDPOINT_USE_DEFAULT_CREDENTIALS_PROVIDER_DEFAULT = false;
public static final String CAMEL_SINK_AWS2SNS_ENDPOINT_SYNCHRONOUS_CONF =
"camel.sink.endpoint.synchronous";
public static final String CAMEL_SINK_AWS2SNS_ENDPOINT_SYNCHRONOUS_DOC =
"Sets whether synchronous processing should be strictly used, or Camel is
allowed to use asynchronous processing (if supported).";
public static final Boolean
CAMEL_SINK_AWS2SNS_ENDPOINT_SYNCHRONOUS_DEFAULT = false;
@@ -135,9 +135,9 @@ public class CamelAws2snsSinkConnectorConfig extends
CamelSinkConnectorConfig {
public static final String
CAMEL_SINK_AWS2SNS_COMPONENT_TRUST_ALL_CERTIFICATES_CONF =
"camel.component.aws2-sns.trustAllCertificates";
public static final String
CAMEL_SINK_AWS2SNS_COMPONENT_TRUST_ALL_CERTIFICATES_DOC = "If we want to trust
all certificates in case of overriding the endpoint";
public static final Boolean
CAMEL_SINK_AWS2SNS_COMPONENT_TRUST_ALL_CERTIFICATES_DEFAULT = false;
- public static final String
CAMEL_SINK_AWS2SNS_COMPONENT_USE_IAMCREDENTIALS_CONF =
"camel.component.aws2-sns.useIAMCredentials";
- public static final String
CAMEL_SINK_AWS2SNS_COMPONENT_USE_IAMCREDENTIALS_DOC = "Set whether the SQS
client should expect to load credentials on an AWS infra instance or to expect
static credentials to be passed in.";
- public static final Boolean
CAMEL_SINK_AWS2SNS_COMPONENT_USE_IAMCREDENTIALS_DEFAULT = false;
+ public static final String
CAMEL_SINK_AWS2SNS_COMPONENT_USE_DEFAULT_CREDENTIALS_PROVIDER_CONF =
"camel.component.aws2-sns.useDefaultCredentialsProvider";
+ public static final String
CAMEL_SINK_AWS2SNS_COMPONENT_USE_DEFAULT_CREDENTIALS_PROVIDER_DOC = "Set
whether the SQS client should expect to load credentials on an AWS infra
instance or to expect static credentials to be passed in.";
+ public static final Boolean
CAMEL_SINK_AWS2SNS_COMPONENT_USE_DEFAULT_CREDENTIALS_PROVIDER_DEFAULT = false;
public static final String
CAMEL_SINK_AWS2SNS_COMPONENT_AUTOWIRED_ENABLED_CONF =
"camel.component.aws2-sns.autowiredEnabled";
public static final String
CAMEL_SINK_AWS2SNS_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_AWS2SNS_COMPONENT_AUTOWIRED_ENABLED_DEFAULT = true;
@@ -177,7 +177,7 @@ public class CamelAws2snsSinkConnectorConfig extends
CamelSinkConnectorConfig {
conf.define(CAMEL_SINK_AWS2SNS_ENDPOINT_SUBJECT_CONF,
ConfigDef.Type.STRING, CAMEL_SINK_AWS2SNS_ENDPOINT_SUBJECT_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_AWS2SNS_ENDPOINT_SUBJECT_DOC);
conf.define(CAMEL_SINK_AWS2SNS_ENDPOINT_SUBSCRIBE_SNSTO_SQSCONF,
ConfigDef.Type.BOOLEAN, CAMEL_SINK_AWS2SNS_ENDPOINT_SUBSCRIBE_SNSTO_SQSDEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SINK_AWS2SNS_ENDPOINT_SUBSCRIBE_SNSTO_SQSDOC);
conf.define(CAMEL_SINK_AWS2SNS_ENDPOINT_TRUST_ALL_CERTIFICATES_CONF,
ConfigDef.Type.BOOLEAN,
CAMEL_SINK_AWS2SNS_ENDPOINT_TRUST_ALL_CERTIFICATES_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SINK_AWS2SNS_ENDPOINT_TRUST_ALL_CERTIFICATES_DOC);
- conf.define(CAMEL_SINK_AWS2SNS_ENDPOINT_USE_IAMCREDENTIALS_CONF,
ConfigDef.Type.BOOLEAN, CAMEL_SINK_AWS2SNS_ENDPOINT_USE_IAMCREDENTIALS_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SINK_AWS2SNS_ENDPOINT_USE_IAMCREDENTIALS_DOC);
+
conf.define(CAMEL_SINK_AWS2SNS_ENDPOINT_USE_DEFAULT_CREDENTIALS_PROVIDER_CONF,
ConfigDef.Type.BOOLEAN,
CAMEL_SINK_AWS2SNS_ENDPOINT_USE_DEFAULT_CREDENTIALS_PROVIDER_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SINK_AWS2SNS_ENDPOINT_USE_DEFAULT_CREDENTIALS_PROVIDER_DOC);
conf.define(CAMEL_SINK_AWS2SNS_ENDPOINT_SYNCHRONOUS_CONF,
ConfigDef.Type.BOOLEAN, CAMEL_SINK_AWS2SNS_ENDPOINT_SYNCHRONOUS_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_AWS2SNS_ENDPOINT_SYNCHRONOUS_DOC);
conf.define(CAMEL_SINK_AWS2SNS_ENDPOINT_ACCESS_KEY_CONF,
ConfigDef.Type.STRING, CAMEL_SINK_AWS2SNS_ENDPOINT_ACCESS_KEY_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_AWS2SNS_ENDPOINT_ACCESS_KEY_DOC);
conf.define(CAMEL_SINK_AWS2SNS_ENDPOINT_SECRET_KEY_CONF,
ConfigDef.Type.STRING, CAMEL_SINK_AWS2SNS_ENDPOINT_SECRET_KEY_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_AWS2SNS_ENDPOINT_SECRET_KEY_DOC);
@@ -197,7 +197,7 @@ public class CamelAws2snsSinkConnectorConfig extends
CamelSinkConnectorConfig {
conf.define(CAMEL_SINK_AWS2SNS_COMPONENT_SUBJECT_CONF,
ConfigDef.Type.STRING, CAMEL_SINK_AWS2SNS_COMPONENT_SUBJECT_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_AWS2SNS_COMPONENT_SUBJECT_DOC);
conf.define(CAMEL_SINK_AWS2SNS_COMPONENT_SUBSCRIBE_SNSTO_SQSCONF,
ConfigDef.Type.BOOLEAN,
CAMEL_SINK_AWS2SNS_COMPONENT_SUBSCRIBE_SNSTO_SQSDEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SINK_AWS2SNS_COMPONENT_SUBSCRIBE_SNSTO_SQSDOC);
conf.define(CAMEL_SINK_AWS2SNS_COMPONENT_TRUST_ALL_CERTIFICATES_CONF,
ConfigDef.Type.BOOLEAN,
CAMEL_SINK_AWS2SNS_COMPONENT_TRUST_ALL_CERTIFICATES_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SINK_AWS2SNS_COMPONENT_TRUST_ALL_CERTIFICATES_DOC);
- conf.define(CAMEL_SINK_AWS2SNS_COMPONENT_USE_IAMCREDENTIALS_CONF,
ConfigDef.Type.BOOLEAN,
CAMEL_SINK_AWS2SNS_COMPONENT_USE_IAMCREDENTIALS_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SINK_AWS2SNS_COMPONENT_USE_IAMCREDENTIALS_DOC);
+
conf.define(CAMEL_SINK_AWS2SNS_COMPONENT_USE_DEFAULT_CREDENTIALS_PROVIDER_CONF,
ConfigDef.Type.BOOLEAN,
CAMEL_SINK_AWS2SNS_COMPONENT_USE_DEFAULT_CREDENTIALS_PROVIDER_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SINK_AWS2SNS_COMPONENT_USE_DEFAULT_CREDENTIALS_PROVIDER_DOC);
conf.define(CAMEL_SINK_AWS2SNS_COMPONENT_AUTOWIRED_ENABLED_CONF,
ConfigDef.Type.BOOLEAN, CAMEL_SINK_AWS2SNS_COMPONENT_AUTOWIRED_ENABLED_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SINK_AWS2SNS_COMPONENT_AUTOWIRED_ENABLED_DOC);
conf.define(CAMEL_SINK_AWS2SNS_COMPONENT_ACCESS_KEY_CONF,
ConfigDef.Type.STRING, CAMEL_SINK_AWS2SNS_COMPONENT_ACCESS_KEY_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_AWS2SNS_COMPONENT_ACCESS_KEY_DOC);
conf.define(CAMEL_SINK_AWS2SNS_COMPONENT_SECRET_KEY_CONF,
ConfigDef.Type.STRING, CAMEL_SINK_AWS2SNS_COMPONENT_SECRET_KEY_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_AWS2SNS_COMPONENT_SECRET_KEY_DOC);
diff --git
a/connectors/camel-aws2-sqs-kafka-connector/src/generated/resources/camel-aws2-sqs-sink.json
b/connectors/camel-aws2-sqs-kafka-connector/src/generated/resources/camel-aws2-sqs-sink.json
index fcbf868..f731da7 100644
---
a/connectors/camel-aws2-sqs-kafka-connector/src/generated/resources/camel-aws2-sqs-sink.json
+++
b/connectors/camel-aws2-sqs-kafka-connector/src/generated/resources/camel-aws2-sqs-sink.json
@@ -74,8 +74,8 @@
"priority": "MEDIUM",
"required": "false"
},
- "camel.sink.endpoint.useIAMCredentials": {
- "name": "camel.sink.endpoint.useIAMCredentials",
+ "camel.sink.endpoint.useDefaultCredentialsProvider": {
+ "name":
"camel.sink.endpoint.useDefaultCredentialsProvider",
"description": "Set whether the SQS client should
expect to load credentials on an AWS infra instance or to expect static
credentials to be passed in.",
"defaultValue": "false",
"priority": "MEDIUM",
@@ -246,8 +246,8 @@
"priority": "MEDIUM",
"required": "false"
},
- "camel.component.aws2-sqs.useIAMCredentials": {
- "name": "camel.component.aws2-sqs.useIAMCredentials",
+ "camel.component.aws2-sqs.useDefaultCredentialsProvider": {
+ "name":
"camel.component.aws2-sqs.useDefaultCredentialsProvider",
"description": "Set whether the SQS client should
expect to load credentials on an AWS infra instance or to expect static
credentials to be passed in.",
"defaultValue": "false",
"priority": "MEDIUM",
diff --git
a/connectors/camel-aws2-sqs-kafka-connector/src/generated/resources/camel-aws2-sqs-source.json
b/connectors/camel-aws2-sqs-kafka-connector/src/generated/resources/camel-aws2-sqs-source.json
index ff4c0b8..03e382c 100644
---
a/connectors/camel-aws2-sqs-kafka-connector/src/generated/resources/camel-aws2-sqs-source.json
+++
b/connectors/camel-aws2-sqs-kafka-connector/src/generated/resources/camel-aws2-sqs-source.json
@@ -74,8 +74,8 @@
"priority": "MEDIUM",
"required": "false"
},
- "camel.source.endpoint.useIAMCredentials": {
- "name": "camel.source.endpoint.useIAMCredentials",
+ "camel.source.endpoint.useDefaultCredentialsProvider": {
+ "name":
"camel.source.endpoint.useDefaultCredentialsProvider",
"description": "Set whether the SQS client should
expect to load credentials on an AWS infra instance or to expect static
credentials to be passed in.",
"defaultValue": "false",
"priority": "MEDIUM",
@@ -422,8 +422,8 @@
"priority": "MEDIUM",
"required": "false"
},
- "camel.component.aws2-sqs.useIAMCredentials": {
- "name": "camel.component.aws2-sqs.useIAMCredentials",
+ "camel.component.aws2-sqs.useDefaultCredentialsProvider": {
+ "name":
"camel.component.aws2-sqs.useDefaultCredentialsProvider",
"description": "Set whether the SQS client should
expect to load credentials on an AWS infra instance or to expect static
credentials to be passed in.",
"defaultValue": "false",
"priority": "MEDIUM",
diff --git
a/connectors/camel-aws2-sqs-kafka-connector/src/main/docs/camel-aws2-sqs-kafka-sink-connector.adoc
b/connectors/camel-aws2-sqs-kafka-connector/src/main/docs/camel-aws2-sqs-kafka-sink-connector.adoc
index 3cc4922..636d972 100644
---
a/connectors/camel-aws2-sqs-kafka-connector/src/main/docs/camel-aws2-sqs-kafka-sink-connector.adoc
+++
b/connectors/camel-aws2-sqs-kafka-connector/src/main/docs/camel-aws2-sqs-kafka-sink-connector.adoc
@@ -39,7 +39,7 @@ The camel-aws2-sqs sink connector supports 55 options, which
are listed below.
| *camel.sink.endpoint.queueOwnerAWSAccountId* | Specify the queue owner aws
account id when you need to connect the queue with different account owner. |
null | false | MEDIUM
| *camel.sink.endpoint.region* | The region in which SQS 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.useIAMCredentials* | Set whether the SQS client should
expect to load credentials on an AWS infra instance or to expect static
credentials to be passed in. | false | false | MEDIUM
+| *camel.sink.endpoint.useDefaultCredentialsProvider* | Set whether the SQS
client should expect to load credentials on an AWS infra instance or to expect
static credentials to be passed in. | false | false | MEDIUM
| *camel.sink.endpoint.delaySeconds* | Delay sending messages for a number of
seconds. | null | false | MEDIUM
| *camel.sink.endpoint.lazyStartProducer* | Whether the producer should be
started lazy (on the first message). By starting lazy you can use this to allow
CamelContext and routes to startup in situations where a producer may otherwise
fail during starting and cause the route to fail being started. By deferring
this startup to be lazy then the startup failure can be handled during routing
messages via Camel's routing error handlers. Beware that when the first message
is processed then cre [...]
| *camel.sink.endpoint.messageDeduplicationIdStrategy* | Only for FIFO queues.
Strategy for setting the messageDeduplicationId on the message. Can be one of
the following options: useExchangeId, useContentBasedDeduplication. For the
useContentBasedDeduplication option, no messageDeduplicationId will be set on
the message. One of: [useExchangeId] [useContentBasedDeduplication] |
"useExchangeId" | false | MEDIUM
@@ -66,7 +66,7 @@ The camel-aws2-sqs sink connector supports 55 options, which
are listed below.
| *camel.component.aws2-sqs.queueOwnerAWSAccountId* | Specify the queue owner
aws account id when you need to connect the queue with different account owner.
| null | false | MEDIUM
| *camel.component.aws2-sqs.region* | The region in which SQS 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-sqs.trustAllCertificates* | If we want to trust all
certificates in case of overriding the endpoint | false | false | MEDIUM
-| *camel.component.aws2-sqs.useIAMCredentials* | Set whether the SQS client
should expect to load credentials on an AWS infra instance or to expect static
credentials to be passed in. | false | false | MEDIUM
+| *camel.component.aws2-sqs.useDefaultCredentials Provider* | Set whether the
SQS client should expect to load credentials on an AWS infra instance or to
expect static credentials to be passed in. | false | false | MEDIUM
| *camel.component.aws2-sqs.delaySeconds* | Delay sending messages for a
number of seconds. | null | false | MEDIUM
| *camel.component.aws2-sqs.lazyStartProducer* | Whether the producer should
be started lazy (on the first message). By starting lazy you can use this to
allow CamelContext and routes to startup in situations where a producer may
otherwise fail during starting and cause the route to fail being started. By
deferring this startup to be lazy then the startup failure can be handled
during routing messages via Camel's routing error handlers. Beware that when
the first message is processed the [...]
| *camel.component.aws2-sqs.messageDeduplicationId Strategy* | Only for FIFO
queues. Strategy for setting the messageDeduplicationId on the message. Can be
one of the following options: useExchangeId, useContentBasedDeduplication. For
the useContentBasedDeduplication option, no messageDeduplicationId will be set
on the message. One of: [useExchangeId] [useContentBasedDeduplication] |
"useExchangeId" | false | MEDIUM
diff --git
a/connectors/camel-aws2-sqs-kafka-connector/src/main/docs/camel-aws2-sqs-kafka-source-connector.adoc
b/connectors/camel-aws2-sqs-kafka-connector/src/main/docs/camel-aws2-sqs-kafka-source-connector.adoc
index ed8e159..43cdb98 100644
---
a/connectors/camel-aws2-sqs-kafka-connector/src/main/docs/camel-aws2-sqs-kafka-source-connector.adoc
+++
b/connectors/camel-aws2-sqs-kafka-connector/src/main/docs/camel-aws2-sqs-kafka-source-connector.adoc
@@ -39,7 +39,7 @@ The camel-aws2-sqs source connector supports 90 options,
which are listed below.
| *camel.source.endpoint.queueOwnerAWSAccountId* | Specify the queue owner aws
account id when you need to connect the queue with different account owner. |
null | false | MEDIUM
| *camel.source.endpoint.region* | The region in which SQS 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.source.endpoint.trustAllCertificates* | If we want to trust all
certificates in case of overriding the endpoint | false | false | MEDIUM
-| *camel.source.endpoint.useIAMCredentials* | Set whether the SQS client
should expect to load credentials on an AWS infra instance or to expect static
credentials to be passed in. | false | false | MEDIUM
+| *camel.source.endpoint.useDefaultCredentials Provider* | Set whether the SQS
client should expect to load credentials on an AWS infra instance or to expect
static credentials to be passed in. | false | false | MEDIUM
| *camel.source.endpoint.attributeNames* | A list of attribute names to
receive when consuming. Multiple names can be separated by comma. | null |
false | MEDIUM
| *camel.source.endpoint.bridgeErrorHandler* | Allows for bridging the
consumer to the Camel routing Error Handler, which mean any exceptions occurred
while the consumer is trying to pickup incoming messages, or the likes, will
now be processed as a message and handled by the routing Error Handler. By
default the consumer will use the org.apache.camel.spi.ExceptionHandler to deal
with exceptions, that will be logged at WARN or ERROR level and ignored. |
false | false | MEDIUM
| *camel.source.endpoint.concurrentConsumers* | Allows you to use multiple
threads to poll the sqs queue to increase throughput | 1 | false | MEDIUM
@@ -93,7 +93,7 @@ The camel-aws2-sqs source connector supports 90 options,
which are listed below.
| *camel.component.aws2-sqs.queueOwnerAWSAccountId* | Specify the queue owner
aws account id when you need to connect the queue with different account owner.
| null | false | MEDIUM
| *camel.component.aws2-sqs.region* | The region in which SQS 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-sqs.trustAllCertificates* | If we want to trust all
certificates in case of overriding the endpoint | false | false | MEDIUM
-| *camel.component.aws2-sqs.useIAMCredentials* | Set whether the SQS client
should expect to load credentials on an AWS infra instance or to expect static
credentials to be passed in. | false | false | MEDIUM
+| *camel.component.aws2-sqs.useDefaultCredentials Provider* | Set whether the
SQS client should expect to load credentials on an AWS infra instance or to
expect static credentials to be passed in. | false | false | MEDIUM
| *camel.component.aws2-sqs.attributeNames* | A list of attribute names to
receive when consuming. Multiple names can be separated by comma. | null |
false | MEDIUM
| *camel.component.aws2-sqs.bridgeErrorHandler* | Allows for bridging the
consumer to the Camel routing Error Handler, which mean any exceptions occurred
while the consumer is trying to pickup incoming messages, or the likes, will
now be processed as a message and handled by the routing Error Handler. By
default the consumer will use the org.apache.camel.spi.ExceptionHandler to deal
with exceptions, that will be logged at WARN or ERROR level and ignored. |
false | false | MEDIUM
| *camel.component.aws2-sqs.concurrentConsumers* | Allows you to use multiple
threads to poll the sqs queue to increase throughput | 1 | false | MEDIUM
diff --git
a/connectors/camel-aws2-sqs-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/aws2sqs/CamelAws2sqsSinkConnectorConfig.java
b/connectors/camel-aws2-sqs-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/aws2sqs/CamelAws2sqsSinkConnectorConfig.java
index e974de5..47fb020 100644
---
a/connectors/camel-aws2-sqs-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/aws2sqs/CamelAws2sqsSinkConnectorConfig.java
+++
b/connectors/camel-aws2-sqs-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/aws2sqs/CamelAws2sqsSinkConnectorConfig.java
@@ -54,9 +54,9 @@ public class CamelAws2sqsSinkConnectorConfig extends
CamelSinkConnectorConfig {
public static final String
CAMEL_SINK_AWS2SQS_ENDPOINT_TRUST_ALL_CERTIFICATES_CONF =
"camel.sink.endpoint.trustAllCertificates";
public static final String
CAMEL_SINK_AWS2SQS_ENDPOINT_TRUST_ALL_CERTIFICATES_DOC = "If we want to trust
all certificates in case of overriding the endpoint";
public static final Boolean
CAMEL_SINK_AWS2SQS_ENDPOINT_TRUST_ALL_CERTIFICATES_DEFAULT = false;
- public static final String
CAMEL_SINK_AWS2SQS_ENDPOINT_USE_IAMCREDENTIALS_CONF =
"camel.sink.endpoint.useIAMCredentials";
- public static final String
CAMEL_SINK_AWS2SQS_ENDPOINT_USE_IAMCREDENTIALS_DOC = "Set whether the SQS
client should expect to load credentials on an AWS infra instance or to expect
static credentials to be passed in.";
- public static final Boolean
CAMEL_SINK_AWS2SQS_ENDPOINT_USE_IAMCREDENTIALS_DEFAULT = false;
+ public static final String
CAMEL_SINK_AWS2SQS_ENDPOINT_USE_DEFAULT_CREDENTIALS_PROVIDER_CONF =
"camel.sink.endpoint.useDefaultCredentialsProvider";
+ public static final String
CAMEL_SINK_AWS2SQS_ENDPOINT_USE_DEFAULT_CREDENTIALS_PROVIDER_DOC = "Set whether
the SQS client should expect to load credentials on an AWS infra instance or to
expect static credentials to be passed in.";
+ public static final Boolean
CAMEL_SINK_AWS2SQS_ENDPOINT_USE_DEFAULT_CREDENTIALS_PROVIDER_DEFAULT = false;
public static final String CAMEL_SINK_AWS2SQS_ENDPOINT_DELAY_SECONDS_CONF
= "camel.sink.endpoint.delaySeconds";
public static final String CAMEL_SINK_AWS2SQS_ENDPOINT_DELAY_SECONDS_DOC =
"Delay sending messages for a number of seconds.";
public static final String
CAMEL_SINK_AWS2SQS_ENDPOINT_DELAY_SECONDS_DEFAULT = null;
@@ -135,9 +135,9 @@ public class CamelAws2sqsSinkConnectorConfig extends
CamelSinkConnectorConfig {
public static final String
CAMEL_SINK_AWS2SQS_COMPONENT_TRUST_ALL_CERTIFICATES_CONF =
"camel.component.aws2-sqs.trustAllCertificates";
public static final String
CAMEL_SINK_AWS2SQS_COMPONENT_TRUST_ALL_CERTIFICATES_DOC = "If we want to trust
all certificates in case of overriding the endpoint";
public static final Boolean
CAMEL_SINK_AWS2SQS_COMPONENT_TRUST_ALL_CERTIFICATES_DEFAULT = false;
- public static final String
CAMEL_SINK_AWS2SQS_COMPONENT_USE_IAMCREDENTIALS_CONF =
"camel.component.aws2-sqs.useIAMCredentials";
- public static final String
CAMEL_SINK_AWS2SQS_COMPONENT_USE_IAMCREDENTIALS_DOC = "Set whether the SQS
client should expect to load credentials on an AWS infra instance or to expect
static credentials to be passed in.";
- public static final Boolean
CAMEL_SINK_AWS2SQS_COMPONENT_USE_IAMCREDENTIALS_DEFAULT = false;
+ public static final String
CAMEL_SINK_AWS2SQS_COMPONENT_USE_DEFAULT_CREDENTIALS_PROVIDER_CONF =
"camel.component.aws2-sqs.useDefaultCredentialsProvider";
+ public static final String
CAMEL_SINK_AWS2SQS_COMPONENT_USE_DEFAULT_CREDENTIALS_PROVIDER_DOC = "Set
whether the SQS client should expect to load credentials on an AWS infra
instance or to expect static credentials to be passed in.";
+ public static final Boolean
CAMEL_SINK_AWS2SQS_COMPONENT_USE_DEFAULT_CREDENTIALS_PROVIDER_DEFAULT = false;
public static final String CAMEL_SINK_AWS2SQS_COMPONENT_DELAY_SECONDS_CONF
= "camel.component.aws2-sqs.delaySeconds";
public static final String CAMEL_SINK_AWS2SQS_COMPONENT_DELAY_SECONDS_DOC
= "Delay sending messages for a number of seconds.";
public static final String
CAMEL_SINK_AWS2SQS_COMPONENT_DELAY_SECONDS_DEFAULT = null;
@@ -212,7 +212,7 @@ public class CamelAws2sqsSinkConnectorConfig extends
CamelSinkConnectorConfig {
conf.define(CAMEL_SINK_AWS2SQS_ENDPOINT_QUEUE_OWNER_AWSACCOUNT_ID_CONF,
ConfigDef.Type.STRING,
CAMEL_SINK_AWS2SQS_ENDPOINT_QUEUE_OWNER_AWSACCOUNT_ID_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SINK_AWS2SQS_ENDPOINT_QUEUE_OWNER_AWSACCOUNT_ID_DOC);
conf.define(CAMEL_SINK_AWS2SQS_ENDPOINT_REGION_CONF,
ConfigDef.Type.STRING, CAMEL_SINK_AWS2SQS_ENDPOINT_REGION_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_AWS2SQS_ENDPOINT_REGION_DOC);
conf.define(CAMEL_SINK_AWS2SQS_ENDPOINT_TRUST_ALL_CERTIFICATES_CONF,
ConfigDef.Type.BOOLEAN,
CAMEL_SINK_AWS2SQS_ENDPOINT_TRUST_ALL_CERTIFICATES_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SINK_AWS2SQS_ENDPOINT_TRUST_ALL_CERTIFICATES_DOC);
- conf.define(CAMEL_SINK_AWS2SQS_ENDPOINT_USE_IAMCREDENTIALS_CONF,
ConfigDef.Type.BOOLEAN, CAMEL_SINK_AWS2SQS_ENDPOINT_USE_IAMCREDENTIALS_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SINK_AWS2SQS_ENDPOINT_USE_IAMCREDENTIALS_DOC);
+
conf.define(CAMEL_SINK_AWS2SQS_ENDPOINT_USE_DEFAULT_CREDENTIALS_PROVIDER_CONF,
ConfigDef.Type.BOOLEAN,
CAMEL_SINK_AWS2SQS_ENDPOINT_USE_DEFAULT_CREDENTIALS_PROVIDER_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SINK_AWS2SQS_ENDPOINT_USE_DEFAULT_CREDENTIALS_PROVIDER_DOC);
conf.define(CAMEL_SINK_AWS2SQS_ENDPOINT_DELAY_SECONDS_CONF,
ConfigDef.Type.STRING, CAMEL_SINK_AWS2SQS_ENDPOINT_DELAY_SECONDS_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_AWS2SQS_ENDPOINT_DELAY_SECONDS_DOC);
conf.define(CAMEL_SINK_AWS2SQS_ENDPOINT_LAZY_START_PRODUCER_CONF,
ConfigDef.Type.BOOLEAN,
CAMEL_SINK_AWS2SQS_ENDPOINT_LAZY_START_PRODUCER_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SINK_AWS2SQS_ENDPOINT_LAZY_START_PRODUCER_DOC);
conf.define(CAMEL_SINK_AWS2SQS_ENDPOINT_MESSAGE_DEDUPLICATION_ID_STRATEGY_CONF,
ConfigDef.Type.STRING,
CAMEL_SINK_AWS2SQS_ENDPOINT_MESSAGE_DEDUPLICATION_ID_STRATEGY_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SINK_AWS2SQS_ENDPOINT_MESSAGE_DEDUPLICATION_ID_STRATEGY_DOC);
@@ -239,7 +239,7 @@ public class CamelAws2sqsSinkConnectorConfig extends
CamelSinkConnectorConfig {
conf.define(CAMEL_SINK_AWS2SQS_COMPONENT_QUEUE_OWNER_AWSACCOUNT_ID_CONF,
ConfigDef.Type.STRING,
CAMEL_SINK_AWS2SQS_COMPONENT_QUEUE_OWNER_AWSACCOUNT_ID_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SINK_AWS2SQS_COMPONENT_QUEUE_OWNER_AWSACCOUNT_ID_DOC);
conf.define(CAMEL_SINK_AWS2SQS_COMPONENT_REGION_CONF,
ConfigDef.Type.STRING, CAMEL_SINK_AWS2SQS_COMPONENT_REGION_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_AWS2SQS_COMPONENT_REGION_DOC);
conf.define(CAMEL_SINK_AWS2SQS_COMPONENT_TRUST_ALL_CERTIFICATES_CONF,
ConfigDef.Type.BOOLEAN,
CAMEL_SINK_AWS2SQS_COMPONENT_TRUST_ALL_CERTIFICATES_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SINK_AWS2SQS_COMPONENT_TRUST_ALL_CERTIFICATES_DOC);
- conf.define(CAMEL_SINK_AWS2SQS_COMPONENT_USE_IAMCREDENTIALS_CONF,
ConfigDef.Type.BOOLEAN,
CAMEL_SINK_AWS2SQS_COMPONENT_USE_IAMCREDENTIALS_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SINK_AWS2SQS_COMPONENT_USE_IAMCREDENTIALS_DOC);
+
conf.define(CAMEL_SINK_AWS2SQS_COMPONENT_USE_DEFAULT_CREDENTIALS_PROVIDER_CONF,
ConfigDef.Type.BOOLEAN,
CAMEL_SINK_AWS2SQS_COMPONENT_USE_DEFAULT_CREDENTIALS_PROVIDER_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SINK_AWS2SQS_COMPONENT_USE_DEFAULT_CREDENTIALS_PROVIDER_DOC);
conf.define(CAMEL_SINK_AWS2SQS_COMPONENT_DELAY_SECONDS_CONF,
ConfigDef.Type.STRING, CAMEL_SINK_AWS2SQS_COMPONENT_DELAY_SECONDS_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_AWS2SQS_COMPONENT_DELAY_SECONDS_DOC);
conf.define(CAMEL_SINK_AWS2SQS_COMPONENT_LAZY_START_PRODUCER_CONF,
ConfigDef.Type.BOOLEAN,
CAMEL_SINK_AWS2SQS_COMPONENT_LAZY_START_PRODUCER_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SINK_AWS2SQS_COMPONENT_LAZY_START_PRODUCER_DOC);
conf.define(CAMEL_SINK_AWS2SQS_COMPONENT_MESSAGE_DEDUPLICATION_ID_STRATEGY_CONF,
ConfigDef.Type.STRING,
CAMEL_SINK_AWS2SQS_COMPONENT_MESSAGE_DEDUPLICATION_ID_STRATEGY_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SINK_AWS2SQS_COMPONENT_MESSAGE_DEDUPLICATION_ID_STRATEGY_DOC);
diff --git
a/connectors/camel-aws2-sqs-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/aws2sqs/CamelAws2sqsSourceConnectorConfig.java
b/connectors/camel-aws2-sqs-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/aws2sqs/CamelAws2sqsSourceConnectorConfig.java
index d5e48af..4146bc4 100644
---
a/connectors/camel-aws2-sqs-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/aws2sqs/CamelAws2sqsSourceConnectorConfig.java
+++
b/connectors/camel-aws2-sqs-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/aws2sqs/CamelAws2sqsSourceConnectorConfig.java
@@ -56,9 +56,9 @@ public class CamelAws2sqsSourceConnectorConfig
public static final String
CAMEL_SOURCE_AWS2SQS_ENDPOINT_TRUST_ALL_CERTIFICATES_CONF =
"camel.source.endpoint.trustAllCertificates";
public static final String
CAMEL_SOURCE_AWS2SQS_ENDPOINT_TRUST_ALL_CERTIFICATES_DOC = "If we want to trust
all certificates in case of overriding the endpoint";
public static final Boolean
CAMEL_SOURCE_AWS2SQS_ENDPOINT_TRUST_ALL_CERTIFICATES_DEFAULT = false;
- public static final String
CAMEL_SOURCE_AWS2SQS_ENDPOINT_USE_IAMCREDENTIALS_CONF =
"camel.source.endpoint.useIAMCredentials";
- public static final String
CAMEL_SOURCE_AWS2SQS_ENDPOINT_USE_IAMCREDENTIALS_DOC = "Set whether the SQS
client should expect to load credentials on an AWS infra instance or to expect
static credentials to be passed in.";
- public static final Boolean
CAMEL_SOURCE_AWS2SQS_ENDPOINT_USE_IAMCREDENTIALS_DEFAULT = false;
+ public static final String
CAMEL_SOURCE_AWS2SQS_ENDPOINT_USE_DEFAULT_CREDENTIALS_PROVIDER_CONF =
"camel.source.endpoint.useDefaultCredentialsProvider";
+ public static final String
CAMEL_SOURCE_AWS2SQS_ENDPOINT_USE_DEFAULT_CREDENTIALS_PROVIDER_DOC = "Set
whether the SQS client should expect to load credentials on an AWS infra
instance or to expect static credentials to be passed in.";
+ public static final Boolean
CAMEL_SOURCE_AWS2SQS_ENDPOINT_USE_DEFAULT_CREDENTIALS_PROVIDER_DEFAULT = false;
public static final String
CAMEL_SOURCE_AWS2SQS_ENDPOINT_ATTRIBUTE_NAMES_CONF =
"camel.source.endpoint.attributeNames";
public static final String
CAMEL_SOURCE_AWS2SQS_ENDPOINT_ATTRIBUTE_NAMES_DOC = "A list of attribute names
to receive when consuming. Multiple names can be separated by comma.";
public static final String
CAMEL_SOURCE_AWS2SQS_ENDPOINT_ATTRIBUTE_NAMES_DEFAULT = null;
@@ -218,9 +218,9 @@ public class CamelAws2sqsSourceConnectorConfig
public static final String
CAMEL_SOURCE_AWS2SQS_COMPONENT_TRUST_ALL_CERTIFICATES_CONF =
"camel.component.aws2-sqs.trustAllCertificates";
public static final String
CAMEL_SOURCE_AWS2SQS_COMPONENT_TRUST_ALL_CERTIFICATES_DOC = "If we want to
trust all certificates in case of overriding the endpoint";
public static final Boolean
CAMEL_SOURCE_AWS2SQS_COMPONENT_TRUST_ALL_CERTIFICATES_DEFAULT = false;
- public static final String
CAMEL_SOURCE_AWS2SQS_COMPONENT_USE_IAMCREDENTIALS_CONF =
"camel.component.aws2-sqs.useIAMCredentials";
- public static final String
CAMEL_SOURCE_AWS2SQS_COMPONENT_USE_IAMCREDENTIALS_DOC = "Set whether the SQS
client should expect to load credentials on an AWS infra instance or to expect
static credentials to be passed in.";
- public static final Boolean
CAMEL_SOURCE_AWS2SQS_COMPONENT_USE_IAMCREDENTIALS_DEFAULT = false;
+ public static final String
CAMEL_SOURCE_AWS2SQS_COMPONENT_USE_DEFAULT_CREDENTIALS_PROVIDER_CONF =
"camel.component.aws2-sqs.useDefaultCredentialsProvider";
+ public static final String
CAMEL_SOURCE_AWS2SQS_COMPONENT_USE_DEFAULT_CREDENTIALS_PROVIDER_DOC = "Set
whether the SQS client should expect to load credentials on an AWS infra
instance or to expect static credentials to be passed in.";
+ public static final Boolean
CAMEL_SOURCE_AWS2SQS_COMPONENT_USE_DEFAULT_CREDENTIALS_PROVIDER_DEFAULT = false;
public static final String
CAMEL_SOURCE_AWS2SQS_COMPONENT_ATTRIBUTE_NAMES_CONF =
"camel.component.aws2-sqs.attributeNames";
public static final String
CAMEL_SOURCE_AWS2SQS_COMPONENT_ATTRIBUTE_NAMES_DOC = "A list of attribute names
to receive when consuming. Multiple names can be separated by comma.";
public static final String
CAMEL_SOURCE_AWS2SQS_COMPONENT_ATTRIBUTE_NAMES_DEFAULT = null;
@@ -319,7 +319,7 @@ public class CamelAws2sqsSourceConnectorConfig
conf.define(CAMEL_SOURCE_AWS2SQS_ENDPOINT_QUEUE_OWNER_AWSACCOUNT_ID_CONF,
ConfigDef.Type.STRING,
CAMEL_SOURCE_AWS2SQS_ENDPOINT_QUEUE_OWNER_AWSACCOUNT_ID_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SOURCE_AWS2SQS_ENDPOINT_QUEUE_OWNER_AWSACCOUNT_ID_DOC);
conf.define(CAMEL_SOURCE_AWS2SQS_ENDPOINT_REGION_CONF,
ConfigDef.Type.STRING, CAMEL_SOURCE_AWS2SQS_ENDPOINT_REGION_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_AWS2SQS_ENDPOINT_REGION_DOC);
conf.define(CAMEL_SOURCE_AWS2SQS_ENDPOINT_TRUST_ALL_CERTIFICATES_CONF,
ConfigDef.Type.BOOLEAN,
CAMEL_SOURCE_AWS2SQS_ENDPOINT_TRUST_ALL_CERTIFICATES_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SOURCE_AWS2SQS_ENDPOINT_TRUST_ALL_CERTIFICATES_DOC);
- conf.define(CAMEL_SOURCE_AWS2SQS_ENDPOINT_USE_IAMCREDENTIALS_CONF,
ConfigDef.Type.BOOLEAN,
CAMEL_SOURCE_AWS2SQS_ENDPOINT_USE_IAMCREDENTIALS_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SOURCE_AWS2SQS_ENDPOINT_USE_IAMCREDENTIALS_DOC);
+
conf.define(CAMEL_SOURCE_AWS2SQS_ENDPOINT_USE_DEFAULT_CREDENTIALS_PROVIDER_CONF,
ConfigDef.Type.BOOLEAN,
CAMEL_SOURCE_AWS2SQS_ENDPOINT_USE_DEFAULT_CREDENTIALS_PROVIDER_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SOURCE_AWS2SQS_ENDPOINT_USE_DEFAULT_CREDENTIALS_PROVIDER_DOC);
conf.define(CAMEL_SOURCE_AWS2SQS_ENDPOINT_ATTRIBUTE_NAMES_CONF,
ConfigDef.Type.STRING, CAMEL_SOURCE_AWS2SQS_ENDPOINT_ATTRIBUTE_NAMES_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_AWS2SQS_ENDPOINT_ATTRIBUTE_NAMES_DOC);
conf.define(CAMEL_SOURCE_AWS2SQS_ENDPOINT_BRIDGE_ERROR_HANDLER_CONF,
ConfigDef.Type.BOOLEAN,
CAMEL_SOURCE_AWS2SQS_ENDPOINT_BRIDGE_ERROR_HANDLER_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SOURCE_AWS2SQS_ENDPOINT_BRIDGE_ERROR_HANDLER_DOC);
conf.define(CAMEL_SOURCE_AWS2SQS_ENDPOINT_CONCURRENT_CONSUMERS_CONF,
ConfigDef.Type.INT, CAMEL_SOURCE_AWS2SQS_ENDPOINT_CONCURRENT_CONSUMERS_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SOURCE_AWS2SQS_ENDPOINT_CONCURRENT_CONSUMERS_DOC);
@@ -373,7 +373,7 @@ public class CamelAws2sqsSourceConnectorConfig
conf.define(CAMEL_SOURCE_AWS2SQS_COMPONENT_QUEUE_OWNER_AWSACCOUNT_ID_CONF,
ConfigDef.Type.STRING,
CAMEL_SOURCE_AWS2SQS_COMPONENT_QUEUE_OWNER_AWSACCOUNT_ID_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SOURCE_AWS2SQS_COMPONENT_QUEUE_OWNER_AWSACCOUNT_ID_DOC);
conf.define(CAMEL_SOURCE_AWS2SQS_COMPONENT_REGION_CONF,
ConfigDef.Type.STRING, CAMEL_SOURCE_AWS2SQS_COMPONENT_REGION_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SOURCE_AWS2SQS_COMPONENT_REGION_DOC);
conf.define(CAMEL_SOURCE_AWS2SQS_COMPONENT_TRUST_ALL_CERTIFICATES_CONF,
ConfigDef.Type.BOOLEAN,
CAMEL_SOURCE_AWS2SQS_COMPONENT_TRUST_ALL_CERTIFICATES_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SOURCE_AWS2SQS_COMPONENT_TRUST_ALL_CERTIFICATES_DOC);
- conf.define(CAMEL_SOURCE_AWS2SQS_COMPONENT_USE_IAMCREDENTIALS_CONF,
ConfigDef.Type.BOOLEAN,
CAMEL_SOURCE_AWS2SQS_COMPONENT_USE_IAMCREDENTIALS_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SOURCE_AWS2SQS_COMPONENT_USE_IAMCREDENTIALS_DOC);
+
conf.define(CAMEL_SOURCE_AWS2SQS_COMPONENT_USE_DEFAULT_CREDENTIALS_PROVIDER_CONF,
ConfigDef.Type.BOOLEAN,
CAMEL_SOURCE_AWS2SQS_COMPONENT_USE_DEFAULT_CREDENTIALS_PROVIDER_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SOURCE_AWS2SQS_COMPONENT_USE_DEFAULT_CREDENTIALS_PROVIDER_DOC);
conf.define(CAMEL_SOURCE_AWS2SQS_COMPONENT_ATTRIBUTE_NAMES_CONF,
ConfigDef.Type.STRING, CAMEL_SOURCE_AWS2SQS_COMPONENT_ATTRIBUTE_NAMES_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SOURCE_AWS2SQS_COMPONENT_ATTRIBUTE_NAMES_DOC);
conf.define(CAMEL_SOURCE_AWS2SQS_COMPONENT_BRIDGE_ERROR_HANDLER_CONF,
ConfigDef.Type.BOOLEAN,
CAMEL_SOURCE_AWS2SQS_COMPONENT_BRIDGE_ERROR_HANDLER_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SOURCE_AWS2SQS_COMPONENT_BRIDGE_ERROR_HANDLER_DOC);
conf.define(CAMEL_SOURCE_AWS2SQS_COMPONENT_CONCURRENT_CONSUMERS_CONF,
ConfigDef.Type.INT,
CAMEL_SOURCE_AWS2SQS_COMPONENT_CONCURRENT_CONSUMERS_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SOURCE_AWS2SQS_COMPONENT_CONCURRENT_CONSUMERS_DOC);
diff --git
a/connectors/camel-graphql-kafka-connector/src/generated/resources/camel-graphql-sink.json
b/connectors/camel-graphql-kafka-connector/src/generated/resources/camel-graphql-sink.json
index 6ce7dbd..e44f0f1 100644
---
a/connectors/camel-graphql-kafka-connector/src/generated/resources/camel-graphql-sink.json
+++
b/connectors/camel-graphql-kafka-connector/src/generated/resources/camel-graphql-sink.json
@@ -65,6 +65,13 @@
"priority": "MEDIUM",
"required": "false"
},
+ "camel.sink.endpoint.jwtAuthorizationType": {
+ "name": "camel.sink.endpoint.jwtAuthorizationType",
+ "description": "The JWT Authorization type. Default is
Bearer.",
+ "defaultValue": "\"Bearer\"",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
"camel.sink.endpoint.password": {
"name": "camel.sink.endpoint.password",
"description": "The password for Basic authentication.",
diff --git
a/connectors/camel-graphql-kafka-connector/src/main/docs/camel-graphql-kafka-sink-connector.adoc
b/connectors/camel-graphql-kafka-connector/src/main/docs/camel-graphql-kafka-sink-connector.adoc
index 2d2821b..a748244 100644
---
a/connectors/camel-graphql-kafka-connector/src/main/docs/camel-graphql-kafka-sink-connector.adoc
+++
b/connectors/camel-graphql-kafka-connector/src/main/docs/camel-graphql-kafka-sink-connector.adoc
@@ -22,7 +22,7 @@
connector.class=org.apache.camel.kafkaconnector.graphql.CamelGraphqlSinkConnecto
----
-The camel-graphql sink connector supports 13 options, which are listed below.
+The camel-graphql sink connector supports 14 options, which are listed below.
@@ -38,6 +38,7 @@ The camel-graphql sink connector supports 13 options, which
are listed below.
| *camel.sink.endpoint.variables* | The JsonObject instance containing the
operation variables. | null | false | MEDIUM
| *camel.sink.endpoint.synchronous* | Sets whether synchronous processing
should be strictly used, or Camel is allowed to use asynchronous processing (if
supported). | false | false | MEDIUM
| *camel.sink.endpoint.accessToken* | The access token sent in the
Authorization header. | null | false | MEDIUM
+| *camel.sink.endpoint.jwtAuthorizationType* | The JWT Authorization type.
Default is Bearer. | "Bearer" | false | MEDIUM
| *camel.sink.endpoint.password* | The password for Basic authentication. |
null | false | MEDIUM
| *camel.sink.endpoint.username* | The username for Basic authentication. |
null | false | MEDIUM
| *camel.component.graphql.lazyStartProducer* | Whether the producer should be
started lazy (on the first message). By starting lazy you can use this to allow
CamelContext and routes to startup in situations where a producer may otherwise
fail during starting and cause the route to fail being started. By deferring
this startup to be lazy then the startup failure can be handled during routing
messages via Camel's routing error handlers. Beware that when the first message
is processed then [...]
diff --git
a/connectors/camel-graphql-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/graphql/CamelGraphqlSinkConnectorConfig.java
b/connectors/camel-graphql-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/graphql/CamelGraphqlSinkConnectorConfig.java
index 4f7d1df..68794e9 100644
---
a/connectors/camel-graphql-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/graphql/CamelGraphqlSinkConnectorConfig.java
+++
b/connectors/camel-graphql-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/graphql/CamelGraphqlSinkConnectorConfig.java
@@ -51,6 +51,9 @@ public class CamelGraphqlSinkConnectorConfig extends
CamelSinkConnectorConfig {
public static final String CAMEL_SINK_GRAPHQL_ENDPOINT_ACCESS_TOKEN_CONF =
"camel.sink.endpoint.accessToken";
public static final String CAMEL_SINK_GRAPHQL_ENDPOINT_ACCESS_TOKEN_DOC =
"The access token sent in the Authorization header.";
public static final String
CAMEL_SINK_GRAPHQL_ENDPOINT_ACCESS_TOKEN_DEFAULT = null;
+ public static final String
CAMEL_SINK_GRAPHQL_ENDPOINT_JWT_AUTHORIZATION_TYPE_CONF =
"camel.sink.endpoint.jwtAuthorizationType";
+ public static final String
CAMEL_SINK_GRAPHQL_ENDPOINT_JWT_AUTHORIZATION_TYPE_DOC = "The JWT Authorization
type. Default is Bearer.";
+ public static final String
CAMEL_SINK_GRAPHQL_ENDPOINT_JWT_AUTHORIZATION_TYPE_DEFAULT = "Bearer";
public static final String CAMEL_SINK_GRAPHQL_ENDPOINT_PASSWORD_CONF =
"camel.sink.endpoint.password";
public static final String CAMEL_SINK_GRAPHQL_ENDPOINT_PASSWORD_DOC = "The
password for Basic authentication.";
public static final String CAMEL_SINK_GRAPHQL_ENDPOINT_PASSWORD_DEFAULT =
null;
@@ -85,6 +88,7 @@ public class CamelGraphqlSinkConnectorConfig extends
CamelSinkConnectorConfig {
conf.define(CAMEL_SINK_GRAPHQL_ENDPOINT_VARIABLES_CONF,
ConfigDef.Type.STRING, CAMEL_SINK_GRAPHQL_ENDPOINT_VARIABLES_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_GRAPHQL_ENDPOINT_VARIABLES_DOC);
conf.define(CAMEL_SINK_GRAPHQL_ENDPOINT_SYNCHRONOUS_CONF,
ConfigDef.Type.BOOLEAN, CAMEL_SINK_GRAPHQL_ENDPOINT_SYNCHRONOUS_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_GRAPHQL_ENDPOINT_SYNCHRONOUS_DOC);
conf.define(CAMEL_SINK_GRAPHQL_ENDPOINT_ACCESS_TOKEN_CONF,
ConfigDef.Type.STRING, CAMEL_SINK_GRAPHQL_ENDPOINT_ACCESS_TOKEN_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_GRAPHQL_ENDPOINT_ACCESS_TOKEN_DOC);
+ conf.define(CAMEL_SINK_GRAPHQL_ENDPOINT_JWT_AUTHORIZATION_TYPE_CONF,
ConfigDef.Type.STRING,
CAMEL_SINK_GRAPHQL_ENDPOINT_JWT_AUTHORIZATION_TYPE_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SINK_GRAPHQL_ENDPOINT_JWT_AUTHORIZATION_TYPE_DOC);
conf.define(CAMEL_SINK_GRAPHQL_ENDPOINT_PASSWORD_CONF,
ConfigDef.Type.STRING, CAMEL_SINK_GRAPHQL_ENDPOINT_PASSWORD_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_GRAPHQL_ENDPOINT_PASSWORD_DOC);
conf.define(CAMEL_SINK_GRAPHQL_ENDPOINT_USERNAME_CONF,
ConfigDef.Type.STRING, CAMEL_SINK_GRAPHQL_ENDPOINT_USERNAME_DEFAULT,
ConfigDef.Importance.MEDIUM, CAMEL_SINK_GRAPHQL_ENDPOINT_USERNAME_DOC);
conf.define(CAMEL_SINK_GRAPHQL_COMPONENT_LAZY_START_PRODUCER_CONF,
ConfigDef.Type.BOOLEAN,
CAMEL_SINK_GRAPHQL_COMPONENT_LAZY_START_PRODUCER_DEFAULT,
ConfigDef.Importance.MEDIUM,
CAMEL_SINK_GRAPHQL_COMPONENT_LAZY_START_PRODUCER_DOC);
diff --git
a/connectors/camel-salesforce-kafka-connector/src/generated/resources/camel-salesforce-sink.json
b/connectors/camel-salesforce-kafka-connector/src/generated/resources/camel-salesforce-sink.json
index 60fe53a..c2f48bf 100644
---
a/connectors/camel-salesforce-kafka-connector/src/generated/resources/camel-salesforce-sink.json
+++
b/connectors/camel-salesforce-kafka-connector/src/generated/resources/camel-salesforce-sink.json
@@ -36,7 +36,7 @@
"camel.sink.endpoint.apiVersion": {
"name": "camel.sink.endpoint.apiVersion",
"description": "Salesforce API version.",
- "defaultValue": "\"34.0\"",
+ "defaultValue": "\"50.0\"",
"priority": "MEDIUM",
"required": "false"
},
@@ -284,7 +284,7 @@
"camel.component.salesforce.apiVersion": {
"name": "camel.component.salesforce.apiVersion",
"description": "Salesforce API version.",
- "defaultValue": "\"34.0\"",
+ "defaultValue": "\"50.0\"",
"priority": "MEDIUM",
"required": "false"
},
diff --git
a/connectors/camel-salesforce-kafka-connector/src/generated/resources/camel-salesforce-source.json
b/connectors/camel-salesforce-kafka-connector/src/generated/resources/camel-salesforce-source.json
index 68e7968..425fd94 100644
---
a/connectors/camel-salesforce-kafka-connector/src/generated/resources/camel-salesforce-source.json
+++
b/connectors/camel-salesforce-kafka-connector/src/generated/resources/camel-salesforce-source.json
@@ -36,7 +36,7 @@
"camel.source.endpoint.apiVersion": {
"name": "camel.source.endpoint.apiVersion",
"description": "Salesforce API version.",
- "defaultValue": "\"34.0\"",
+ "defaultValue": "\"50.0\"",
"priority": "MEDIUM",
"required": "false"
},
@@ -302,7 +302,7 @@
"camel.component.salesforce.apiVersion": {
"name": "camel.component.salesforce.apiVersion",
"description": "Salesforce API version.",
- "defaultValue": "\"34.0\"",
+ "defaultValue": "\"50.0\"",
"priority": "MEDIUM",
"required": "false"
},
diff --git
a/connectors/camel-salesforce-kafka-connector/src/main/docs/camel-salesforce-kafka-sink-connector.adoc
b/connectors/camel-salesforce-kafka-connector/src/main/docs/camel-salesforce-kafka-sink-connector.adoc
index b7c71da..a38141e 100644
---
a/connectors/camel-salesforce-kafka-connector/src/main/docs/camel-salesforce-kafka-sink-connector.adoc
+++
b/connectors/camel-salesforce-kafka-connector/src/main/docs/camel-salesforce-kafka-sink-connector.adoc
@@ -33,7 +33,7 @@ The camel-salesforce sink connector supports 112 options,
which are listed below
| *camel.sink.endpoint.apexMethod* | APEX method name | null | false | MEDIUM
| *camel.sink.endpoint.apexQueryParams* | Query params for APEX method | null
| false | MEDIUM
| *camel.sink.endpoint.apexUrl* | APEX method URL | null | false | MEDIUM
-| *camel.sink.endpoint.apiVersion* | Salesforce API version. | "34.0" | false
| MEDIUM
+| *camel.sink.endpoint.apiVersion* | Salesforce API version. | "50.0" | false
| MEDIUM
| *camel.sink.endpoint.backoffIncrement* | Backoff interval increment for
Streaming connection restart attempts for failures beyond CometD
auto-reconnect. | 1000L | false | MEDIUM
| *camel.sink.endpoint.batchId* | Bulk API Batch ID | null | false | MEDIUM
| *camel.sink.endpoint.contentType* | Bulk API content type, one of XML, CSV,
ZIP_XML, ZIP_CSV One of: [XML] [CSV] [JSON] [ZIP_XML] [ZIP_CSV] [ZIP_JSON] |
null | false | MEDIUM
@@ -73,7 +73,7 @@ The camel-salesforce sink connector supports 112 options,
which are listed below
| *camel.component.salesforce.apexMethod* | APEX method name | null | false |
MEDIUM
| *camel.component.salesforce.apexQueryParams* | Query params for APEX method
| null | false | MEDIUM
| *camel.component.salesforce.apexUrl* | APEX method URL | null | false |
MEDIUM
-| *camel.component.salesforce.apiVersion* | Salesforce API version. | "34.0" |
false | MEDIUM
+| *camel.component.salesforce.apiVersion* | Salesforce API version. | "50.0" |
false | MEDIUM
| *camel.component.salesforce.backoffIncrement* | Backoff interval increment
for Streaming connection restart attempts for failures beyond CometD
auto-reconnect. | 1000L | false | MEDIUM
| *camel.component.salesforce.batchId* | Bulk API Batch ID | null | false |
MEDIUM
| *camel.component.salesforce.contentType* | Bulk API content type, one of
XML, CSV, ZIP_XML, ZIP_CSV One of: [XML] [CSV] [JSON] [ZIP_XML] [ZIP_CSV]
[ZIP_JSON] | null | false | MEDIUM
diff --git
a/connectors/camel-salesforce-kafka-connector/src/main/docs/camel-salesforce-kafka-source-connector.adoc
b/connectors/camel-salesforce-kafka-connector/src/main/docs/camel-salesforce-kafka-source-connector.adoc
index 63c351e..48c45c6 100644
---
a/connectors/camel-salesforce-kafka-connector/src/main/docs/camel-salesforce-kafka-source-connector.adoc
+++
b/connectors/camel-salesforce-kafka-connector/src/main/docs/camel-salesforce-kafka-source-connector.adoc
@@ -33,7 +33,7 @@ The camel-salesforce source connector supports 115 options,
which are listed bel
| *camel.source.endpoint.apexMethod* | APEX method name | null | false | MEDIUM
| *camel.source.endpoint.apexQueryParams* | Query params for APEX method |
null | false | MEDIUM
| *camel.source.endpoint.apexUrl* | APEX method URL | null | false | MEDIUM
-| *camel.source.endpoint.apiVersion* | Salesforce API version. | "34.0" |
false | MEDIUM
+| *camel.source.endpoint.apiVersion* | Salesforce API version. | "50.0" |
false | MEDIUM
| *camel.source.endpoint.backoffIncrement* | Backoff interval increment for
Streaming connection restart attempts for failures beyond CometD
auto-reconnect. | 1000L | false | MEDIUM
| *camel.source.endpoint.batchId* | Bulk API Batch ID | null | false | MEDIUM
| *camel.source.endpoint.contentType* | Bulk API content type, one of XML,
CSV, ZIP_XML, ZIP_CSV One of: [XML] [CSV] [JSON] [ZIP_XML] [ZIP_CSV] [ZIP_JSON]
| null | false | MEDIUM
@@ -76,7 +76,7 @@ The camel-salesforce source connector supports 115 options,
which are listed bel
| *camel.component.salesforce.apexMethod* | APEX method name | null | false |
MEDIUM
| *camel.component.salesforce.apexQueryParams* | Query params for APEX method
| null | false | MEDIUM
| *camel.component.salesforce.apexUrl* | APEX method URL | null | false |
MEDIUM
-| *camel.component.salesforce.apiVersion* | Salesforce API version. | "34.0" |
false | MEDIUM
+| *camel.component.salesforce.apiVersion* | Salesforce API version. | "50.0" |
false | MEDIUM
| *camel.component.salesforce.backoffIncrement* | Backoff interval increment
for Streaming connection restart attempts for failures beyond CometD
auto-reconnect. | 1000L | false | MEDIUM
| *camel.component.salesforce.batchId* | Bulk API Batch ID | null | false |
MEDIUM
| *camel.component.salesforce.contentType* | Bulk API content type, one of
XML, CSV, ZIP_XML, ZIP_CSV One of: [XML] [CSV] [JSON] [ZIP_XML] [ZIP_CSV]
[ZIP_JSON] | null | false | MEDIUM
diff --git
a/connectors/camel-salesforce-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/salesforce/CamelSalesforceSinkConnectorConfig.java
b/connectors/camel-salesforce-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/salesforce/CamelSalesforceSinkConnectorConfig.java
index e2caa8f..5dad693 100644
---
a/connectors/camel-salesforce-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/salesforce/CamelSalesforceSinkConnectorConfig.java
+++
b/connectors/camel-salesforce-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/salesforce/CamelSalesforceSinkConnectorConfig.java
@@ -40,7 +40,7 @@ public class CamelSalesforceSinkConnectorConfig
public static final String CAMEL_SINK_SALESFORCE_ENDPOINT_APEX_URL_DEFAULT
= null;
public static final String CAMEL_SINK_SALESFORCE_ENDPOINT_API_VERSION_CONF
= "camel.sink.endpoint.apiVersion";
public static final String CAMEL_SINK_SALESFORCE_ENDPOINT_API_VERSION_DOC
= "Salesforce API version.";
- public static final String
CAMEL_SINK_SALESFORCE_ENDPOINT_API_VERSION_DEFAULT = "34.0";
+ public static final String
CAMEL_SINK_SALESFORCE_ENDPOINT_API_VERSION_DEFAULT = "50.0";
public static final String
CAMEL_SINK_SALESFORCE_ENDPOINT_BACKOFF_INCREMENT_CONF =
"camel.sink.endpoint.backoffIncrement";
public static final String
CAMEL_SINK_SALESFORCE_ENDPOINT_BACKOFF_INCREMENT_DOC = "Backoff interval
increment for Streaming connection restart attempts for failures beyond CometD
auto-reconnect.";
public static final Long
CAMEL_SINK_SALESFORCE_ENDPOINT_BACKOFF_INCREMENT_DEFAULT = 1000L;
@@ -160,7 +160,7 @@ public class CamelSalesforceSinkConnectorConfig
public static final String
CAMEL_SINK_SALESFORCE_COMPONENT_APEX_URL_DEFAULT = null;
public static final String
CAMEL_SINK_SALESFORCE_COMPONENT_API_VERSION_CONF =
"camel.component.salesforce.apiVersion";
public static final String CAMEL_SINK_SALESFORCE_COMPONENT_API_VERSION_DOC
= "Salesforce API version.";
- public static final String
CAMEL_SINK_SALESFORCE_COMPONENT_API_VERSION_DEFAULT = "34.0";
+ public static final String
CAMEL_SINK_SALESFORCE_COMPONENT_API_VERSION_DEFAULT = "50.0";
public static final String
CAMEL_SINK_SALESFORCE_COMPONENT_BACKOFF_INCREMENT_CONF =
"camel.component.salesforce.backoffIncrement";
public static final String
CAMEL_SINK_SALESFORCE_COMPONENT_BACKOFF_INCREMENT_DOC = "Backoff interval
increment for Streaming connection restart attempts for failures beyond CometD
auto-reconnect.";
public static final Long
CAMEL_SINK_SALESFORCE_COMPONENT_BACKOFF_INCREMENT_DEFAULT = 1000L;
diff --git
a/connectors/camel-salesforce-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/salesforce/CamelSalesforceSourceConnectorConfig.java
b/connectors/camel-salesforce-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/salesforce/CamelSalesforceSourceConnectorConfig.java
index 02f04a3..864c339 100644
---
a/connectors/camel-salesforce-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/salesforce/CamelSalesforceSourceConnectorConfig.java
+++
b/connectors/camel-salesforce-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/salesforce/CamelSalesforceSourceConnectorConfig.java
@@ -40,7 +40,7 @@ public class CamelSalesforceSourceConnectorConfig
public static final String
CAMEL_SOURCE_SALESFORCE_ENDPOINT_APEX_URL_DEFAULT = null;
public static final String
CAMEL_SOURCE_SALESFORCE_ENDPOINT_API_VERSION_CONF =
"camel.source.endpoint.apiVersion";
public static final String
CAMEL_SOURCE_SALESFORCE_ENDPOINT_API_VERSION_DOC = "Salesforce API version.";
- public static final String
CAMEL_SOURCE_SALESFORCE_ENDPOINT_API_VERSION_DEFAULT = "34.0";
+ public static final String
CAMEL_SOURCE_SALESFORCE_ENDPOINT_API_VERSION_DEFAULT = "50.0";
public static final String
CAMEL_SOURCE_SALESFORCE_ENDPOINT_BACKOFF_INCREMENT_CONF =
"camel.source.endpoint.backoffIncrement";
public static final String
CAMEL_SOURCE_SALESFORCE_ENDPOINT_BACKOFF_INCREMENT_DOC = "Backoff interval
increment for Streaming connection restart attempts for failures beyond CometD
auto-reconnect.";
public static final Long
CAMEL_SOURCE_SALESFORCE_ENDPOINT_BACKOFF_INCREMENT_DEFAULT = 1000L;
@@ -169,7 +169,7 @@ public class CamelSalesforceSourceConnectorConfig
public static final String
CAMEL_SOURCE_SALESFORCE_COMPONENT_APEX_URL_DEFAULT = null;
public static final String
CAMEL_SOURCE_SALESFORCE_COMPONENT_API_VERSION_CONF =
"camel.component.salesforce.apiVersion";
public static final String
CAMEL_SOURCE_SALESFORCE_COMPONENT_API_VERSION_DOC = "Salesforce API version.";
- public static final String
CAMEL_SOURCE_SALESFORCE_COMPONENT_API_VERSION_DEFAULT = "34.0";
+ public static final String
CAMEL_SOURCE_SALESFORCE_COMPONENT_API_VERSION_DEFAULT = "50.0";
public static final String
CAMEL_SOURCE_SALESFORCE_COMPONENT_BACKOFF_INCREMENT_CONF =
"camel.component.salesforce.backoffIncrement";
public static final String
CAMEL_SOURCE_SALESFORCE_COMPONENT_BACKOFF_INCREMENT_DOC = "Backoff interval
increment for Streaming connection restart attempts for failures beyond CometD
auto-reconnect.";
public static final Long
CAMEL_SOURCE_SALESFORCE_COMPONENT_BACKOFF_INCREMENT_DEFAULT = 1000L;
diff --git
a/core/src/test/java/org/apache/camel/kafkaconnector/transforms/SourcePojoToSchemaAndStructTransformTest.java
b/core/src/test/java/org/apache/camel/kafkaconnector/transforms/SourcePojoToSchemaAndStructTransformTest.java
index dfe1ed6..fbd5144 100644
---
a/core/src/test/java/org/apache/camel/kafkaconnector/transforms/SourcePojoToSchemaAndStructTransformTest.java
+++
b/core/src/test/java/org/apache/camel/kafkaconnector/transforms/SourcePojoToSchemaAndStructTransformTest.java
@@ -22,6 +22,8 @@ import java.util.List;
import java.util.Map;
import org.apache.camel.component.slack.helper.SlackMessage;
+import org.apache.camel.component.slack.helper.SlackMessage.Attachment;
+import org.apache.camel.component.slack.helper.SlackMessage.Attachment.Field;
import org.apache.kafka.connect.connector.ConnectRecord;
import org.apache.kafka.connect.data.Schema;
import org.apache.kafka.connect.data.Struct;
@@ -42,14 +44,14 @@ public class SourcePojoToSchemaAndStructTransformTest {
SlackMessage sm = new SlackMessage();
- SlackMessage.Attachment at1 = sm.new Attachment();
- SlackMessage.Attachment.Field at1f1 = at1.new Field();
+ SlackMessage.Attachment at1 = new Attachment();
+ SlackMessage.Attachment.Field at1f1 = new Field();
at1f1.setTitle("ciao");
at1f1.setShortValue(true);
at1.setFields(new
ArrayList<SlackMessage.Attachment.Field>(Collections.singleton(at1f1)));
at1.setAuthorName("Andrea");
- SlackMessage.Attachment at2 = sm.new Attachment();
+ SlackMessage.Attachment at2 = new Attachment();
at2.setColor("green");
ArrayList<SlackMessage.Attachment> attachments = new ArrayList<>();
diff --git
a/docs/modules/ROOT/pages/connectors/camel-aws2-s3-kafka-sink-connector.adoc
b/docs/modules/ROOT/pages/connectors/camel-aws2-s3-kafka-sink-connector.adoc
index ffe0bd0..18a7c1a 100644
--- a/docs/modules/ROOT/pages/connectors/camel-aws2-s3-kafka-sink-connector.adoc
+++ b/docs/modules/ROOT/pages/connectors/camel-aws2-s3-kafka-sink-connector.adoc
@@ -22,7 +22,7 @@
connector.class=org.apache.camel.kafkaconnector.aws2s3.CamelAws2s3SinkConnector
----
-The camel-aws2-s3 sink connector supports 58 options, which are listed below.
+The camel-aws2-s3 sink connector supports 60 options, which are listed below.
@@ -31,6 +31,7 @@ The camel-aws2-s3 sink connector supports 58 options, which
are listed below.
| Name | Description | Default | Required | Priority
| *camel.sink.path.bucketNameOrArn* | Bucket name or ARN | null | true | HIGH
| *camel.sink.endpoint.amazonS3Client* | Reference to a
com.amazonaws.services.s3.AmazonS3 in the registry. | null | false | MEDIUM
+| *camel.sink.endpoint.amazonS3Presigner* | An S3 Presigner for Request, used
mainly in createDownloadLink operation | null | false | MEDIUM
| *camel.sink.endpoint.autoCreateBucket* | Setting the autocreation of the S3
bucket bucketName. This will apply also in case of moveAfterRead option enabled
and it will create the destinationBucket if it doesn't exist already. | true |
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
@@ -41,7 +42,7 @@ The camel-aws2-s3 sink connector supports 58 options, which
are listed below.
| *camel.sink.endpoint.region* | The region in which S3 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.useIAMCredentials* | Set whether the S3 client should
expect to load credentials on an EC2 instance or to expect static credentials
to be passed in. | false | false | MEDIUM
+| *camel.sink.endpoint.useDefaultCredentialsProvider* | Set whether the S3
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.customerAlgorithm* | Define the customer algorithm to
use in case CustomerKey is enabled | null | false | MEDIUM
| *camel.sink.endpoint.customerKeyId* | Define the id of Customer key to use
in case CustomerKey is enabled | null | false | MEDIUM
| *camel.sink.endpoint.customerKeyMD5* | Define the MD5 of Customer key to use
in case CustomerKey is enabled | null | false | MEDIUM
@@ -59,6 +60,7 @@ The camel-aws2-s3 sink connector supports 58 options, which
are listed below.
| *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-s3.amazonS3Client* | Reference to a
com.amazonaws.services.s3.AmazonS3 in the registry. | null | false | MEDIUM
+| *camel.component.aws2-s3.amazonS3Presigner* | An S3 Presigner for Request,
used mainly in createDownloadLink operation | null | false | MEDIUM
| *camel.component.aws2-s3.autoCreateBucket* | Setting the autocreation of the
S3 bucket bucketName. This will apply also in case of moveAfterRead option
enabled and it will create the destinationBucket if it doesn't exist already. |
true | false | MEDIUM
| *camel.component.aws2-s3.configuration* | The component configuration | null
| false | MEDIUM
| *camel.component.aws2-s3.overrideEndpoint* | Set the need for overidding the
endpoint. This option needs to be used in combination with uriEndpointOverride
option | false | false | MEDIUM
@@ -70,7 +72,7 @@ The camel-aws2-s3 sink connector supports 58 options, which
are listed below.
| *camel.component.aws2-s3.region* | The region in which S3 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-s3.trustAllCertificates* | If we want to trust all
certificates in case of overriding the endpoint | false | false | MEDIUM
| *camel.component.aws2-s3.uriEndpointOverride* | Set the overriding uri
endpoint. This option needs to be used in combination with overrideEndpoint
option | null | false | MEDIUM
-| *camel.component.aws2-s3.useIAMCredentials* | Set whether the S3 client
should expect to load credentials on an EC2 instance or to expect static
credentials to be passed in. | false | false | MEDIUM
+| *camel.component.aws2-s3.useDefaultCredentials Provider* | Set whether the
S3 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-s3.customerAlgorithm* | Define the customer algorithm
to use in case CustomerKey is enabled | null | false | MEDIUM
| *camel.component.aws2-s3.customerKeyId* | Define the id of Customer key to
use in case CustomerKey is enabled | null | false | MEDIUM
| *camel.component.aws2-s3.customerKeyMD5* | Define the MD5 of Customer key to
use in case CustomerKey is enabled | null | false | MEDIUM
diff --git
a/docs/modules/ROOT/pages/connectors/camel-aws2-s3-kafka-source-connector.adoc
b/docs/modules/ROOT/pages/connectors/camel-aws2-s3-kafka-source-connector.adoc
index 0c67013..466b485 100644
---
a/docs/modules/ROOT/pages/connectors/camel-aws2-s3-kafka-source-connector.adoc
+++
b/docs/modules/ROOT/pages/connectors/camel-aws2-s3-kafka-source-connector.adoc
@@ -22,7 +22,7 @@
connector.class=org.apache.camel.kafkaconnector.aws2s3.CamelAws2s3SourceConnecto
----
-The camel-aws2-s3 source connector supports 82 options, which are listed below.
+The camel-aws2-s3 source connector supports 84 options, which are listed below.
@@ -31,6 +31,7 @@ The camel-aws2-s3 source connector supports 82 options, which
are listed below.
| Name | Description | Default | Required | Priority
| *camel.source.path.bucketNameOrArn* | Bucket name or ARN | null | true | HIGH
| *camel.source.endpoint.amazonS3Client* | Reference to a
com.amazonaws.services.s3.AmazonS3 in the registry. | null | false | MEDIUM
+| *camel.source.endpoint.amazonS3Presigner* | An S3 Presigner for Request,
used mainly in createDownloadLink operation | null | false | MEDIUM
| *camel.source.endpoint.autoCreateBucket* | Setting the autocreation of the
S3 bucket bucketName. This will apply also in case of moveAfterRead option
enabled and it will create the destinationBucket if it doesn't exist already. |
true | false | MEDIUM
| *camel.source.endpoint.overrideEndpoint* | Set the need for overidding the
endpoint. This option needs to be used in combination with uriEndpointOverride
option | false | false | MEDIUM
| *camel.source.endpoint.pojoRequest* | If we want to use a POJO request as
body or not | false | false | MEDIUM
@@ -41,7 +42,7 @@ The camel-aws2-s3 source connector supports 82 options, which
are listed below.
| *camel.source.endpoint.region* | The region in which S3 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.source.endpoint.trustAllCertificates* | If we want to trust all
certificates in case of overriding the endpoint | false | false | MEDIUM
| *camel.source.endpoint.uriEndpointOverride* | Set the overriding uri
endpoint. This option needs to be used in combination with overrideEndpoint
option | null | false | MEDIUM
-| *camel.source.endpoint.useIAMCredentials* | Set whether the S3 client should
expect to load credentials on an EC2 instance or to expect static credentials
to be passed in. | false | false | MEDIUM
+| *camel.source.endpoint.useDefaultCredentials Provider* | Set whether the S3
client should expect to load credentials through a default credentials provider
or to expect static credentials to be passed in. | false | false | MEDIUM
| *camel.source.endpoint.customerAlgorithm* | Define the customer algorithm to
use in case CustomerKey is enabled | null | false | MEDIUM
| *camel.source.endpoint.customerKeyId* | Define the id of Customer key to use
in case CustomerKey is enabled | null | false | MEDIUM
| *camel.source.endpoint.customerKeyMD5* | Define the MD5 of Customer key to
use in case CustomerKey is enabled | null | false | MEDIUM
@@ -81,6 +82,7 @@ The camel-aws2-s3 source connector supports 82 options, which
are listed below.
| *camel.source.endpoint.accessKey* | Amazon AWS Access Key | null | false |
MEDIUM
| *camel.source.endpoint.secretKey* | Amazon AWS Secret Key | null | false |
MEDIUM
| *camel.component.aws2-s3.amazonS3Client* | Reference to a
com.amazonaws.services.s3.AmazonS3 in the registry. | null | false | MEDIUM
+| *camel.component.aws2-s3.amazonS3Presigner* | An S3 Presigner for Request,
used mainly in createDownloadLink operation | null | false | MEDIUM
| *camel.component.aws2-s3.autoCreateBucket* | Setting the autocreation of the
S3 bucket bucketName. This will apply also in case of moveAfterRead option
enabled and it will create the destinationBucket if it doesn't exist already. |
true | false | MEDIUM
| *camel.component.aws2-s3.configuration* | The component configuration | null
| false | MEDIUM
| *camel.component.aws2-s3.overrideEndpoint* | Set the need for overidding the
endpoint. This option needs to be used in combination with uriEndpointOverride
option | false | false | MEDIUM
@@ -92,7 +94,7 @@ The camel-aws2-s3 source connector supports 82 options, which
are listed below.
| *camel.component.aws2-s3.region* | The region in which S3 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-s3.trustAllCertificates* | If we want to trust all
certificates in case of overriding the endpoint | false | false | MEDIUM
| *camel.component.aws2-s3.uriEndpointOverride* | Set the overriding uri
endpoint. This option needs to be used in combination with overrideEndpoint
option | null | false | MEDIUM
-| *camel.component.aws2-s3.useIAMCredentials* | Set whether the S3 client
should expect to load credentials on an EC2 instance or to expect static
credentials to be passed in. | false | false | MEDIUM
+| *camel.component.aws2-s3.useDefaultCredentials Provider* | Set whether the
S3 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-s3.customerAlgorithm* | Define the customer algorithm
to use in case CustomerKey is enabled | null | false | MEDIUM
| *camel.component.aws2-s3.customerKeyId* | Define the id of Customer key to
use in case CustomerKey is enabled | null | false | MEDIUM
| *camel.component.aws2-s3.customerKeyMD5* | Define the MD5 of Customer key to
use in case CustomerKey is enabled | null | false | MEDIUM
diff --git
a/docs/modules/ROOT/pages/connectors/camel-aws2-sns-kafka-sink-connector.adoc
b/docs/modules/ROOT/pages/connectors/camel-aws2-sns-kafka-sink-connector.adoc
index a3cd361..ab19b95 100644
---
a/docs/modules/ROOT/pages/connectors/camel-aws2-sns-kafka-sink-connector.adoc
+++
b/docs/modules/ROOT/pages/connectors/camel-aws2-sns-kafka-sink-connector.adoc
@@ -46,7 +46,7 @@ The camel-aws2-sns sink connector supports 41 options, which
are listed below.
| *camel.sink.endpoint.subject* | The subject which is used if the message
header 'CamelAwsSnsSubject' is not present. | null | false | MEDIUM
| *camel.sink.endpoint.subscribeSNStoSQS* | Define if the subscription between
SNS Topic and SQS must be done or not | false | 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.useIAMCredentials* | Set whether the SQS client should
expect to load credentials on an AWS infra instance or to expect static
credentials to be passed in. | false | false | MEDIUM
+| *camel.sink.endpoint.useDefaultCredentialsProvider* | Set whether the SQS
client should expect to load credentials on an AWS infra instance or to expect
static credentials to be passed in. | false | false | MEDIUM
| *camel.sink.endpoint.synchronous* | Sets whether synchronous processing
should be strictly used, or Camel is allowed to use asynchronous processing (if
supported). | 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
@@ -66,7 +66,7 @@ The camel-aws2-sns sink connector supports 41 options, which
are listed below.
| *camel.component.aws2-sns.subject* | The subject which is used if the
message header 'CamelAwsSnsSubject' is not present. | null | false | MEDIUM
| *camel.component.aws2-sns.subscribeSNStoSQS* | Define if the subscription
between SNS Topic and SQS must be done or not | false | false | MEDIUM
| *camel.component.aws2-sns.trustAllCertificates* | If we want to trust all
certificates in case of overriding the endpoint | false | false | MEDIUM
-| *camel.component.aws2-sns.useIAMCredentials* | Set whether the SQS client
should expect to load credentials on an AWS infra instance or to expect static
credentials to be passed in. | false | false | MEDIUM
+| *camel.component.aws2-sns.useDefaultCredentials Provider* | Set whether the
SQS client should expect to load credentials on an AWS infra instance or to
expect static credentials to be passed in. | false | false | MEDIUM
| *camel.component.aws2-sns.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-sns.accessKey* | Amazon AWS Access Key | null | false
| MEDIUM
| *camel.component.aws2-sns.secretKey* | Amazon AWS Secret Key | null | false
| MEDIUM
diff --git
a/docs/modules/ROOT/pages/connectors/camel-aws2-sqs-kafka-sink-connector.adoc
b/docs/modules/ROOT/pages/connectors/camel-aws2-sqs-kafka-sink-connector.adoc
index 3cc4922..636d972 100644
---
a/docs/modules/ROOT/pages/connectors/camel-aws2-sqs-kafka-sink-connector.adoc
+++
b/docs/modules/ROOT/pages/connectors/camel-aws2-sqs-kafka-sink-connector.adoc
@@ -39,7 +39,7 @@ The camel-aws2-sqs sink connector supports 55 options, which
are listed below.
| *camel.sink.endpoint.queueOwnerAWSAccountId* | Specify the queue owner aws
account id when you need to connect the queue with different account owner. |
null | false | MEDIUM
| *camel.sink.endpoint.region* | The region in which SQS 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.useIAMCredentials* | Set whether the SQS client should
expect to load credentials on an AWS infra instance or to expect static
credentials to be passed in. | false | false | MEDIUM
+| *camel.sink.endpoint.useDefaultCredentialsProvider* | Set whether the SQS
client should expect to load credentials on an AWS infra instance or to expect
static credentials to be passed in. | false | false | MEDIUM
| *camel.sink.endpoint.delaySeconds* | Delay sending messages for a number of
seconds. | null | false | MEDIUM
| *camel.sink.endpoint.lazyStartProducer* | Whether the producer should be
started lazy (on the first message). By starting lazy you can use this to allow
CamelContext and routes to startup in situations where a producer may otherwise
fail during starting and cause the route to fail being started. By deferring
this startup to be lazy then the startup failure can be handled during routing
messages via Camel's routing error handlers. Beware that when the first message
is processed then cre [...]
| *camel.sink.endpoint.messageDeduplicationIdStrategy* | Only for FIFO queues.
Strategy for setting the messageDeduplicationId on the message. Can be one of
the following options: useExchangeId, useContentBasedDeduplication. For the
useContentBasedDeduplication option, no messageDeduplicationId will be set on
the message. One of: [useExchangeId] [useContentBasedDeduplication] |
"useExchangeId" | false | MEDIUM
@@ -66,7 +66,7 @@ The camel-aws2-sqs sink connector supports 55 options, which
are listed below.
| *camel.component.aws2-sqs.queueOwnerAWSAccountId* | Specify the queue owner
aws account id when you need to connect the queue with different account owner.
| null | false | MEDIUM
| *camel.component.aws2-sqs.region* | The region in which SQS 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-sqs.trustAllCertificates* | If we want to trust all
certificates in case of overriding the endpoint | false | false | MEDIUM
-| *camel.component.aws2-sqs.useIAMCredentials* | Set whether the SQS client
should expect to load credentials on an AWS infra instance or to expect static
credentials to be passed in. | false | false | MEDIUM
+| *camel.component.aws2-sqs.useDefaultCredentials Provider* | Set whether the
SQS client should expect to load credentials on an AWS infra instance or to
expect static credentials to be passed in. | false | false | MEDIUM
| *camel.component.aws2-sqs.delaySeconds* | Delay sending messages for a
number of seconds. | null | false | MEDIUM
| *camel.component.aws2-sqs.lazyStartProducer* | Whether the producer should
be started lazy (on the first message). By starting lazy you can use this to
allow CamelContext and routes to startup in situations where a producer may
otherwise fail during starting and cause the route to fail being started. By
deferring this startup to be lazy then the startup failure can be handled
during routing messages via Camel's routing error handlers. Beware that when
the first message is processed the [...]
| *camel.component.aws2-sqs.messageDeduplicationId Strategy* | Only for FIFO
queues. Strategy for setting the messageDeduplicationId on the message. Can be
one of the following options: useExchangeId, useContentBasedDeduplication. For
the useContentBasedDeduplication option, no messageDeduplicationId will be set
on the message. One of: [useExchangeId] [useContentBasedDeduplication] |
"useExchangeId" | false | MEDIUM
diff --git
a/docs/modules/ROOT/pages/connectors/camel-aws2-sqs-kafka-source-connector.adoc
b/docs/modules/ROOT/pages/connectors/camel-aws2-sqs-kafka-source-connector.adoc
index ed8e159..43cdb98 100644
---
a/docs/modules/ROOT/pages/connectors/camel-aws2-sqs-kafka-source-connector.adoc
+++
b/docs/modules/ROOT/pages/connectors/camel-aws2-sqs-kafka-source-connector.adoc
@@ -39,7 +39,7 @@ The camel-aws2-sqs source connector supports 90 options,
which are listed below.
| *camel.source.endpoint.queueOwnerAWSAccountId* | Specify the queue owner aws
account id when you need to connect the queue with different account owner. |
null | false | MEDIUM
| *camel.source.endpoint.region* | The region in which SQS 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.source.endpoint.trustAllCertificates* | If we want to trust all
certificates in case of overriding the endpoint | false | false | MEDIUM
-| *camel.source.endpoint.useIAMCredentials* | Set whether the SQS client
should expect to load credentials on an AWS infra instance or to expect static
credentials to be passed in. | false | false | MEDIUM
+| *camel.source.endpoint.useDefaultCredentials Provider* | Set whether the SQS
client should expect to load credentials on an AWS infra instance or to expect
static credentials to be passed in. | false | false | MEDIUM
| *camel.source.endpoint.attributeNames* | A list of attribute names to
receive when consuming. Multiple names can be separated by comma. | null |
false | MEDIUM
| *camel.source.endpoint.bridgeErrorHandler* | Allows for bridging the
consumer to the Camel routing Error Handler, which mean any exceptions occurred
while the consumer is trying to pickup incoming messages, or the likes, will
now be processed as a message and handled by the routing Error Handler. By
default the consumer will use the org.apache.camel.spi.ExceptionHandler to deal
with exceptions, that will be logged at WARN or ERROR level and ignored. |
false | false | MEDIUM
| *camel.source.endpoint.concurrentConsumers* | Allows you to use multiple
threads to poll the sqs queue to increase throughput | 1 | false | MEDIUM
@@ -93,7 +93,7 @@ The camel-aws2-sqs source connector supports 90 options,
which are listed below.
| *camel.component.aws2-sqs.queueOwnerAWSAccountId* | Specify the queue owner
aws account id when you need to connect the queue with different account owner.
| null | false | MEDIUM
| *camel.component.aws2-sqs.region* | The region in which SQS 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-sqs.trustAllCertificates* | If we want to trust all
certificates in case of overriding the endpoint | false | false | MEDIUM
-| *camel.component.aws2-sqs.useIAMCredentials* | Set whether the SQS client
should expect to load credentials on an AWS infra instance or to expect static
credentials to be passed in. | false | false | MEDIUM
+| *camel.component.aws2-sqs.useDefaultCredentials Provider* | Set whether the
SQS client should expect to load credentials on an AWS infra instance or to
expect static credentials to be passed in. | false | false | MEDIUM
| *camel.component.aws2-sqs.attributeNames* | A list of attribute names to
receive when consuming. Multiple names can be separated by comma. | null |
false | MEDIUM
| *camel.component.aws2-sqs.bridgeErrorHandler* | Allows for bridging the
consumer to the Camel routing Error Handler, which mean any exceptions occurred
while the consumer is trying to pickup incoming messages, or the likes, will
now be processed as a message and handled by the routing Error Handler. By
default the consumer will use the org.apache.camel.spi.ExceptionHandler to deal
with exceptions, that will be logged at WARN or ERROR level and ignored. |
false | false | MEDIUM
| *camel.component.aws2-sqs.concurrentConsumers* | Allows you to use multiple
threads to poll the sqs queue to increase throughput | 1 | false | MEDIUM
diff --git
a/docs/modules/ROOT/pages/connectors/camel-graphql-kafka-sink-connector.adoc
b/docs/modules/ROOT/pages/connectors/camel-graphql-kafka-sink-connector.adoc
index 2d2821b..a748244 100644
--- a/docs/modules/ROOT/pages/connectors/camel-graphql-kafka-sink-connector.adoc
+++ b/docs/modules/ROOT/pages/connectors/camel-graphql-kafka-sink-connector.adoc
@@ -22,7 +22,7 @@
connector.class=org.apache.camel.kafkaconnector.graphql.CamelGraphqlSinkConnecto
----
-The camel-graphql sink connector supports 13 options, which are listed below.
+The camel-graphql sink connector supports 14 options, which are listed below.
@@ -38,6 +38,7 @@ The camel-graphql sink connector supports 13 options, which
are listed below.
| *camel.sink.endpoint.variables* | The JsonObject instance containing the
operation variables. | null | false | MEDIUM
| *camel.sink.endpoint.synchronous* | Sets whether synchronous processing
should be strictly used, or Camel is allowed to use asynchronous processing (if
supported). | false | false | MEDIUM
| *camel.sink.endpoint.accessToken* | The access token sent in the
Authorization header. | null | false | MEDIUM
+| *camel.sink.endpoint.jwtAuthorizationType* | The JWT Authorization type.
Default is Bearer. | "Bearer" | false | MEDIUM
| *camel.sink.endpoint.password* | The password for Basic authentication. |
null | false | MEDIUM
| *camel.sink.endpoint.username* | The username for Basic authentication. |
null | false | MEDIUM
| *camel.component.graphql.lazyStartProducer* | Whether the producer should be
started lazy (on the first message). By starting lazy you can use this to allow
CamelContext and routes to startup in situations where a producer may otherwise
fail during starting and cause the route to fail being started. By deferring
this startup to be lazy then the startup failure can be handled during routing
messages via Camel's routing error handlers. Beware that when the first message
is processed then [...]
diff --git
a/docs/modules/ROOT/pages/connectors/camel-salesforce-kafka-sink-connector.adoc
b/docs/modules/ROOT/pages/connectors/camel-salesforce-kafka-sink-connector.adoc
index b7c71da..a38141e 100644
---
a/docs/modules/ROOT/pages/connectors/camel-salesforce-kafka-sink-connector.adoc
+++
b/docs/modules/ROOT/pages/connectors/camel-salesforce-kafka-sink-connector.adoc
@@ -33,7 +33,7 @@ The camel-salesforce sink connector supports 112 options,
which are listed below
| *camel.sink.endpoint.apexMethod* | APEX method name | null | false | MEDIUM
| *camel.sink.endpoint.apexQueryParams* | Query params for APEX method | null
| false | MEDIUM
| *camel.sink.endpoint.apexUrl* | APEX method URL | null | false | MEDIUM
-| *camel.sink.endpoint.apiVersion* | Salesforce API version. | "34.0" | false
| MEDIUM
+| *camel.sink.endpoint.apiVersion* | Salesforce API version. | "50.0" | false
| MEDIUM
| *camel.sink.endpoint.backoffIncrement* | Backoff interval increment for
Streaming connection restart attempts for failures beyond CometD
auto-reconnect. | 1000L | false | MEDIUM
| *camel.sink.endpoint.batchId* | Bulk API Batch ID | null | false | MEDIUM
| *camel.sink.endpoint.contentType* | Bulk API content type, one of XML, CSV,
ZIP_XML, ZIP_CSV One of: [XML] [CSV] [JSON] [ZIP_XML] [ZIP_CSV] [ZIP_JSON] |
null | false | MEDIUM
@@ -73,7 +73,7 @@ The camel-salesforce sink connector supports 112 options,
which are listed below
| *camel.component.salesforce.apexMethod* | APEX method name | null | false |
MEDIUM
| *camel.component.salesforce.apexQueryParams* | Query params for APEX method
| null | false | MEDIUM
| *camel.component.salesforce.apexUrl* | APEX method URL | null | false |
MEDIUM
-| *camel.component.salesforce.apiVersion* | Salesforce API version. | "34.0" |
false | MEDIUM
+| *camel.component.salesforce.apiVersion* | Salesforce API version. | "50.0" |
false | MEDIUM
| *camel.component.salesforce.backoffIncrement* | Backoff interval increment
for Streaming connection restart attempts for failures beyond CometD
auto-reconnect. | 1000L | false | MEDIUM
| *camel.component.salesforce.batchId* | Bulk API Batch ID | null | false |
MEDIUM
| *camel.component.salesforce.contentType* | Bulk API content type, one of
XML, CSV, ZIP_XML, ZIP_CSV One of: [XML] [CSV] [JSON] [ZIP_XML] [ZIP_CSV]
[ZIP_JSON] | null | false | MEDIUM
diff --git
a/docs/modules/ROOT/pages/connectors/camel-salesforce-kafka-source-connector.adoc
b/docs/modules/ROOT/pages/connectors/camel-salesforce-kafka-source-connector.adoc
index 63c351e..48c45c6 100644
---
a/docs/modules/ROOT/pages/connectors/camel-salesforce-kafka-source-connector.adoc
+++
b/docs/modules/ROOT/pages/connectors/camel-salesforce-kafka-source-connector.adoc
@@ -33,7 +33,7 @@ The camel-salesforce source connector supports 115 options,
which are listed bel
| *camel.source.endpoint.apexMethod* | APEX method name | null | false | MEDIUM
| *camel.source.endpoint.apexQueryParams* | Query params for APEX method |
null | false | MEDIUM
| *camel.source.endpoint.apexUrl* | APEX method URL | null | false | MEDIUM
-| *camel.source.endpoint.apiVersion* | Salesforce API version. | "34.0" |
false | MEDIUM
+| *camel.source.endpoint.apiVersion* | Salesforce API version. | "50.0" |
false | MEDIUM
| *camel.source.endpoint.backoffIncrement* | Backoff interval increment for
Streaming connection restart attempts for failures beyond CometD
auto-reconnect. | 1000L | false | MEDIUM
| *camel.source.endpoint.batchId* | Bulk API Batch ID | null | false | MEDIUM
| *camel.source.endpoint.contentType* | Bulk API content type, one of XML,
CSV, ZIP_XML, ZIP_CSV One of: [XML] [CSV] [JSON] [ZIP_XML] [ZIP_CSV] [ZIP_JSON]
| null | false | MEDIUM
@@ -76,7 +76,7 @@ The camel-salesforce source connector supports 115 options,
which are listed bel
| *camel.component.salesforce.apexMethod* | APEX method name | null | false |
MEDIUM
| *camel.component.salesforce.apexQueryParams* | Query params for APEX method
| null | false | MEDIUM
| *camel.component.salesforce.apexUrl* | APEX method URL | null | false |
MEDIUM
-| *camel.component.salesforce.apiVersion* | Salesforce API version. | "34.0" |
false | MEDIUM
+| *camel.component.salesforce.apiVersion* | Salesforce API version. | "50.0" |
false | MEDIUM
| *camel.component.salesforce.backoffIncrement* | Backoff interval increment
for Streaming connection restart attempts for failures beyond CometD
auto-reconnect. | 1000L | false | MEDIUM
| *camel.component.salesforce.batchId* | Bulk API Batch ID | null | false |
MEDIUM
| *camel.component.salesforce.contentType* | Bulk API content type, one of
XML, CSV, ZIP_XML, ZIP_CSV One of: [XML] [CSV] [JSON] [ZIP_XML] [ZIP_CSV]
[ZIP_JSON] | null | false | MEDIUM
