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 51a2e476d094a0cc17c4ff21d4cdb15cbc64c844 Author: Andrea Cosentino <[email protected]> AuthorDate: Fri Oct 7 11:00:44 2022 +0200 Duplicate some of headers with a different name - AWS Kinesis Source --- kamelets/aws-kinesis-source.kamelet.yaml | 15 +++++++++++++++ .../resources/kamelets/aws-kinesis-source.kamelet.yaml | 15 +++++++++++++++ 2 files changed, 30 insertions(+) diff --git a/kamelets/aws-kinesis-source.kamelet.yaml b/kamelets/aws-kinesis-source.kamelet.yaml index bdd814a0..4c9decdf 100644 --- a/kamelets/aws-kinesis-source.kamelet.yaml +++ b/kamelets/aws-kinesis-source.kamelet.yaml @@ -96,7 +96,20 @@ spec: - "camel:aws2-kinesis" - "camel:kamelet" - "camel:core" + - "github:apache.camel-kamelets:camel-kamelets-utils:main-SNAPSHOT" template: + beans: + - name: duplicateHeaders + type: "#class:org.apache.camel.kamelets.utils.headers.DuplicateNamingHeaders" + property: + - key: prefix + value: 'CamelAwsKinesis' + - key: renamingPrefix + value: 'aws.kinesis.' + - key: mode + value: 'filtering' + - key: selectedHeaders + value: 'CamelAwsKinesisPartitionKey,CamelAwsKinesisShardId,CamelAwsKinesisSequenceNumber' from: uri: aws2-kinesis:{{stream}} parameters: @@ -108,4 +121,6 @@ spec: overrideEndpoint: "{{overrideEndpoint}}" delay: "{{delay}}" steps: + - process: + ref: "{{duplicateHeaders}}" - to: "kamelet:sink" 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 bdd814a0..4c9decdf 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 @@ -96,7 +96,20 @@ spec: - "camel:aws2-kinesis" - "camel:kamelet" - "camel:core" + - "github:apache.camel-kamelets:camel-kamelets-utils:main-SNAPSHOT" template: + beans: + - name: duplicateHeaders + type: "#class:org.apache.camel.kamelets.utils.headers.DuplicateNamingHeaders" + property: + - key: prefix + value: 'CamelAwsKinesis' + - key: renamingPrefix + value: 'aws.kinesis.' + - key: mode + value: 'filtering' + - key: selectedHeaders + value: 'CamelAwsKinesisPartitionKey,CamelAwsKinesisShardId,CamelAwsKinesisSequenceNumber' from: uri: aws2-kinesis:{{stream}} parameters: @@ -108,4 +121,6 @@ spec: overrideEndpoint: "{{overrideEndpoint}}" delay: "{{delay}}" steps: + - process: + ref: "{{duplicateHeaders}}" - to: "kamelet:sink"
