You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by ac...@apache.org on 2022/10/19 04:38:33 UTC
[camel-kafka-connector] branch main updated: [create-pull-request] automated change
This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git
The following commit(s) were added to refs/heads/main by this push:
new 8212ddbb0 [create-pull-request] automated change
8212ddbb0 is described below
commit 8212ddbb084e63f6483db2564272b478a441ff8c
Author: oscerd <os...@users.noreply.github.com>
AuthorDate: Wed Oct 19 04:16:21 2022 +0000
[create-pull-request] automated change
---
.../connectors/camel-aws-s3-streaming-upload-sink-sink.json | 7 +++++++
.../connectors/camel-google-storage-source-source.json | 2 +-
.../resources/connectors/camel-mongodb-source-source.json | 2 +-
connectors/camel-aws-cloudwatch-sink-kafka-connector/pom.xml | 5 -----
.../main/resources/kamelets/aws-cloudwatch-sink.kamelet.yaml | 3 +--
connectors/camel-aws-ddb-sink-kafka-connector/pom.xml | 5 -----
.../src/main/resources/kamelets/aws-ddb-sink.kamelet.yaml | 3 +--
.../camel-aws-ddb-streams-source-kafka-connector/pom.xml | 5 -----
.../resources/kamelets/aws-ddb-streams-source.kamelet.yaml | 3 +--
connectors/camel-aws-ec2-sink-kafka-connector/pom.xml | 5 -----
.../src/main/resources/kamelets/aws-ec2-sink.kamelet.yaml | 3 +--
.../camel-aws-eventbridge-sink-kafka-connector/pom.xml | 5 -----
.../resources/kamelets/aws-eventbridge-sink.kamelet.yaml | 3 +--
.../camel-aws-kinesis-firehose-sink-kafka-connector/pom.xml | 5 -----
.../kamelets/aws-kinesis-firehose-sink.kamelet.yaml | 3 +--
connectors/camel-aws-kinesis-sink-kafka-connector/pom.xml | 5 -----
.../main/resources/kamelets/aws-kinesis-sink.kamelet.yaml | 3 +--
connectors/camel-aws-kinesis-source-kafka-connector/pom.xml | 5 -----
.../main/resources/kamelets/aws-kinesis-source.kamelet.yaml | 3 +--
connectors/camel-aws-lambda-sink-kafka-connector/pom.xml | 5 -----
.../src/main/resources/kamelets/aws-lambda-sink.kamelet.yaml | 3 +--
connectors/camel-aws-s3-sink-kafka-connector/pom.xml | 5 -----
.../src/main/resources/kamelets/aws-s3-sink.kamelet.yaml | 3 +--
connectors/camel-aws-s3-source-kafka-connector/pom.xml | 5 -----
.../src/main/resources/kamelets/aws-s3-source.kamelet.yaml | 3 +--
.../pom.xml | 5 -----
.../resources/camel-aws-s3-streaming-upload-sink-sink.json | 7 +++++++
.../CamelAwss3streaminguploadsinkSinkConnectorConfig.java | 4 ++++
.../kamelets/aws-s3-streaming-upload-sink.kamelet.yaml | 12 +++++++++---
.../camel-aws-secrets-manager-sink-kafka-connector/pom.xml | 5 -----
.../resources/kamelets/aws-secrets-manager-sink.kamelet.yaml | 3 +--
connectors/camel-aws-ses-sink-kafka-connector/pom.xml | 5 -----
.../src/main/resources/kamelets/aws-ses-sink.kamelet.yaml | 3 +--
connectors/camel-aws-sns-fifo-sink-kafka-connector/pom.xml | 5 -----
.../main/resources/kamelets/aws-sns-fifo-sink.kamelet.yaml | 3 +--
connectors/camel-aws-sns-sink-kafka-connector/pom.xml | 5 -----
.../src/main/resources/kamelets/aws-sns-sink.kamelet.yaml | 3 +--
connectors/camel-aws-sqs-batch-sink-kafka-connector/pom.xml | 5 -----
.../main/resources/kamelets/aws-sqs-batch-sink.kamelet.yaml | 3 +--
connectors/camel-aws-sqs-fifo-sink-kafka-connector/pom.xml | 5 -----
.../main/resources/kamelets/aws-sqs-fifo-sink.kamelet.yaml | 3 +--
connectors/camel-aws-sqs-sink-kafka-connector/pom.xml | 5 -----
.../src/main/resources/kamelets/aws-sqs-sink.kamelet.yaml | 3 +--
connectors/camel-aws-sqs-source-kafka-connector/pom.xml | 5 -----
.../src/main/resources/kamelets/aws-sqs-source.kamelet.yaml | 3 +--
.../main/resources/kamelets/chuck-norris-source.kamelet.yaml | 4 ++--
.../resources/camel-google-storage-source-source.json | 2 +-
.../CamelGooglestoragesourceSourceConnector.properties | 2 +-
.../CamelGooglestoragesourceSourceConnectorConfig.java | 2 +-
.../resources/kamelets/google-storage-source.kamelet.yaml | 2 +-
connectors/camel-minio-source-kafka-connector/pom.xml | 4 ++++
.../src/main/resources/kamelets/minio-source.kamelet.yaml | 6 ++++++
.../src/generated/resources/camel-mongodb-source-source.json | 2 +-
.../CamelMongodbsourceSourceConnectorConfig.java | 2 +-
.../src/main/resources/kamelets/mongodb-source.kamelet.yaml | 2 +-
55 files changed, 67 insertions(+), 152 deletions(-)
diff --git a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws-s3-streaming-upload-sink-sink.json b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws-s3-streaming-upload-sink-sink.json
index aa302331c..e766831e8 100644
--- a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws-s3-streaming-upload-sink-sink.json
+++ b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-aws-s3-streaming-upload-sink-sink.json
@@ -40,6 +40,13 @@
"priority": "MEDIUM",
"required": "false"
},
+ "camel.kamelet.aws-s3-streaming-upload-sink.streamingUploadMode": {
+ "name": "camel.kamelet.aws-s3-streaming-upload-sink.streamingUploadMode",
+ "description": "Setting the Streaming Upload Mode",
+ "defaultValue": "true",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
"camel.kamelet.aws-s3-streaming-upload-sink.restartingPolicy": {
"name": "camel.kamelet.aws-s3-streaming-upload-sink.restartingPolicy",
"description": "The restarting policy to use in streaming upload mode. There are 2 enums and the value can be one of override, lastPart",
diff --git a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-google-storage-source-source.json b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-google-storage-source-source.json
index 1c04eb7b5..a5672e8a8 100644
--- a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-google-storage-source-source.json
+++ b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-google-storage-source-source.json
@@ -17,7 +17,7 @@
},
"camel.kamelet.google-storage-source.serviceAccountKey": {
"name": "camel.kamelet.google-storage-source.serviceAccountKey",
- "description": "The service account key to use as credentials for Google Cloud Storage access. You must encode this value in base64.",
+ "description": "TThe service account key to use as credentials for Google Cloud Storage access. You must encode this value in base64.",
"priority": "HIGH",
"required": "true"
},
diff --git a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-mongodb-source-source.json b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-mongodb-source-source.json
index 72f291a4c..c818ddec7 100644
--- a/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-mongodb-source-source.json
+++ b/camel-kafka-connector-catalog/src/generated/resources/connectors/camel-mongodb-source-source.json
@@ -41,7 +41,7 @@
},
"camel.kamelet.mongodb-source.persistentTailTracking": {
"name": "camel.kamelet.mongodb-source.persistentTailTracking",
- "description": "Specifies to enable persistent tail tracking, which is a mechanism to keep track of the last consumed data across system restarts. The next time the system is up, the endpoint recovers the cursor from the point where it last stopped consuimg data. This option will only work on capped collections.",
+ "description": "Specifies to enable persistent tail tracking, which is a mechanism to keep track of the last consumed data across system restarts. The next time the system is up, the endpoint recovers the cursor from the point where it last stopped consuimg data.",
"defaultValue": "false",
"priority": "MEDIUM",
"required": "false"
diff --git a/connectors/camel-aws-cloudwatch-sink-kafka-connector/pom.xml b/connectors/camel-aws-cloudwatch-sink-kafka-connector/pom.xml
index d1f44f81a..b2e98bb86 100644
--- a/connectors/camel-aws-cloudwatch-sink-kafka-connector/pom.xml
+++ b/connectors/camel-aws-cloudwatch-sink-kafka-connector/pom.xml
@@ -49,11 +49,6 @@
<groupId>org.apache.camel</groupId>
<artifactId>camel-core</artifactId>
</dependency>
- <dependency>
- <groupId>software.amazon.awssdk</groupId>
- <artifactId>utils</artifactId>
- <version>2.17.223</version>
- </dependency>
<dependency>
<groupId>org.apache.camel.kafkaconnector</groupId>
<artifactId>camel-kafka-connector</artifactId>
diff --git a/connectors/camel-aws-cloudwatch-sink-kafka-connector/src/main/resources/kamelets/aws-cloudwatch-sink.kamelet.yaml b/connectors/camel-aws-cloudwatch-sink-kafka-connector/src/main/resources/kamelets/aws-cloudwatch-sink.kamelet.yaml
index b70dbfb48..108e66705 100644
--- a/connectors/camel-aws-cloudwatch-sink-kafka-connector/src/main/resources/kamelets/aws-cloudwatch-sink.kamelet.yaml
+++ b/connectors/camel-aws-cloudwatch-sink-kafka-connector/src/main/resources/kamelets/aws-cloudwatch-sink.kamelet.yaml
@@ -74,7 +74,7 @@ spec:
title: AWS Region
description: The AWS region to access.
type: string
- enum: ["ap-south-1", "eu-south-1", "us-gov-east-1", "me-central-1", "ca-central-1", "eu-central-1", "us-iso-west-1", "us-west-1", "us-west-2", "af-south-1", "eu-north-1", "eu-west-3", "eu-west-2", "eu-west-1", "ap-northeast-3", "ap-northeast-2", "ap-northeast-1", "me-south-1", "sa-east-1", "ap-east-1", "cn-north-1", "us-gov-west-1", "ap-southeast-1", "ap-southeast-2", "us-iso-east-1", "ap-southeast-3", "us-east-1", "us-east-2", "cn-northwest-1", "us-isob-east-1", "aws-global", "a [...]
+ enum: ["af-south-1", "ap-east-1", "ap-northeast-1", "ap-northeast-2", "ap-northeast-3", "ap-south-1", "ap-southeast-1", "ap-southeast-2", "ap-southeast-3", "ca-central-1", "eu-central-1", "eu-north-1", "eu-south-1", "eu-west-1", "eu-west-2", "eu-west-3", "fips-us-east-1", "fips-us-east-2", "fips-us-west-1", "fips-us-west-2", "me-south-1", "sa-east-1", "us-east-1", "us-east-2", "us-west-1", "us-west-2", "cn-north-1", "cn-northwest-1", "us-gov-east-1", "us-gov-west-1", "us-iso-east [...]
useDefaultCredentialsProvider:
title: Default Credentials Provider
description: If true, the CloudWatch client loads credentials through a default credentials provider. If false, it uses the basic authentication method (access key and secret key).
@@ -97,7 +97,6 @@ spec:
- "camel:core"
- "camel:aws2-cw"
- "camel:kamelet"
- - "mvn:software.amazon.awssdk:utils:2.17.223"
template:
from:
uri: kamelet:source
diff --git a/connectors/camel-aws-ddb-sink-kafka-connector/pom.xml b/connectors/camel-aws-ddb-sink-kafka-connector/pom.xml
index c0a842d4b..37560a8ce 100644
--- a/connectors/camel-aws-ddb-sink-kafka-connector/pom.xml
+++ b/connectors/camel-aws-ddb-sink-kafka-connector/pom.xml
@@ -49,11 +49,6 @@
<groupId>org.apache.camel</groupId>
<artifactId>camel-core</artifactId>
</dependency>
- <dependency>
- <groupId>software.amazon.awssdk</groupId>
- <artifactId>utils</artifactId>
- <version>2.17.223</version>
- </dependency>
<dependency>
<groupId>org.apache.camel</groupId>
<artifactId>camel-aws2-ddb</artifactId>
diff --git a/connectors/camel-aws-ddb-sink-kafka-connector/src/main/resources/kamelets/aws-ddb-sink.kamelet.yaml b/connectors/camel-aws-ddb-sink-kafka-connector/src/main/resources/kamelets/aws-ddb-sink.kamelet.yaml
index ed70f94cd..214fedffb 100644
--- a/connectors/camel-aws-ddb-sink-kafka-connector/src/main/resources/kamelets/aws-ddb-sink.kamelet.yaml
+++ b/connectors/camel-aws-ddb-sink-kafka-connector/src/main/resources/kamelets/aws-ddb-sink.kamelet.yaml
@@ -67,7 +67,7 @@ spec:
title: AWS Region
description: The AWS region to access.
type: string
- enum: ["ap-south-1", "eu-south-1", "us-gov-east-1", "me-central-1", "ca-central-1", "eu-central-1", "us-iso-west-1", "us-west-1", "us-west-2", "af-south-1", "eu-north-1", "eu-west-3", "eu-west-2", "eu-west-1", "ap-northeast-3", "ap-northeast-2", "ap-northeast-1", "me-south-1", "sa-east-1", "ap-east-1", "cn-north-1", "us-gov-west-1", "ap-southeast-1", "ap-southeast-2", "us-iso-east-1", "ap-southeast-3", "us-east-1", "us-east-2", "cn-northwest-1", "us-isob-east-1", "aws-global", "a [...]
+ enum: ["af-south-1", "ap-east-1", "ap-northeast-1", "ap-northeast-2", "ap-northeast-3", "ap-south-1", "ap-southeast-1", "ap-southeast-2", "ap-southeast-3", "ca-central-1", "eu-central-1", "eu-north-1", "eu-south-1", "eu-west-1", "eu-west-2", "eu-west-3", "fips-us-east-1", "fips-us-east-2", "fips-us-west-1", "fips-us-west-2", "me-south-1", "sa-east-1", "us-east-1", "us-east-2", "us-west-1", "us-west-2", "cn-north-1", "cn-northwest-1", "us-gov-east-1", "us-gov-west-1", "us-iso-east [...]
operation:
title: Operation
description: "The operation to perform. The options are PutItem, UpdateItem, or DeleteItem."
@@ -106,7 +106,6 @@ spec:
- "camel:jackson"
- "camel:aws2-ddb"
- "camel:kamelet"
- - "mvn:software.amazon.awssdk:utils:2.17.223"
template:
from:
uri: "kamelet:source"
diff --git a/connectors/camel-aws-ddb-streams-source-kafka-connector/pom.xml b/connectors/camel-aws-ddb-streams-source-kafka-connector/pom.xml
index c7d023f2c..4e493e612 100644
--- a/connectors/camel-aws-ddb-streams-source-kafka-connector/pom.xml
+++ b/connectors/camel-aws-ddb-streams-source-kafka-connector/pom.xml
@@ -41,11 +41,6 @@
</dependency>
<!-- Camel -->
<!--START OF GENERATED CODE-->
- <dependency>
- <groupId>software.amazon.awssdk</groupId>
- <artifactId>utils</artifactId>
- <version>2.17.223</version>
- </dependency>
<dependency>
<groupId>org.apache.camel</groupId>
<artifactId>camel-aws2-ddb</artifactId>
diff --git a/connectors/camel-aws-ddb-streams-source-kafka-connector/src/main/resources/kamelets/aws-ddb-streams-source.kamelet.yaml b/connectors/camel-aws-ddb-streams-source-kafka-connector/src/main/resources/kamelets/aws-ddb-streams-source.kamelet.yaml
index 13ace5c71..55cece6f3 100644
--- a/connectors/camel-aws-ddb-streams-source-kafka-connector/src/main/resources/kamelets/aws-ddb-streams-source.kamelet.yaml
+++ b/connectors/camel-aws-ddb-streams-source-kafka-connector/src/main/resources/kamelets/aws-ddb-streams-source.kamelet.yaml
@@ -65,7 +65,7 @@ spec:
title: AWS Region
description: The AWS region to access.
type: string
- enum: ["ap-south-1", "eu-south-1", "us-gov-east-1", "me-central-1", "ca-central-1", "eu-central-1", "us-iso-west-1", "us-west-1", "us-west-2", "af-south-1", "eu-north-1", "eu-west-3", "eu-west-2", "eu-west-1", "ap-northeast-3", "ap-northeast-2", "ap-northeast-1", "me-south-1", "sa-east-1", "ap-east-1", "cn-north-1", "us-gov-west-1", "ap-southeast-1", "ap-southeast-2", "us-iso-east-1", "ap-southeast-3", "us-east-1", "us-east-2", "cn-northwest-1", "us-isob-east-1", "aws-global", "a [...]
+ enum: ["af-south-1", "ap-east-1", "ap-northeast-1", "ap-northeast-2", "ap-northeast-3", "ap-south-1", "ap-southeast-1", "ap-southeast-2", "ap-southeast-3", "ca-central-1", "eu-central-1", "eu-north-1", "eu-south-1", "eu-west-1", "eu-west-2", "eu-west-3", "fips-us-east-1", "fips-us-east-2", "fips-us-west-1", "fips-us-west-2", "me-south-1", "sa-east-1", "us-east-1", "us-east-2", "us-west-1", "us-west-2", "cn-north-1", "cn-northwest-1", "us-gov-east-1", "us-gov-west-1", "us-iso-east [...]
streamIteratorType:
title: Stream Iterator Type
description: Defines where in the DynamoDB stream to start getting records. There are two enums and the value can be one of FROM_LATEST and FROM_START. Note that using FROM_START can cause a significant delay before the stream has caught up to real-time.
@@ -101,7 +101,6 @@ spec:
- "camel:gson"
- "camel:aws2-ddb"
- "camel:kamelet"
- - "mvn:software.amazon.awssdk:utils:2.17.223"
template:
from:
uri: "aws2-ddbstream:{{table}}"
diff --git a/connectors/camel-aws-ec2-sink-kafka-connector/pom.xml b/connectors/camel-aws-ec2-sink-kafka-connector/pom.xml
index 41d9f6b90..7b7bbd096 100644
--- a/connectors/camel-aws-ec2-sink-kafka-connector/pom.xml
+++ b/connectors/camel-aws-ec2-sink-kafka-connector/pom.xml
@@ -49,11 +49,6 @@
<groupId>org.apache.camel</groupId>
<artifactId>camel-core</artifactId>
</dependency>
- <dependency>
- <groupId>software.amazon.awssdk</groupId>
- <artifactId>utils</artifactId>
- <version>2.17.223</version>
- </dependency>
<dependency>
<groupId>org.apache.camel.kafkaconnector</groupId>
<artifactId>camel-kafka-connector</artifactId>
diff --git a/connectors/camel-aws-ec2-sink-kafka-connector/src/main/resources/kamelets/aws-ec2-sink.kamelet.yaml b/connectors/camel-aws-ec2-sink-kafka-connector/src/main/resources/kamelets/aws-ec2-sink.kamelet.yaml
index 4b6102dd6..3c25a86c0 100644
--- a/connectors/camel-aws-ec2-sink-kafka-connector/src/main/resources/kamelets/aws-ec2-sink.kamelet.yaml
+++ b/connectors/camel-aws-ec2-sink-kafka-connector/src/main/resources/kamelets/aws-ec2-sink.kamelet.yaml
@@ -64,7 +64,7 @@ spec:
title: AWS Region
description: The AWS region to access.
type: string
- enum: ["ap-south-1", "eu-south-1", "us-gov-east-1", "me-central-1", "ca-central-1", "eu-central-1", "us-iso-west-1", "us-west-1", "us-west-2", "af-south-1", "eu-north-1", "eu-west-3", "eu-west-2", "eu-west-1", "ap-northeast-3", "ap-northeast-2", "ap-northeast-1", "me-south-1", "sa-east-1", "ap-east-1", "cn-north-1", "us-gov-west-1", "ap-southeast-1", "ap-southeast-2", "us-iso-east-1", "ap-southeast-3", "us-east-1", "us-east-2", "cn-northwest-1", "us-isob-east-1", "aws-global", "a [...]
+ enum: ["af-south-1", "ap-east-1", "ap-northeast-1", "ap-northeast-2", "ap-northeast-3", "ap-south-1", "ap-southeast-1", "ap-southeast-2", "ap-southeast-3", "ca-central-1", "eu-central-1", "eu-north-1", "eu-south-1", "eu-west-1", "eu-west-2", "eu-west-3", "fips-us-east-1", "fips-us-east-2", "fips-us-west-1", "fips-us-west-2", "me-south-1", "sa-east-1", "us-east-1", "us-east-2", "us-west-1", "us-west-2", "cn-north-1", "cn-northwest-1", "us-gov-east-1", "us-gov-west-1", "us-iso-east [...]
useDefaultCredentialsProvider:
title: Default Credentials Provider
description: If true, the CloudWatch client loads credentials through a default credentials provider. If false, it uses the basic authentication method (access key and secret key).
@@ -87,7 +87,6 @@ spec:
- "camel:core"
- "camel:aws2-ec2"
- "camel:kamelet"
- - "mvn:software.amazon.awssdk:utils:2.17.223"
template:
from:
uri: kamelet:source
diff --git a/connectors/camel-aws-eventbridge-sink-kafka-connector/pom.xml b/connectors/camel-aws-eventbridge-sink-kafka-connector/pom.xml
index c830b874e..4a9df2a80 100644
--- a/connectors/camel-aws-eventbridge-sink-kafka-connector/pom.xml
+++ b/connectors/camel-aws-eventbridge-sink-kafka-connector/pom.xml
@@ -49,11 +49,6 @@
<groupId>org.apache.camel</groupId>
<artifactId>camel-core</artifactId>
</dependency>
- <dependency>
- <groupId>software.amazon.awssdk</groupId>
- <artifactId>utils</artifactId>
- <version>2.17.223</version>
- </dependency>
<dependency>
<groupId>org.apache.camel.kafkaconnector</groupId>
<artifactId>camel-kafka-connector</artifactId>
diff --git a/connectors/camel-aws-eventbridge-sink-kafka-connector/src/main/resources/kamelets/aws-eventbridge-sink.kamelet.yaml b/connectors/camel-aws-eventbridge-sink-kafka-connector/src/main/resources/kamelets/aws-eventbridge-sink.kamelet.yaml
index 6fa40ba22..d8328328c 100644
--- a/connectors/camel-aws-eventbridge-sink-kafka-connector/src/main/resources/kamelets/aws-eventbridge-sink.kamelet.yaml
+++ b/connectors/camel-aws-eventbridge-sink-kafka-connector/src/main/resources/kamelets/aws-eventbridge-sink.kamelet.yaml
@@ -73,7 +73,7 @@ spec:
title: AWS Region
description: The AWS region to access.
type: string
- enum: ["ap-south-1", "eu-south-1", "us-gov-east-1", "me-central-1", "ca-central-1", "eu-central-1", "us-iso-west-1", "us-west-1", "us-west-2", "af-south-1", "eu-north-1", "eu-west-3", "eu-west-2", "eu-west-1", "ap-northeast-3", "ap-northeast-2", "ap-northeast-1", "me-south-1", "sa-east-1", "ap-east-1", "cn-north-1", "us-gov-west-1", "ap-southeast-1", "ap-southeast-2", "us-iso-east-1", "ap-southeast-3", "us-east-1", "us-east-2", "cn-northwest-1", "us-isob-east-1", "aws-global", "a [...]
+ enum: ["af-south-1", "ap-east-1", "ap-northeast-1", "ap-northeast-2", "ap-northeast-3", "ap-south-1", "ap-southeast-1", "ap-southeast-2", "ap-southeast-3", "ca-central-1", "eu-central-1", "eu-north-1", "eu-south-1", "eu-west-1", "eu-west-2", "eu-west-3", "fips-us-east-1", "fips-us-east-2", "fips-us-west-1", "fips-us-west-2", "me-south-1", "sa-east-1", "us-east-1", "us-east-2", "us-west-1", "us-west-2", "cn-north-1", "cn-northwest-1", "us-gov-east-1", "us-gov-west-1", "us-iso-east [...]
useDefaultCredentialsProvider:
title: Default Credentials Provider
description: If true, the Eventbridge client loads credentials through a default credentials provider. If false, it uses the basic authentication method (access key and secret key).
@@ -96,7 +96,6 @@ spec:
- "camel:core"
- "camel:aws2-eventbridge"
- "camel:kamelet"
- - "mvn:software.amazon.awssdk:utils:2.17.223"
template:
from:
uri: "kamelet:source"
diff --git a/connectors/camel-aws-kinesis-firehose-sink-kafka-connector/pom.xml b/connectors/camel-aws-kinesis-firehose-sink-kafka-connector/pom.xml
index a26930d8c..de3d739f6 100644
--- a/connectors/camel-aws-kinesis-firehose-sink-kafka-connector/pom.xml
+++ b/connectors/camel-aws-kinesis-firehose-sink-kafka-connector/pom.xml
@@ -41,11 +41,6 @@
</dependency>
<!-- Camel -->
<!--START OF GENERATED CODE-->
- <dependency>
- <groupId>software.amazon.awssdk</groupId>
- <artifactId>utils</artifactId>
- <version>2.17.223</version>
- </dependency>
<dependency>
<groupId>org.apache.camel.kafkaconnector</groupId>
<artifactId>camel-kafka-connector</artifactId>
diff --git a/connectors/camel-aws-kinesis-firehose-sink-kafka-connector/src/main/resources/kamelets/aws-kinesis-firehose-sink.kamelet.yaml b/connectors/camel-aws-kinesis-firehose-sink-kafka-connector/src/main/resources/kamelets/aws-kinesis-firehose-sink.kamelet.yaml
index 89b29180e..d8d258467 100644
--- a/connectors/camel-aws-kinesis-firehose-sink-kafka-connector/src/main/resources/kamelets/aws-kinesis-firehose-sink.kamelet.yaml
+++ b/connectors/camel-aws-kinesis-firehose-sink-kafka-connector/src/main/resources/kamelets/aws-kinesis-firehose-sink.kamelet.yaml
@@ -65,7 +65,7 @@ spec:
title: AWS Region
description: The AWS region to access.
type: string
- enum: ["ap-south-1", "eu-south-1", "us-gov-east-1", "me-central-1", "ca-central-1", "eu-central-1", "us-iso-west-1", "us-west-1", "us-west-2", "af-south-1", "eu-north-1", "eu-west-3", "eu-west-2", "eu-west-1", "ap-northeast-3", "ap-northeast-2", "ap-northeast-1", "me-south-1", "sa-east-1", "ap-east-1", "cn-north-1", "us-gov-west-1", "ap-southeast-1", "ap-southeast-2", "us-iso-east-1", "ap-southeast-3", "us-east-1", "us-east-2", "cn-northwest-1", "us-isob-east-1", "aws-global", "a [...]
+ enum: ["af-south-1", "ap-east-1", "ap-northeast-1", "ap-northeast-2", "ap-northeast-3", "ap-south-1", "ap-southeast-1", "ap-southeast-2", "ap-southeast-3", "ca-central-1", "eu-central-1", "eu-north-1", "eu-south-1", "eu-west-1", "eu-west-2", "eu-west-3", "fips-us-east-1", "fips-us-east-2", "fips-us-west-1", "fips-us-west-2", "me-south-1", "sa-east-1", "us-east-1", "us-east-2", "us-west-1", "us-west-2", "cn-north-1", "cn-northwest-1", "us-gov-east-1", "us-gov-west-1", "us-iso-east [...]
useDefaultCredentialsProvider:
title: Default Credentials Provider
description: Set whether the Kinesis Firehose client should expect to load credentials through a default credentials provider or to expect static credentials to be passed in.
@@ -87,7 +87,6 @@ spec:
dependencies:
- "camel:aws2-kinesis"
- "camel:kamelet"
- - "mvn:software.amazon.awssdk:utils:2.17.223"
template:
from:
uri: kamelet:source
diff --git a/connectors/camel-aws-kinesis-sink-kafka-connector/pom.xml b/connectors/camel-aws-kinesis-sink-kafka-connector/pom.xml
index f31aff9e6..a4f39e457 100644
--- a/connectors/camel-aws-kinesis-sink-kafka-connector/pom.xml
+++ b/connectors/camel-aws-kinesis-sink-kafka-connector/pom.xml
@@ -45,11 +45,6 @@
<groupId>org.apache.camel</groupId>
<artifactId>camel-core</artifactId>
</dependency>
- <dependency>
- <groupId>software.amazon.awssdk</groupId>
- <artifactId>utils</artifactId>
- <version>2.17.223</version>
- </dependency>
<dependency>
<groupId>org.apache.camel.kafkaconnector</groupId>
<artifactId>camel-kafka-connector</artifactId>
diff --git a/connectors/camel-aws-kinesis-sink-kafka-connector/src/main/resources/kamelets/aws-kinesis-sink.kamelet.yaml b/connectors/camel-aws-kinesis-sink-kafka-connector/src/main/resources/kamelets/aws-kinesis-sink.kamelet.yaml
index 62bdb145a..6f04d87d2 100644
--- a/connectors/camel-aws-kinesis-sink-kafka-connector/src/main/resources/kamelets/aws-kinesis-sink.kamelet.yaml
+++ b/connectors/camel-aws-kinesis-sink-kafka-connector/src/main/resources/kamelets/aws-kinesis-sink.kamelet.yaml
@@ -72,7 +72,7 @@ spec:
title: AWS Region
description: The AWS region to access.
type: string
- enum: ["ap-south-1", "eu-south-1", "us-gov-east-1", "me-central-1", "ca-central-1", "eu-central-1", "us-iso-west-1", "us-west-1", "us-west-2", "af-south-1", "eu-north-1", "eu-west-3", "eu-west-2", "eu-west-1", "ap-northeast-3", "ap-northeast-2", "ap-northeast-1", "me-south-1", "sa-east-1", "ap-east-1", "cn-north-1", "us-gov-west-1", "ap-southeast-1", "ap-southeast-2", "us-iso-east-1", "ap-southeast-3", "us-east-1", "us-east-2", "cn-northwest-1", "us-isob-east-1", "aws-global", "a [...]
+ enum: ["af-south-1", "ap-east-1", "ap-northeast-1", "ap-northeast-2", "ap-northeast-3", "ap-south-1", "ap-southeast-1", "ap-southeast-2", "ap-southeast-3", "ca-central-1", "eu-central-1", "eu-north-1", "eu-south-1", "eu-west-1", "eu-west-2", "eu-west-3", "fips-us-east-1", "fips-us-east-2", "fips-us-west-1", "fips-us-west-2", "me-south-1", "sa-east-1", "us-east-1", "us-east-2", "us-west-1", "us-west-2", "cn-north-1", "cn-northwest-1", "us-gov-east-1", "us-gov-west-1", "us-iso-east [...]
useDefaultCredentialsProvider:
title: Default Credentials Provider
description: If true, the Kinesis client loads credentials through a default credentials provider. If false, it uses the basic authentication method (access key and secret key).
@@ -98,7 +98,6 @@ spec:
- "camel:core"
- "camel:aws2-kinesis"
- "camel:kamelet"
- - "mvn:software.amazon.awssdk:utils:2.17.223"
template:
from:
uri: kamelet:source
diff --git a/connectors/camel-aws-kinesis-source-kafka-connector/pom.xml b/connectors/camel-aws-kinesis-source-kafka-connector/pom.xml
index 408ff9c16..b79d8bcdf 100644
--- a/connectors/camel-aws-kinesis-source-kafka-connector/pom.xml
+++ b/connectors/camel-aws-kinesis-source-kafka-connector/pom.xml
@@ -45,11 +45,6 @@
<groupId>org.apache.camel</groupId>
<artifactId>camel-core</artifactId>
</dependency>
- <dependency>
- <groupId>software.amazon.awssdk</groupId>
- <artifactId>utils</artifactId>
- <version>2.17.223</version>
- </dependency>
<dependency>
<groupId>org.apache.camel.kafkaconnector</groupId>
<artifactId>camel-kafka-connector</artifactId>
diff --git a/connectors/camel-aws-kinesis-source-kafka-connector/src/main/resources/kamelets/aws-kinesis-source.kamelet.yaml b/connectors/camel-aws-kinesis-source-kafka-connector/src/main/resources/kamelets/aws-kinesis-source.kamelet.yaml
index e25c4bbd7..e9750da60 100644
--- a/connectors/camel-aws-kinesis-source-kafka-connector/src/main/resources/kamelets/aws-kinesis-source.kamelet.yaml
+++ b/connectors/camel-aws-kinesis-source-kafka-connector/src/main/resources/kamelets/aws-kinesis-source.kamelet.yaml
@@ -65,7 +65,7 @@ spec:
title: AWS Region
description: The AWS region to access.
type: string
- enum: ["ap-south-1", "eu-south-1", "us-gov-east-1", "me-central-1", "ca-central-1", "eu-central-1", "us-iso-west-1", "us-west-1", "us-west-2", "af-south-1", "eu-north-1", "eu-west-3", "eu-west-2", "eu-west-1", "ap-northeast-3", "ap-northeast-2", "ap-northeast-1", "me-south-1", "sa-east-1", "ap-east-1", "cn-north-1", "us-gov-west-1", "ap-southeast-1", "ap-southeast-2", "us-iso-east-1", "ap-southeast-3", "us-east-1", "us-east-2", "cn-northwest-1", "us-isob-east-1", "aws-global", "a [...]
+ enum: ["af-south-1", "ap-east-1", "ap-northeast-1", "ap-northeast-2", "ap-northeast-3", "ap-south-1", "ap-southeast-1", "ap-southeast-2", "ap-southeast-3", "ca-central-1", "eu-central-1", "eu-north-1", "eu-south-1", "eu-west-1", "eu-west-2", "eu-west-3", "fips-us-east-1", "fips-us-east-2", "fips-us-west-1", "fips-us-west-2", "me-south-1", "sa-east-1", "us-east-1", "us-east-2", "us-west-1", "us-west-2", "cn-north-1", "cn-northwest-1", "us-gov-east-1", "us-gov-west-1", "us-iso-east [...]
useDefaultCredentialsProvider:
title: Default Credentials Provider
description: If true, the Kinesis client loads credentials through a default credentials provider. If false, it uses the basic authentication method (access key and secret key).
@@ -96,7 +96,6 @@ spec:
- "camel:aws2-kinesis"
- "camel:kamelet"
- "camel:core"
- - "mvn:software.amazon.awssdk:utils:2.17.223"
template:
from:
uri: aws2-kinesis:{{stream}}
diff --git a/connectors/camel-aws-lambda-sink-kafka-connector/pom.xml b/connectors/camel-aws-lambda-sink-kafka-connector/pom.xml
index 25ec44add..8f685697c 100644
--- a/connectors/camel-aws-lambda-sink-kafka-connector/pom.xml
+++ b/connectors/camel-aws-lambda-sink-kafka-connector/pom.xml
@@ -41,11 +41,6 @@
</dependency>
<!-- Camel -->
<!--START OF GENERATED CODE-->
- <dependency>
- <groupId>software.amazon.awssdk</groupId>
- <artifactId>utils</artifactId>
- <version>2.17.223</version>
- </dependency>
<dependency>
<groupId>org.apache.camel</groupId>
<artifactId>camel-aws2-lambda</artifactId>
diff --git a/connectors/camel-aws-lambda-sink-kafka-connector/src/main/resources/kamelets/aws-lambda-sink.kamelet.yaml b/connectors/camel-aws-lambda-sink-kafka-connector/src/main/resources/kamelets/aws-lambda-sink.kamelet.yaml
index d4e7448ab..a91c923bc 100644
--- a/connectors/camel-aws-lambda-sink-kafka-connector/src/main/resources/kamelets/aws-lambda-sink.kamelet.yaml
+++ b/connectors/camel-aws-lambda-sink-kafka-connector/src/main/resources/kamelets/aws-lambda-sink.kamelet.yaml
@@ -65,7 +65,7 @@ spec:
title: AWS Region
description: The AWS region to access.
type: string
- enum: ["ap-south-1", "eu-south-1", "us-gov-east-1", "me-central-1", "ca-central-1", "eu-central-1", "us-iso-west-1", "us-west-1", "us-west-2", "af-south-1", "eu-north-1", "eu-west-3", "eu-west-2", "eu-west-1", "ap-northeast-3", "ap-northeast-2", "ap-northeast-1", "me-south-1", "sa-east-1", "ap-east-1", "cn-north-1", "us-gov-west-1", "ap-southeast-1", "ap-southeast-2", "us-iso-east-1", "ap-southeast-3", "us-east-1", "us-east-2", "cn-northwest-1", "us-isob-east-1", "aws-global", "a [...]
+ enum: ["af-south-1", "ap-east-1", "ap-northeast-1", "ap-northeast-2", "ap-northeast-3", "ap-south-1", "ap-southeast-1", "ap-southeast-2", "ap-southeast-3", "ca-central-1", "eu-central-1", "eu-north-1", "eu-south-1", "eu-west-1", "eu-west-2", "eu-west-3", "fips-us-east-1", "fips-us-east-2", "fips-us-west-1", "fips-us-west-2", "me-south-1", "sa-east-1", "us-east-1", "us-east-2", "us-west-1", "us-west-2", "cn-north-1", "cn-northwest-1", "us-gov-east-1", "us-gov-west-1", "us-iso-east [...]
useDefaultCredentialsProvider:
title: Default Credentials Provider
description: If true, the Lambda client loads credentials through a default credentials provider. If false, it uses the basic authentication method (access key and secret key).
@@ -76,7 +76,6 @@ spec:
dependencies:
- "camel:aws2-lambda"
- "camel:kamelet"
- - "mvn:software.amazon.awssdk:utils:2.17.223"
template:
from:
uri: kamelet:source
diff --git a/connectors/camel-aws-s3-sink-kafka-connector/pom.xml b/connectors/camel-aws-s3-sink-kafka-connector/pom.xml
index ab1c7da8c..b649e07be 100644
--- a/connectors/camel-aws-s3-sink-kafka-connector/pom.xml
+++ b/connectors/camel-aws-s3-sink-kafka-connector/pom.xml
@@ -45,11 +45,6 @@
<groupId>org.apache.camel</groupId>
<artifactId>camel-core</artifactId>
</dependency>
- <dependency>
- <groupId>software.amazon.awssdk</groupId>
- <artifactId>utils</artifactId>
- <version>2.17.223</version>
- </dependency>
<dependency>
<groupId>org.apache.camel.kafkaconnector</groupId>
<artifactId>camel-kafka-connector</artifactId>
diff --git a/connectors/camel-aws-s3-sink-kafka-connector/src/main/resources/kamelets/aws-s3-sink.kamelet.yaml b/connectors/camel-aws-s3-sink-kafka-connector/src/main/resources/kamelets/aws-s3-sink.kamelet.yaml
index 2342c3a8a..b90d1ee08 100644
--- a/connectors/camel-aws-s3-sink-kafka-connector/src/main/resources/kamelets/aws-s3-sink.kamelet.yaml
+++ b/connectors/camel-aws-s3-sink-kafka-connector/src/main/resources/kamelets/aws-s3-sink.kamelet.yaml
@@ -69,7 +69,7 @@ spec:
title: AWS Region
description: The AWS region to access.
type: string
- enum: ["ap-south-1", "eu-south-1", "us-gov-east-1", "me-central-1", "ca-central-1", "eu-central-1", "us-iso-west-1", "us-west-1", "us-west-2", "af-south-1", "eu-north-1", "eu-west-3", "eu-west-2", "eu-west-1", "ap-northeast-3", "ap-northeast-2", "ap-northeast-1", "me-south-1", "sa-east-1", "ap-east-1", "cn-north-1", "us-gov-west-1", "ap-southeast-1", "ap-southeast-2", "us-iso-east-1", "ap-southeast-3", "us-east-1", "us-east-2", "cn-northwest-1", "us-isob-east-1", "aws-global", "a [...]
+ enum: ["af-south-1", "ap-east-1", "ap-northeast-1", "ap-northeast-2", "ap-northeast-3", "ap-south-1", "ap-southeast-1", "ap-southeast-2", "ap-southeast-3", "ca-central-1", "eu-central-1", "eu-north-1", "eu-south-1", "eu-west-1", "eu-west-2", "eu-west-3", "fips-us-east-1", "fips-us-east-2", "fips-us-west-1", "fips-us-west-2", "me-south-1", "sa-east-1", "us-east-1", "us-east-2", "us-west-1", "us-west-2", "cn-north-1", "cn-northwest-1", "us-gov-east-1", "us-gov-west-1", "us-iso-east [...]
autoCreateBucket:
title: Autocreate Bucket
description: Specifies to automatically create the S3 bucket.
@@ -103,7 +103,6 @@ spec:
- "camel:core"
- "camel:aws2-s3"
- "camel:kamelet"
- - "mvn:software.amazon.awssdk:utils:2.17.223"
template:
from:
uri: "kamelet:source"
diff --git a/connectors/camel-aws-s3-source-kafka-connector/pom.xml b/connectors/camel-aws-s3-source-kafka-connector/pom.xml
index 4e186aef5..42f6b052b 100644
--- a/connectors/camel-aws-s3-source-kafka-connector/pom.xml
+++ b/connectors/camel-aws-s3-source-kafka-connector/pom.xml
@@ -41,11 +41,6 @@
</dependency>
<!-- Camel -->
<!--START OF GENERATED CODE-->
- <dependency>
- <groupId>software.amazon.awssdk</groupId>
- <artifactId>utils</artifactId>
- <version>2.17.223</version>
- </dependency>
<dependency>
<groupId>org.apache.camel.kafkaconnector</groupId>
<artifactId>camel-kafka-connector</artifactId>
diff --git a/connectors/camel-aws-s3-source-kafka-connector/src/main/resources/kamelets/aws-s3-source.kamelet.yaml b/connectors/camel-aws-s3-source-kafka-connector/src/main/resources/kamelets/aws-s3-source.kamelet.yaml
index 3bb8a1c50..868571c67 100644
--- a/connectors/camel-aws-s3-source-kafka-connector/src/main/resources/kamelets/aws-s3-source.kamelet.yaml
+++ b/connectors/camel-aws-s3-source-kafka-connector/src/main/resources/kamelets/aws-s3-source.kamelet.yaml
@@ -55,7 +55,7 @@ spec:
title: AWS Region
description: The AWS region to access.
type: string
- enum: ["ap-south-1", "eu-south-1", "us-gov-east-1", "me-central-1", "ca-central-1", "eu-central-1", "us-iso-west-1", "us-west-1", "us-west-2", "af-south-1", "eu-north-1", "eu-west-3", "eu-west-2", "eu-west-1", "ap-northeast-3", "ap-northeast-2", "ap-northeast-1", "me-south-1", "sa-east-1", "ap-east-1", "cn-north-1", "us-gov-west-1", "ap-southeast-1", "ap-southeast-2", "us-iso-east-1", "ap-southeast-3", "us-east-1", "us-east-2", "cn-northwest-1", "us-isob-east-1", "aws-global", "a [...]
+ enum: ["af-south-1", "ap-east-1", "ap-northeast-1", "ap-northeast-2", "ap-northeast-3", "ap-south-1", "ap-southeast-1", "ap-southeast-2", "ap-southeast-3", "ca-central-1", "eu-central-1", "eu-north-1", "eu-south-1", "eu-west-1", "eu-west-2", "eu-west-3", "fips-us-east-1", "fips-us-east-2", "fips-us-west-1", "fips-us-west-2", "me-south-1", "sa-east-1", "us-east-1", "us-east-2", "us-west-1", "us-west-2", "cn-north-1", "cn-northwest-1", "us-gov-east-1", "us-gov-west-1", "us-iso-east [...]
autoCreateBucket:
title: Autocreate Bucket
description: Specifies to automatically create the S3 bucket.
@@ -108,7 +108,6 @@ spec:
dependencies:
- "camel:aws2-s3"
- "camel:kamelet"
- - "mvn:software.amazon.awssdk:utils:2.17.223"
template:
from:
uri: "aws2-s3:{{bucketNameOrArn}}"
diff --git a/connectors/camel-aws-s3-streaming-upload-sink-kafka-connector/pom.xml b/connectors/camel-aws-s3-streaming-upload-sink-kafka-connector/pom.xml
index 9491614bf..6ea8d928b 100644
--- a/connectors/camel-aws-s3-streaming-upload-sink-kafka-connector/pom.xml
+++ b/connectors/camel-aws-s3-streaming-upload-sink-kafka-connector/pom.xml
@@ -41,11 +41,6 @@
</dependency>
<!-- Camel -->
<!--START OF GENERATED CODE-->
- <dependency>
- <groupId>software.amazon.awssdk</groupId>
- <artifactId>utils</artifactId>
- <version>2.17.223</version>
- </dependency>
<dependency>
<groupId>org.apache.camel.kafkaconnector</groupId>
<artifactId>camel-kafka-connector</artifactId>
diff --git a/connectors/camel-aws-s3-streaming-upload-sink-kafka-connector/src/generated/resources/camel-aws-s3-streaming-upload-sink-sink.json b/connectors/camel-aws-s3-streaming-upload-sink-kafka-connector/src/generated/resources/camel-aws-s3-streaming-upload-sink-sink.json
index aa302331c..e766831e8 100644
--- a/connectors/camel-aws-s3-streaming-upload-sink-kafka-connector/src/generated/resources/camel-aws-s3-streaming-upload-sink-sink.json
+++ b/connectors/camel-aws-s3-streaming-upload-sink-kafka-connector/src/generated/resources/camel-aws-s3-streaming-upload-sink-sink.json
@@ -40,6 +40,13 @@
"priority": "MEDIUM",
"required": "false"
},
+ "camel.kamelet.aws-s3-streaming-upload-sink.streamingUploadMode": {
+ "name": "camel.kamelet.aws-s3-streaming-upload-sink.streamingUploadMode",
+ "description": "Setting the Streaming Upload Mode",
+ "defaultValue": "true",
+ "priority": "MEDIUM",
+ "required": "false"
+ },
"camel.kamelet.aws-s3-streaming-upload-sink.restartingPolicy": {
"name": "camel.kamelet.aws-s3-streaming-upload-sink.restartingPolicy",
"description": "The restarting policy to use in streaming upload mode. There are 2 enums and the value can be one of override, lastPart",
diff --git a/connectors/camel-aws-s3-streaming-upload-sink-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/awss3streaminguploadsink/CamelAwss3streaminguploadsinkSinkConnectorConfig.java b/connectors/camel-aws-s3-streaming-upload-sink-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/awss3streaminguploadsink/CamelAwss3streaminguploadsinkSinkConnectorConfig.java
index 8c851a05b..d66b4ecb5 100644
--- a/connectors/camel-aws-s3-streaming-upload-sink-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/awss3streaminguploadsink/CamelAwss3streaminguploadsinkSinkConnectorConfig.java
+++ b/connectors/camel-aws-s3-streaming-upload-sink-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/awss3streaminguploadsink/CamelAwss3streaminguploadsinkSinkConnectorConfig.java
@@ -41,6 +41,9 @@ public class CamelAwss3streaminguploadsinkSinkConnectorConfig
public static final String CAMEL_SINK_AWSS3STREAMINGUPLOADSINK_KAMELET_AUTO_CREATE_BUCKET_CONF = "camel.kamelet.aws-s3-streaming-upload-sink.autoCreateBucket";
public static final String CAMEL_SINK_AWSS3STREAMINGUPLOADSINK_KAMELET_AUTO_CREATE_BUCKET_DOC = "Setting the autocreation of the S3 bucket bucketName.";
public static final Boolean CAMEL_SINK_AWSS3STREAMINGUPLOADSINK_KAMELET_AUTO_CREATE_BUCKET_DEFAULT = false;
+ public static final String CAMEL_SINK_AWSS3STREAMINGUPLOADSINK_KAMELET_STREAMING_UPLOAD_MODE_CONF = "camel.kamelet.aws-s3-streaming-upload-sink.streamingUploadMode";
+ public static final String CAMEL_SINK_AWSS3STREAMINGUPLOADSINK_KAMELET_STREAMING_UPLOAD_MODE_DOC = "Setting the Streaming Upload Mode";
+ public static final Boolean CAMEL_SINK_AWSS3STREAMINGUPLOADSINK_KAMELET_STREAMING_UPLOAD_MODE_DEFAULT = true;
public static final String CAMEL_SINK_AWSS3STREAMINGUPLOADSINK_KAMELET_RESTARTING_POLICY_CONF = "camel.kamelet.aws-s3-streaming-upload-sink.restartingPolicy";
public static final String CAMEL_SINK_AWSS3STREAMINGUPLOADSINK_KAMELET_RESTARTING_POLICY_DOC = "The restarting policy to use in streaming upload mode. There are 2 enums and the value can be one of override, lastPart";
public static final String CAMEL_SINK_AWSS3STREAMINGUPLOADSINK_KAMELET_RESTARTING_POLICY_DEFAULT = "lastPart";
@@ -87,6 +90,7 @@ public class CamelAwss3streaminguploadsinkSinkConnectorConfig
conf.define(CAMEL_SINK_AWSS3STREAMINGUPLOADSINK_KAMELET_SECRET_KEY_CONF, ConfigDef.Type.PASSWORD, CAMEL_SINK_AWSS3STREAMINGUPLOADSINK_KAMELET_SECRET_KEY_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SINK_AWSS3STREAMINGUPLOADSINK_KAMELET_SECRET_KEY_DOC);
conf.define(CAMEL_SINK_AWSS3STREAMINGUPLOADSINK_KAMELET_REGION_CONF, ConfigDef.Type.STRING, CAMEL_SINK_AWSS3STREAMINGUPLOADSINK_KAMELET_REGION_DEFAULT, ConfigDef.Importance.HIGH, CAMEL_SINK_AWSS3STREAMINGUPLOADSINK_KAMELET_REGION_DOC);
conf.define(CAMEL_SINK_AWSS3STREAMINGUPLOADSINK_KAMELET_AUTO_CREATE_BUCKET_CONF, ConfigDef.Type.BOOLEAN, CAMEL_SINK_AWSS3STREAMINGUPLOADSINK_KAMELET_AUTO_CREATE_BUCKET_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SINK_AWSS3STREAMINGUPLOADSINK_KAMELET_AUTO_CREATE_BUCKET_DOC);
+ conf.define(CAMEL_SINK_AWSS3STREAMINGUPLOADSINK_KAMELET_STREAMING_UPLOAD_MODE_CONF, ConfigDef.Type.BOOLEAN, CAMEL_SINK_AWSS3STREAMINGUPLOADSINK_KAMELET_STREAMING_UPLOAD_MODE_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SINK_AWSS3STREAMINGUPLOADSINK_KAMELET_STREAMING_UPLOAD_MODE_DOC);
conf.define(CAMEL_SINK_AWSS3STREAMINGUPLOADSINK_KAMELET_RESTARTING_POLICY_CONF, ConfigDef.Type.STRING, CAMEL_SINK_AWSS3STREAMINGUPLOADSINK_KAMELET_RESTARTING_POLICY_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SINK_AWSS3STREAMINGUPLOADSINK_KAMELET_RESTARTING_POLICY_DOC);
conf.define(CAMEL_SINK_AWSS3STREAMINGUPLOADSINK_KAMELET_BATCH_MESSAGE_NUMBER_CONF, ConfigDef.Type.INT, CAMEL_SINK_AWSS3STREAMINGUPLOADSINK_KAMELET_BATCH_MESSAGE_NUMBER_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SINK_AWSS3STREAMINGUPLOADSINK_KAMELET_BATCH_MESSAGE_NUMBER_DOC);
conf.define(CAMEL_SINK_AWSS3STREAMINGUPLOADSINK_KAMELET_BATCH_SIZE_CONF, ConfigDef.Type.INT, CAMEL_SINK_AWSS3STREAMINGUPLOADSINK_KAMELET_BATCH_SIZE_DEFAULT, ConfigDef.Importance.MEDIUM, CAMEL_SINK_AWSS3STREAMINGUPLOADSINK_KAMELET_BATCH_SIZE_DOC);
diff --git a/connectors/camel-aws-s3-streaming-upload-sink-kafka-connector/src/main/resources/kamelets/aws-s3-streaming-upload-sink.kamelet.yaml b/connectors/camel-aws-s3-streaming-upload-sink-kafka-connector/src/main/resources/kamelets/aws-s3-streaming-upload-sink.kamelet.yaml
index 2f4d248ce..a4b690f26 100644
--- a/connectors/camel-aws-s3-streaming-upload-sink-kafka-connector/src/main/resources/kamelets/aws-s3-streaming-upload-sink.kamelet.yaml
+++ b/connectors/camel-aws-s3-streaming-upload-sink-kafka-connector/src/main/resources/kamelets/aws-s3-streaming-upload-sink.kamelet.yaml
@@ -66,7 +66,7 @@ spec:
title: AWS Region
description: The AWS region to access.
type: string
- enum: ["ap-south-1", "eu-south-1", "us-gov-east-1", "me-central-1", "ca-central-1", "eu-central-1", "us-iso-west-1", "us-west-1", "us-west-2", "af-south-1", "eu-north-1", "eu-west-3", "eu-west-2", "eu-west-1", "ap-northeast-3", "ap-northeast-2", "ap-northeast-1", "me-south-1", "sa-east-1", "ap-east-1", "cn-north-1", "us-gov-west-1", "ap-southeast-1", "ap-southeast-2", "us-iso-east-1", "ap-southeast-3", "us-east-1", "us-east-2", "cn-northwest-1", "us-isob-east-1", "aws-global", "a [...]
+ enum: ["af-south-1", "ap-east-1", "ap-northeast-1", "ap-northeast-2", "ap-northeast-3", "ap-south-1", "ap-southeast-1", "ap-southeast-2", "ap-southeast-3", "ca-central-1", "eu-central-1", "eu-north-1", "eu-south-1", "eu-west-1", "eu-west-2", "eu-west-3", "fips-us-east-1", "fips-us-east-2", "fips-us-west-1", "fips-us-west-2", "me-south-1", "sa-east-1", "us-east-1", "us-east-2", "us-west-1", "us-west-2", "cn-north-1", "cn-northwest-1", "us-gov-east-1", "us-gov-west-1", "us-iso-east [...]
autoCreateBucket:
title: Autocreate Bucket
description: Setting the autocreation of the S3 bucket bucketName.
@@ -74,6 +74,13 @@ spec:
x-descriptors:
- 'urn:alm:descriptor:com.tectonic.ui:checkbox'
default: false
+ streamingUploadMode:
+ title: Streaming Upload Mode
+ description: Setting the Streaming Upload Mode
+ type: boolean
+ x-descriptors:
+ - 'urn:alm:descriptor:com.tectonic.ui:checkbox'
+ default: true
restartingPolicy:
title: Restarting Policy
description: The restarting policy to use in streaming upload mode. There are 2 enums and the value can be one of override, lastPart
@@ -123,7 +130,6 @@ spec:
dependencies:
- "camel:aws2-s3"
- "camel:kamelet"
- - "mvn:software.amazon.awssdk:utils:2.17.223"
template:
from:
uri: "kamelet:source"
@@ -135,7 +141,7 @@ spec:
accessKey: "{{?accessKey}}"
region: "{{region}}"
autoCreateBucket: "{{autoCreateBucket}}"
- streamingUploadMode: "true"
+ streamingUploadMode: "{{streamingUploadMode}}"
restartingPolicy: "{{restartingPolicy}}"
batchMessageNumber: "{{batchMessageNumber}}"
batchSize: "{{batchSize}}"
diff --git a/connectors/camel-aws-secrets-manager-sink-kafka-connector/pom.xml b/connectors/camel-aws-secrets-manager-sink-kafka-connector/pom.xml
index 0844938fc..cd4df2be9 100644
--- a/connectors/camel-aws-secrets-manager-sink-kafka-connector/pom.xml
+++ b/connectors/camel-aws-secrets-manager-sink-kafka-connector/pom.xml
@@ -45,11 +45,6 @@
<groupId>org.apache.camel</groupId>
<artifactId>camel-core</artifactId>
</dependency>
- <dependency>
- <groupId>software.amazon.awssdk</groupId>
- <artifactId>utils</artifactId>
- <version>2.17.223</version>
- </dependency>
<dependency>
<groupId>org.apache.camel</groupId>
<artifactId>camel-aws-secrets-manager</artifactId>
diff --git a/connectors/camel-aws-secrets-manager-sink-kafka-connector/src/main/resources/kamelets/aws-secrets-manager-sink.kamelet.yaml b/connectors/camel-aws-secrets-manager-sink-kafka-connector/src/main/resources/kamelets/aws-secrets-manager-sink.kamelet.yaml
index 1a1f512d3..bbb507a18 100644
--- a/connectors/camel-aws-secrets-manager-sink-kafka-connector/src/main/resources/kamelets/aws-secrets-manager-sink.kamelet.yaml
+++ b/connectors/camel-aws-secrets-manager-sink-kafka-connector/src/main/resources/kamelets/aws-secrets-manager-sink.kamelet.yaml
@@ -66,7 +66,7 @@ spec:
title: AWS Region
description: The AWS region to access.
type: string
- enum: ["ap-south-1", "eu-south-1", "us-gov-east-1", "me-central-1", "ca-central-1", "eu-central-1", "us-iso-west-1", "us-west-1", "us-west-2", "af-south-1", "eu-north-1", "eu-west-3", "eu-west-2", "eu-west-1", "ap-northeast-3", "ap-northeast-2", "ap-northeast-1", "me-south-1", "sa-east-1", "ap-east-1", "cn-north-1", "us-gov-west-1", "ap-southeast-1", "ap-southeast-2", "us-iso-east-1", "ap-southeast-3", "us-east-1", "us-east-2", "cn-northwest-1", "us-isob-east-1", "aws-global", "a [...]
+ enum: ["af-south-1", "ap-east-1", "ap-northeast-1", "ap-northeast-2", "ap-northeast-3", "ap-south-1", "ap-southeast-1", "ap-southeast-2", "ap-southeast-3", "ca-central-1", "eu-central-1", "eu-north-1", "eu-south-1", "eu-west-1", "eu-west-2", "eu-west-3", "fips-us-east-1", "fips-us-east-2", "fips-us-west-1", "fips-us-west-2", "me-south-1", "sa-east-1", "us-east-1", "us-east-2", "us-west-1", "us-west-2", "cn-north-1", "cn-northwest-1", "us-gov-east-1", "us-gov-west-1", "us-iso-east [...]
useDefaultCredentialsProvider:
title: Default Credentials Provider
description: Set whether the Secrets Manager client should expect to load credentials through a default credentials provider or to expect static credentials to be passed in.
@@ -78,7 +78,6 @@ spec:
- "camel:core"
- "camel:aws-secrets-manager"
- "camel:kamelet"
- - "mvn:software.amazon.awssdk:utils:2.17.223"
template:
from:
uri: "kamelet:source"
diff --git a/connectors/camel-aws-ses-sink-kafka-connector/pom.xml b/connectors/camel-aws-ses-sink-kafka-connector/pom.xml
index 417a23d1f..e33e105cd 100644
--- a/connectors/camel-aws-ses-sink-kafka-connector/pom.xml
+++ b/connectors/camel-aws-ses-sink-kafka-connector/pom.xml
@@ -45,11 +45,6 @@
<groupId>org.apache.camel</groupId>
<artifactId>camel-core</artifactId>
</dependency>
- <dependency>
- <groupId>software.amazon.awssdk</groupId>
- <artifactId>utils</artifactId>
- <version>2.17.223</version>
- </dependency>
<dependency>
<groupId>org.apache.camel</groupId>
<artifactId>camel-aws2-ses</artifactId>
diff --git a/connectors/camel-aws-ses-sink-kafka-connector/src/main/resources/kamelets/aws-ses-sink.kamelet.yaml b/connectors/camel-aws-ses-sink-kafka-connector/src/main/resources/kamelets/aws-ses-sink.kamelet.yaml
index 99cda592b..9e99aff08 100644
--- a/connectors/camel-aws-ses-sink-kafka-connector/src/main/resources/kamelets/aws-ses-sink.kamelet.yaml
+++ b/connectors/camel-aws-ses-sink-kafka-connector/src/main/resources/kamelets/aws-ses-sink.kamelet.yaml
@@ -75,7 +75,7 @@ spec:
title: AWS Region
description: The AWS region to access.
type: string
- enum: ["ap-south-1", "eu-south-1", "us-gov-east-1", "me-central-1", "ca-central-1", "eu-central-1", "us-iso-west-1", "us-west-1", "us-west-2", "af-south-1", "eu-north-1", "eu-west-3", "eu-west-2", "eu-west-1", "ap-northeast-3", "ap-northeast-2", "ap-northeast-1", "me-south-1", "sa-east-1", "ap-east-1", "cn-north-1", "us-gov-west-1", "ap-southeast-1", "ap-southeast-2", "us-iso-east-1", "ap-southeast-3", "us-east-1", "us-east-2", "cn-northwest-1", "us-isob-east-1", "aws-global", "a [...]
+ enum: ["af-south-1", "ap-east-1", "ap-northeast-1", "ap-northeast-2", "ap-northeast-3", "ap-south-1", "ap-southeast-1", "ap-southeast-2", "ap-southeast-3", "ca-central-1", "eu-central-1", "eu-north-1", "eu-south-1", "eu-west-1", "eu-west-2", "eu-west-3", "fips-us-east-1", "fips-us-east-2", "fips-us-west-1", "fips-us-west-2", "me-south-1", "sa-east-1", "us-east-1", "us-east-2", "us-west-1", "us-west-2", "cn-north-1", "cn-northwest-1", "us-gov-east-1", "us-gov-west-1", "us-iso-east [...]
useDefaultCredentialsProvider:
title: Default Credentials Provider
description: If true, the SES client loads credentials through a default credentials provider. If false, it uses the basic authentication method (access key and secret key).
@@ -87,7 +87,6 @@ spec:
- "camel:core"
- "camel:aws2-ses"
- "camel:kamelet"
- - "mvn:software.amazon.awssdk:utils:2.17.223"
template:
from:
uri: "kamelet:source"
diff --git a/connectors/camel-aws-sns-fifo-sink-kafka-connector/pom.xml b/connectors/camel-aws-sns-fifo-sink-kafka-connector/pom.xml
index 7ef68959d..0c813a815 100644
--- a/connectors/camel-aws-sns-fifo-sink-kafka-connector/pom.xml
+++ b/connectors/camel-aws-sns-fifo-sink-kafka-connector/pom.xml
@@ -45,11 +45,6 @@
<groupId>org.apache.camel</groupId>
<artifactId>camel-core</artifactId>
</dependency>
- <dependency>
- <groupId>software.amazon.awssdk</groupId>
- <artifactId>utils</artifactId>
- <version>2.17.223</version>
- </dependency>
<dependency>
<groupId>org.apache.camel.kafkaconnector</groupId>
<artifactId>camel-kafka-connector</artifactId>
diff --git a/connectors/camel-aws-sns-fifo-sink-kafka-connector/src/main/resources/kamelets/aws-sns-fifo-sink.kamelet.yaml b/connectors/camel-aws-sns-fifo-sink-kafka-connector/src/main/resources/kamelets/aws-sns-fifo-sink.kamelet.yaml
index b9f792495..d3ebf541a 100644
--- a/connectors/camel-aws-sns-fifo-sink-kafka-connector/src/main/resources/kamelets/aws-sns-fifo-sink.kamelet.yaml
+++ b/connectors/camel-aws-sns-fifo-sink-kafka-connector/src/main/resources/kamelets/aws-sns-fifo-sink.kamelet.yaml
@@ -69,7 +69,7 @@ spec:
title: AWS Region
description: The AWS region to access.
type: string
- enum: ["ap-south-1", "eu-south-1", "us-gov-east-1", "me-central-1", "ca-central-1", "eu-central-1", "us-iso-west-1", "us-west-1", "us-west-2", "af-south-1", "eu-north-1", "eu-west-3", "eu-west-2", "eu-west-1", "ap-northeast-3", "ap-northeast-2", "ap-northeast-1", "me-south-1", "sa-east-1", "ap-east-1", "cn-north-1", "us-gov-west-1", "ap-southeast-1", "ap-southeast-2", "us-iso-east-1", "ap-southeast-3", "us-east-1", "us-east-2", "cn-northwest-1", "us-isob-east-1", "aws-global", "a [...]
+ enum: ["af-south-1", "ap-east-1", "ap-northeast-1", "ap-northeast-2", "ap-northeast-3", "ap-south-1", "ap-southeast-1", "ap-southeast-2", "ap-southeast-3", "ca-central-1", "eu-central-1", "eu-north-1", "eu-south-1", "eu-west-1", "eu-west-2", "eu-west-3", "fips-us-east-1", "fips-us-east-2", "fips-us-west-1", "fips-us-west-2", "me-south-1", "sa-east-1", "us-east-1", "us-east-2", "us-west-1", "us-west-2", "cn-north-1", "cn-northwest-1", "us-gov-east-1", "us-gov-west-1", "us-iso-east [...]
contentBasedDeduplication:
title: Content-Based Deduplication
description: Use content-based deduplication (should be enabled in the SQS FIFO queue first)
@@ -106,7 +106,6 @@ spec:
- "camel:aws2-sns"
- "camel:core"
- "camel:kamelet"
- - "mvn:software.amazon.awssdk:utils:2.17.223"
template:
from:
uri: kamelet:source
diff --git a/connectors/camel-aws-sns-sink-kafka-connector/pom.xml b/connectors/camel-aws-sns-sink-kafka-connector/pom.xml
index 33e7245e9..350f67aeb 100644
--- a/connectors/camel-aws-sns-sink-kafka-connector/pom.xml
+++ b/connectors/camel-aws-sns-sink-kafka-connector/pom.xml
@@ -45,11 +45,6 @@
<groupId>org.apache.camel</groupId>
<artifactId>camel-core</artifactId>
</dependency>
- <dependency>
- <groupId>software.amazon.awssdk</groupId>
- <artifactId>utils</artifactId>
- <version>2.17.223</version>
- </dependency>
<dependency>
<groupId>org.apache.camel.kafkaconnector</groupId>
<artifactId>camel-kafka-connector</artifactId>
diff --git a/connectors/camel-aws-sns-sink-kafka-connector/src/main/resources/kamelets/aws-sns-sink.kamelet.yaml b/connectors/camel-aws-sns-sink-kafka-connector/src/main/resources/kamelets/aws-sns-sink.kamelet.yaml
index 5ed533316..8a9a6d9c7 100644
--- a/connectors/camel-aws-sns-sink-kafka-connector/src/main/resources/kamelets/aws-sns-sink.kamelet.yaml
+++ b/connectors/camel-aws-sns-sink-kafka-connector/src/main/resources/kamelets/aws-sns-sink.kamelet.yaml
@@ -67,7 +67,7 @@ spec:
title: AWS Region
description: The AWS region to access.
type: string
- enum: ["ap-south-1", "eu-south-1", "us-gov-east-1", "me-central-1", "ca-central-1", "eu-central-1", "us-iso-west-1", "us-west-1", "us-west-2", "af-south-1", "eu-north-1", "eu-west-3", "eu-west-2", "eu-west-1", "ap-northeast-3", "ap-northeast-2", "ap-northeast-1", "me-south-1", "sa-east-1", "ap-east-1", "cn-north-1", "us-gov-west-1", "ap-southeast-1", "ap-southeast-2", "us-iso-east-1", "ap-southeast-3", "us-east-1", "us-east-2", "cn-northwest-1", "us-isob-east-1", "aws-global", "a [...]
+ enum: ["af-south-1", "ap-east-1", "ap-northeast-1", "ap-northeast-2", "ap-northeast-3", "ap-south-1", "ap-southeast-1", "ap-southeast-2", "ap-southeast-3", "ca-central-1", "eu-central-1", "eu-north-1", "eu-south-1", "eu-west-1", "eu-west-2", "eu-west-3", "fips-us-east-1", "fips-us-east-2", "fips-us-west-1", "fips-us-west-2", "me-south-1", "sa-east-1", "us-east-1", "us-east-2", "us-west-1", "us-west-2", "cn-north-1", "cn-northwest-1", "us-gov-east-1", "us-gov-west-1", "us-iso-east [...]
autoCreateTopic:
title: Autocreate Topic
description: Setting the autocreation of the SNS topic.
@@ -97,7 +97,6 @@ spec:
- "camel:core"
- "camel:aws2-sns"
- "camel:kamelet"
- - "mvn:software.amazon.awssdk:utils:2.17.223"
template:
from:
uri: kamelet:source
diff --git a/connectors/camel-aws-sqs-batch-sink-kafka-connector/pom.xml b/connectors/camel-aws-sqs-batch-sink-kafka-connector/pom.xml
index 910aaf5e5..ed7c87a54 100644
--- a/connectors/camel-aws-sqs-batch-sink-kafka-connector/pom.xml
+++ b/connectors/camel-aws-sqs-batch-sink-kafka-connector/pom.xml
@@ -45,11 +45,6 @@
<groupId>org.apache.camel</groupId>
<artifactId>camel-aws2-sqs</artifactId>
</dependency>
- <dependency>
- <groupId>software.amazon.awssdk</groupId>
- <artifactId>utils</artifactId>
- <version>2.17.223</version>
- </dependency>
<dependency>
<groupId>org.apache.camel.kafkaconnector</groupId>
<artifactId>camel-kafka-connector</artifactId>
diff --git a/connectors/camel-aws-sqs-batch-sink-kafka-connector/src/main/resources/kamelets/aws-sqs-batch-sink.kamelet.yaml b/connectors/camel-aws-sqs-batch-sink-kafka-connector/src/main/resources/kamelets/aws-sqs-batch-sink.kamelet.yaml
index d6c38715e..759590ed2 100644
--- a/connectors/camel-aws-sqs-batch-sink-kafka-connector/src/main/resources/kamelets/aws-sqs-batch-sink.kamelet.yaml
+++ b/connectors/camel-aws-sqs-batch-sink-kafka-connector/src/main/resources/kamelets/aws-sqs-batch-sink.kamelet.yaml
@@ -66,7 +66,7 @@ spec:
title: AWS Region
description: The AWS region to access.
type: string
- enum: ["ap-south-1", "eu-south-1", "us-gov-east-1", "me-central-1", "ca-central-1", "eu-central-1", "us-iso-west-1", "us-west-1", "us-west-2", "af-south-1", "eu-north-1", "eu-west-3", "eu-west-2", "eu-west-1", "ap-northeast-3", "ap-northeast-2", "ap-northeast-1", "me-south-1", "sa-east-1", "ap-east-1", "cn-north-1", "us-gov-west-1", "ap-southeast-1", "ap-southeast-2", "us-iso-east-1", "ap-southeast-3", "us-east-1", "us-east-2", "cn-northwest-1", "us-isob-east-1", "aws-global", "a [...]
+ enum: ["af-south-1", "ap-east-1", "ap-northeast-1", "ap-northeast-2", "ap-northeast-3", "ap-south-1", "ap-southeast-1", "ap-southeast-2", "ap-southeast-3", "ca-central-1", "eu-central-1", "eu-north-1", "eu-south-1", "eu-west-1", "eu-west-2", "eu-west-3", "fips-us-east-1", "fips-us-east-2", "fips-us-west-1", "fips-us-west-2", "me-south-1", "sa-east-1", "us-east-1", "us-east-2", "us-west-1", "us-west-2", "cn-north-1", "cn-northwest-1", "us-gov-east-1", "us-gov-west-1", "us-iso-east [...]
autoCreateQueue:
title: Autocreate Queue
description: Setting the autocreation of the SQS queue.
@@ -111,7 +111,6 @@ spec:
dependencies:
- "camel:aws2-sqs"
- "camel:kamelet"
- - "mvn:software.amazon.awssdk:utils:2.17.223"
template:
from:
uri: kamelet:source
diff --git a/connectors/camel-aws-sqs-fifo-sink-kafka-connector/pom.xml b/connectors/camel-aws-sqs-fifo-sink-kafka-connector/pom.xml
index 183123673..db4a372ae 100644
--- a/connectors/camel-aws-sqs-fifo-sink-kafka-connector/pom.xml
+++ b/connectors/camel-aws-sqs-fifo-sink-kafka-connector/pom.xml
@@ -49,11 +49,6 @@
<groupId>org.apache.camel</groupId>
<artifactId>camel-core</artifactId>
</dependency>
- <dependency>
- <groupId>software.amazon.awssdk</groupId>
- <artifactId>utils</artifactId>
- <version>2.17.223</version>
- </dependency>
<dependency>
<groupId>org.apache.camel.kafkaconnector</groupId>
<artifactId>camel-kafka-connector</artifactId>
diff --git a/connectors/camel-aws-sqs-fifo-sink-kafka-connector/src/main/resources/kamelets/aws-sqs-fifo-sink.kamelet.yaml b/connectors/camel-aws-sqs-fifo-sink-kafka-connector/src/main/resources/kamelets/aws-sqs-fifo-sink.kamelet.yaml
index de073a201..0d813841c 100644
--- a/connectors/camel-aws-sqs-fifo-sink-kafka-connector/src/main/resources/kamelets/aws-sqs-fifo-sink.kamelet.yaml
+++ b/connectors/camel-aws-sqs-fifo-sink-kafka-connector/src/main/resources/kamelets/aws-sqs-fifo-sink.kamelet.yaml
@@ -66,7 +66,7 @@ spec:
title: AWS Region
description: The AWS region to access.
type: string
- enum: ["ap-south-1", "eu-south-1", "us-gov-east-1", "me-central-1", "ca-central-1", "eu-central-1", "us-iso-west-1", "us-west-1", "us-west-2", "af-south-1", "eu-north-1", "eu-west-3", "eu-west-2", "eu-west-1", "ap-northeast-3", "ap-northeast-2", "ap-northeast-1", "me-south-1", "sa-east-1", "ap-east-1", "cn-north-1", "us-gov-west-1", "ap-southeast-1", "ap-southeast-2", "us-iso-east-1", "ap-southeast-3", "us-east-1", "us-east-2", "cn-northwest-1", "us-isob-east-1", "aws-global", "a [...]
+ enum: ["af-south-1", "ap-east-1", "ap-northeast-1", "ap-northeast-2", "ap-northeast-3", "ap-south-1", "ap-southeast-1", "ap-southeast-2", "ap-southeast-3", "ca-central-1", "eu-central-1", "eu-north-1", "eu-south-1", "eu-west-1", "eu-west-2", "eu-west-3", "fips-us-east-1", "fips-us-east-2", "fips-us-west-1", "fips-us-west-2", "me-south-1", "sa-east-1", "us-east-1", "us-east-2", "us-west-1", "us-west-2", "cn-north-1", "cn-northwest-1", "us-gov-east-1", "us-gov-west-1", "us-iso-east [...]
contentBasedDeduplication:
title: Content-Based Deduplication
description: Use content-based deduplication (should be enabled in the SQS FIFO queue first)
@@ -114,7 +114,6 @@ spec:
- "camel:aws2-sqs"
- "camel:core"
- "camel:kamelet"
- - "mvn:software.amazon.awssdk:utils:2.17.223"
template:
from:
uri: kamelet:source
diff --git a/connectors/camel-aws-sqs-sink-kafka-connector/pom.xml b/connectors/camel-aws-sqs-sink-kafka-connector/pom.xml
index 3c60ed40a..603400076 100644
--- a/connectors/camel-aws-sqs-sink-kafka-connector/pom.xml
+++ b/connectors/camel-aws-sqs-sink-kafka-connector/pom.xml
@@ -45,11 +45,6 @@
<groupId>org.apache.camel</groupId>
<artifactId>camel-aws2-sqs</artifactId>
</dependency>
- <dependency>
- <groupId>software.amazon.awssdk</groupId>
- <artifactId>utils</artifactId>
- <version>2.17.223</version>
- </dependency>
<dependency>
<groupId>org.apache.camel.kafkaconnector</groupId>
<artifactId>camel-kafka-connector</artifactId>
diff --git a/connectors/camel-aws-sqs-sink-kafka-connector/src/main/resources/kamelets/aws-sqs-sink.kamelet.yaml b/connectors/camel-aws-sqs-sink-kafka-connector/src/main/resources/kamelets/aws-sqs-sink.kamelet.yaml
index 6b27c8a63..f5f41f1c2 100644
--- a/connectors/camel-aws-sqs-sink-kafka-connector/src/main/resources/kamelets/aws-sqs-sink.kamelet.yaml
+++ b/connectors/camel-aws-sqs-sink-kafka-connector/src/main/resources/kamelets/aws-sqs-sink.kamelet.yaml
@@ -65,7 +65,7 @@ spec:
title: AWS Region
description: The AWS region to access.
type: string
- enum: ["ap-south-1", "eu-south-1", "us-gov-east-1", "me-central-1", "ca-central-1", "eu-central-1", "us-iso-west-1", "us-west-1", "us-west-2", "af-south-1", "eu-north-1", "eu-west-3", "eu-west-2", "eu-west-1", "ap-northeast-3", "ap-northeast-2", "ap-northeast-1", "me-south-1", "sa-east-1", "ap-east-1", "cn-north-1", "us-gov-west-1", "ap-southeast-1", "ap-southeast-2", "us-iso-east-1", "ap-southeast-3", "us-east-1", "us-east-2", "cn-northwest-1", "us-isob-east-1", "aws-global", "a [...]
+ enum: ["af-south-1", "ap-east-1", "ap-northeast-1", "ap-northeast-2", "ap-northeast-3", "ap-south-1", "ap-southeast-1", "ap-southeast-2", "ap-southeast-3", "ca-central-1", "eu-central-1", "eu-north-1", "eu-south-1", "eu-west-1", "eu-west-2", "eu-west-3", "fips-us-east-1", "fips-us-east-2", "fips-us-west-1", "fips-us-west-2", "me-south-1", "sa-east-1", "us-east-1", "us-east-2", "us-west-1", "us-west-2", "cn-north-1", "cn-northwest-1", "us-gov-east-1", "us-gov-west-1", "us-iso-east [...]
autoCreateQueue:
title: Autocreate Queue
description: Automatically create the SQS queue.
@@ -105,7 +105,6 @@ spec:
dependencies:
- "camel:aws2-sqs"
- "camel:kamelet"
- - "mvn:software.amazon.awssdk:utils:2.17.223"
template:
from:
uri: kamelet:source
diff --git a/connectors/camel-aws-sqs-source-kafka-connector/pom.xml b/connectors/camel-aws-sqs-source-kafka-connector/pom.xml
index d27ed8598..13d630429 100644
--- a/connectors/camel-aws-sqs-source-kafka-connector/pom.xml
+++ b/connectors/camel-aws-sqs-source-kafka-connector/pom.xml
@@ -45,11 +45,6 @@
<groupId>org.apache.camel</groupId>
<artifactId>camel-aws2-sqs</artifactId>
</dependency>
- <dependency>
- <groupId>software.amazon.awssdk</groupId>
- <artifactId>utils</artifactId>
- <version>2.17.223</version>
- </dependency>
<dependency>
<groupId>org.apache.camel.kafkaconnector</groupId>
<artifactId>camel-kafka-connector</artifactId>
diff --git a/connectors/camel-aws-sqs-source-kafka-connector/src/main/resources/kamelets/aws-sqs-source.kamelet.yaml b/connectors/camel-aws-sqs-source-kafka-connector/src/main/resources/kamelets/aws-sqs-source.kamelet.yaml
index 3f1f7a7fe..1c4fd21c1 100644
--- a/connectors/camel-aws-sqs-source-kafka-connector/src/main/resources/kamelets/aws-sqs-source.kamelet.yaml
+++ b/connectors/camel-aws-sqs-source-kafka-connector/src/main/resources/kamelets/aws-sqs-source.kamelet.yaml
@@ -80,7 +80,7 @@ spec:
x-descriptors:
- urn:keda:metadata:awsRegion
- urn:keda:required
- enum: ["ap-south-1", "eu-south-1", "us-gov-east-1", "me-central-1", "ca-central-1", "eu-central-1", "us-iso-west-1", "us-west-1", "us-west-2", "af-south-1", "eu-north-1", "eu-west-3", "eu-west-2", "eu-west-1", "ap-northeast-3", "ap-northeast-2", "ap-northeast-1", "me-south-1", "sa-east-1", "ap-east-1", "cn-north-1", "us-gov-west-1", "ap-southeast-1", "ap-southeast-2", "us-iso-east-1", "ap-southeast-3", "us-east-1", "us-east-2", "cn-northwest-1", "us-isob-east-1", "aws-global", "a [...]
+ enum: ["af-south-1", "ap-east-1", "ap-northeast-1", "ap-northeast-2", "ap-northeast-3", "ap-south-1", "ap-southeast-1", "ap-southeast-2", "ap-southeast-3", "ca-central-1", "eu-central-1", "eu-north-1", "eu-south-1", "eu-west-1", "eu-west-2", "eu-west-3", "fips-us-east-1", "fips-us-east-2", "fips-us-west-1", "fips-us-west-2", "me-south-1", "sa-east-1", "us-east-1", "us-east-2", "us-west-1", "us-west-2", "cn-north-1", "cn-northwest-1", "us-gov-east-1", "us-gov-west-1", "us-iso-east [...]
autoCreateQueue:
title: Autocreate Queue
description: Setting the autocreation of the SQS queue.
@@ -132,7 +132,6 @@ spec:
dependencies:
- "camel:aws2-sqs"
- "camel:kamelet"
- - "mvn:software.amazon.awssdk:utils:2.17.223"
template:
from:
uri: "aws2-sqs:{{queueNameOrArn}}"
diff --git a/connectors/camel-chuck-norris-source-kafka-connector/src/main/resources/kamelets/chuck-norris-source.kamelet.yaml b/connectors/camel-chuck-norris-source-kafka-connector/src/main/resources/kamelets/chuck-norris-source.kamelet.yaml
index 5ae81e7d6..bd25abd05 100644
--- a/connectors/camel-chuck-norris-source-kafka-connector/src/main/resources/kamelets/chuck-norris-source.kamelet.yaml
+++ b/connectors/camel-chuck-norris-source-kafka-connector/src/main/resources/kamelets/chuck-norris-source.kamelet.yaml
@@ -52,7 +52,7 @@ spec:
parameters:
period: "{{period}}"
steps:
- - to: "https://api.chucknorris.io/jokes/random"
+ - to: "http://api.icndb.com/jokes/random?exclude=[explicit]"
- set-body:
- jsonpath: "$.value"
+ jsonpath: "$.value.joke"
- to: "kamelet:sink"
\ No newline at end of file
diff --git a/connectors/camel-google-storage-source-kafka-connector/src/generated/resources/camel-google-storage-source-source.json b/connectors/camel-google-storage-source-kafka-connector/src/generated/resources/camel-google-storage-source-source.json
index 1c04eb7b5..a5672e8a8 100644
--- a/connectors/camel-google-storage-source-kafka-connector/src/generated/resources/camel-google-storage-source-source.json
+++ b/connectors/camel-google-storage-source-kafka-connector/src/generated/resources/camel-google-storage-source-source.json
@@ -17,7 +17,7 @@
},
"camel.kamelet.google-storage-source.serviceAccountKey": {
"name": "camel.kamelet.google-storage-source.serviceAccountKey",
- "description": "The service account key to use as credentials for Google Cloud Storage access. You must encode this value in base64.",
+ "description": "TThe service account key to use as credentials for Google Cloud Storage access. You must encode this value in base64.",
"priority": "HIGH",
"required": "true"
},
diff --git a/connectors/camel-google-storage-source-kafka-connector/src/main/docs/examples/CamelGooglestoragesourceSourceConnector.properties b/connectors/camel-google-storage-source-kafka-connector/src/main/docs/examples/CamelGooglestoragesourceSourceConnector.properties
index 101b33e1f..cbbed10a1 100644
--- a/connectors/camel-google-storage-source-kafka-connector/src/main/docs/examples/CamelGooglestoragesourceSourceConnector.properties
+++ b/connectors/camel-google-storage-source-kafka-connector/src/main/docs/examples/CamelGooglestoragesourceSourceConnector.properties
@@ -30,5 +30,5 @@ topics=
# The Google Cloud Storage bucket name or Bucket Amazon Resource Name (ARN).
camel.kamelet.google-storage-source.bucketNameOrArn=
-# The service account key to use as credentials for Google Cloud Storage access. You must encode this value in base64.
+# TThe service account key to use as credentials for Google Cloud Storage access. You must encode this value in base64.
camel.kamelet.google-storage-source.serviceAccountKey=
diff --git a/connectors/camel-google-storage-source-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/googlestoragesource/CamelGooglestoragesourceSourceConnectorConfig.java b/connectors/camel-google-storage-source-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/googlestoragesource/CamelGooglestoragesourceSourceConnectorConfig.java
index 150744c98..a4dbdf42a 100644
--- a/connectors/camel-google-storage-source-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/googlestoragesource/CamelGooglestoragesourceSourceConnectorConfig.java
+++ b/connectors/camel-google-storage-source-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/googlestoragesource/CamelGooglestoragesourceSourceConnectorConfig.java
@@ -30,7 +30,7 @@ public class CamelGooglestoragesourceSourceConnectorConfig
public static final String CAMEL_SOURCE_GOOGLESTORAGESOURCE_KAMELET_BUCKET_NAME_OR_ARN_DOC = "The Google Cloud Storage bucket name or Bucket Amazon Resource Name (ARN).";
public static final String CAMEL_SOURCE_GOOGLESTORAGESOURCE_KAMELET_BUCKET_NAME_OR_ARN_DEFAULT = null;
public static final String CAMEL_SOURCE_GOOGLESTORAGESOURCE_KAMELET_SERVICE_ACCOUNT_KEY_CONF = "camel.kamelet.google-storage-source.serviceAccountKey";
- public static final String CAMEL_SOURCE_GOOGLESTORAGESOURCE_KAMELET_SERVICE_ACCOUNT_KEY_DOC = "The service account key to use as credentials for Google Cloud Storage access. You must encode this value in base64.";
+ public static final String CAMEL_SOURCE_GOOGLESTORAGESOURCE_KAMELET_SERVICE_ACCOUNT_KEY_DOC = "TThe service account key to use as credentials for Google Cloud Storage access. You must encode this value in base64.";
public static final String CAMEL_SOURCE_GOOGLESTORAGESOURCE_KAMELET_SERVICE_ACCOUNT_KEY_DEFAULT = null;
public static final String CAMEL_SOURCE_GOOGLESTORAGESOURCE_KAMELET_DELETE_AFTER_READ_CONF = "camel.kamelet.google-storage-source.deleteAfterRead";
public static final String CAMEL_SOURCE_GOOGLESTORAGESOURCE_KAMELET_DELETE_AFTER_READ_DOC = "Specifies to delete objects after consuming them.";
diff --git a/connectors/camel-google-storage-source-kafka-connector/src/main/resources/kamelets/google-storage-source.kamelet.yaml b/connectors/camel-google-storage-source-kafka-connector/src/main/resources/kamelets/google-storage-source.kamelet.yaml
index 49ed58ea5..bf026bce6 100644
--- a/connectors/camel-google-storage-source-kafka-connector/src/main/resources/kamelets/google-storage-source.kamelet.yaml
+++ b/connectors/camel-google-storage-source-kafka-connector/src/main/resources/kamelets/google-storage-source.kamelet.yaml
@@ -44,7 +44,7 @@ spec:
type: string
serviceAccountKey:
title: Service Account Key
- description: The service account key to use as credentials for Google Cloud Storage access. You must encode this value in base64.
+ description: TThe service account key to use as credentials for Google Cloud Storage access. You must encode this value in base64.
type: binary
x-descriptors:
- urn:camel:group:credentials
diff --git a/connectors/camel-minio-source-kafka-connector/pom.xml b/connectors/camel-minio-source-kafka-connector/pom.xml
index b98409856..e026d0190 100644
--- a/connectors/camel-minio-source-kafka-connector/pom.xml
+++ b/connectors/camel-minio-source-kafka-connector/pom.xml
@@ -41,6 +41,10 @@
</dependency>
<!-- Camel -->
<!--START OF GENERATED CODE-->
+ <dependency>
+ <groupId>org.apache.camel</groupId>
+ <artifactId>camel-jackson</artifactId>
+ </dependency>
<dependency>
<groupId>org.apache.camel.kafkaconnector</groupId>
<artifactId>camel-kafka-connector</artifactId>
diff --git a/connectors/camel-minio-source-kafka-connector/src/main/resources/kamelets/minio-source.kamelet.yaml b/connectors/camel-minio-source-kafka-connector/src/main/resources/kamelets/minio-source.kamelet.yaml
index 9b458bc0b..9aa32e409 100644
--- a/connectors/camel-minio-source-kafka-connector/src/main/resources/kamelets/minio-source.kamelet.yaml
+++ b/connectors/camel-minio-source-kafka-connector/src/main/resources/kamelets/minio-source.kamelet.yaml
@@ -77,7 +77,11 @@ spec:
x-descriptors:
- 'urn:alm:descriptor:com.tectonic.ui:checkbox'
default: false
+ types:
+ out:
+ mediaType: application/json
dependencies:
+ - "camel:jackson"
- "camel:minio"
- "camel:kamelet"
template:
@@ -90,4 +94,6 @@ spec:
endpoint: "{{endpoint}}"
deleteAfterRead: "{{deleteAfterRead}}"
steps:
+ - marshal:
+ json: {}
- to: "kamelet:sink"
\ No newline at end of file
diff --git a/connectors/camel-mongodb-source-kafka-connector/src/generated/resources/camel-mongodb-source-source.json b/connectors/camel-mongodb-source-kafka-connector/src/generated/resources/camel-mongodb-source-source.json
index 72f291a4c..c818ddec7 100644
--- a/connectors/camel-mongodb-source-kafka-connector/src/generated/resources/camel-mongodb-source-source.json
+++ b/connectors/camel-mongodb-source-kafka-connector/src/generated/resources/camel-mongodb-source-source.json
@@ -41,7 +41,7 @@
},
"camel.kamelet.mongodb-source.persistentTailTracking": {
"name": "camel.kamelet.mongodb-source.persistentTailTracking",
- "description": "Specifies to enable persistent tail tracking, which is a mechanism to keep track of the last consumed data across system restarts. The next time the system is up, the endpoint recovers the cursor from the point where it last stopped consuimg data. This option will only work on capped collections.",
+ "description": "Specifies to enable persistent tail tracking, which is a mechanism to keep track of the last consumed data across system restarts. The next time the system is up, the endpoint recovers the cursor from the point where it last stopped consuimg data.",
"defaultValue": "false",
"priority": "MEDIUM",
"required": "false"
diff --git a/connectors/camel-mongodb-source-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/mongodbsource/CamelMongodbsourceSourceConnectorConfig.java b/connectors/camel-mongodb-source-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/mongodbsource/CamelMongodbsourceSourceConnectorConfig.java
index cfc7b6088..98449f1d5 100644
--- a/connectors/camel-mongodb-source-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/mongodbsource/CamelMongodbsourceSourceConnectorConfig.java
+++ b/connectors/camel-mongodb-source-kafka-connector/src/main/java/org/apache/camel/kafkaconnector/mongodbsource/CamelMongodbsourceSourceConnectorConfig.java
@@ -42,7 +42,7 @@ public class CamelMongodbsourceSourceConnectorConfig
public static final String CAMEL_SOURCE_MONGODBSOURCE_KAMELET_DATABASE_DOC = "The name of the MongoDB database.";
public static final String CAMEL_SOURCE_MONGODBSOURCE_KAMELET_DATABASE_DEFAULT = null;
public static final String CAMEL_SOURCE_MONGODBSOURCE_KAMELET_PERSISTENT_TAIL_TRACKING_CONF = "camel.kamelet.mongodb-source.persistentTailTracking";
- public static final String CAMEL_SOURCE_MONGODBSOURCE_KAMELET_PERSISTENT_TAIL_TRACKING_DOC = "Specifies to enable persistent tail tracking, which is a mechanism to keep track of the last consumed data across system restarts. The next time the system is up, the endpoint recovers the cursor from the point where it last stopped consuimg data. This option will only work on capped collections.";
+ public static final String CAMEL_SOURCE_MONGODBSOURCE_KAMELET_PERSISTENT_TAIL_TRACKING_DOC = "Specifies to enable persistent tail tracking, which is a mechanism to keep track of the last consumed data across system restarts. The next time the system is up, the endpoint recovers the cursor from the point where it last stopped consuimg data.";
public static final Boolean CAMEL_SOURCE_MONGODBSOURCE_KAMELET_PERSISTENT_TAIL_TRACKING_DEFAULT = false;
public static final String CAMEL_SOURCE_MONGODBSOURCE_KAMELET_TAIL_TRACK_INCREASING_FIELD_CONF = "camel.kamelet.mongodb-source.tailTrackIncreasingField";
public static final String CAMEL_SOURCE_MONGODBSOURCE_KAMELET_TAIL_TRACK_INCREASING_FIELD_DOC = "The correlation field in the incoming data which is of increasing nature and is used to position the tailing cursor every time it is generated.";
diff --git a/connectors/camel-mongodb-source-kafka-connector/src/main/resources/kamelets/mongodb-source.kamelet.yaml b/connectors/camel-mongodb-source-kafka-connector/src/main/resources/kamelets/mongodb-source.kamelet.yaml
index bf6424358..87906e0ed 100644
--- a/connectors/camel-mongodb-source-kafka-connector/src/main/resources/kamelets/mongodb-source.kamelet.yaml
+++ b/connectors/camel-mongodb-source-kafka-connector/src/main/resources/kamelets/mongodb-source.kamelet.yaml
@@ -71,7 +71,7 @@ spec:
type: string
persistentTailTracking:
title: MongoDB Persistent Tail Tracking
- description: Specifies to enable persistent tail tracking, which is a mechanism to keep track of the last consumed data across system restarts. The next time the system is up, the endpoint recovers the cursor from the point where it last stopped consuimg data. This option will only work on capped collections.
+ description: Specifies to enable persistent tail tracking, which is a mechanism to keep track of the last consumed data across system restarts. The next time the system is up, the endpoint recovers the cursor from the point where it last stopped consuimg data.
type: boolean
x-descriptors:
- 'urn:alm:descriptor:com.tectonic.ui:checkbox'