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/07 09:07:18 UTC

[camel-kamelets] 03/05: Duplicate some of headers with a different name - AWS Kinesis Source

This is an automated email from the ASF dual-hosted git repository.

acosentino pushed a commit to branch aws-kinesis-dup-headers
in repository https://gitbox.apache.org/repos/asf/camel-kamelets.git

commit 1d51aa062c20369afb5803069e434af7deb41c6c
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Fri Oct 7 11:05:05 2022 +0200

    Duplicate some of headers with a different name - AWS Kinesis Source
---
 .../src/main/resources/kamelets/aws-kinesis-source.kamelet.yaml       | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

diff --git a/library/camel-kamelets/src/main/resources/kamelets/aws-kinesis-source.kamelet.yaml b/library/camel-kamelets/src/main/resources/kamelets/aws-kinesis-source.kamelet.yaml
index 4c9decdf..c840d26a 100644
--- a/library/camel-kamelets/src/main/resources/kamelets/aws-kinesis-source.kamelet.yaml
+++ b/library/camel-kamelets/src/main/resources/kamelets/aws-kinesis-source.kamelet.yaml
@@ -36,6 +36,8 @@ spec:
       The basic authentication method for the Kinesis service is to specify an access key and a secret key. These parameters are optional because the Kamelet provides a default credentials provider.
       
       If you use the default credentials provider, the Kinesis client loads the credentials through this provider and doesn't use the basic authentication method.
+
+      Two headers will be duplicated with different names for clarity at sink level, CamelAwsS3Key will be duplicated into aws.s3.key and CamelAwsS3BucketName will be duplicated in aws.s3.bucket.name
     required:
       - stream
       - region
@@ -109,7 +111,7 @@ spec:
           - key: mode
             value: 'filtering'
           - key: selectedHeaders
-            value: 'CamelAwsKinesisPartitionKey,CamelAwsKinesisShardId,CamelAwsKinesisSequenceNumber'
+            value: 'CamelAwsKinesisPartitionKey,CamelAwsKinesisSequenceNumber'
     from:
       uri: aws2-kinesis:{{stream}}
       parameters: