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 <osc...@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'