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:16 UTC
[camel-kamelets] 01/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 51a2e476d094a0cc17c4ff21d4cdb15cbc64c844
Author: Andrea Cosentino <an...@gmail.com>
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"