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-kamelets.git
commit 20f1f320894f4a8a44754e4458f4a86183c70f08 Author: Andrea Cosentino <[email protected]> AuthorDate: Wed Mar 9 10:29:53 2022 +0100 AWS Kinesis Source Kamelet Improvements --- kamelets/aws-kinesis-source.kamelet.yaml | 2 ++ .../src/main/resources/kamelets/aws-kinesis-source.kamelet.yaml | 2 ++ 2 files changed, 4 insertions(+) diff --git a/kamelets/aws-kinesis-source.kamelet.yaml b/kamelets/aws-kinesis-source.kamelet.yaml index 9b6aea1..d4298ba 100644 --- a/kamelets/aws-kinesis-source.kamelet.yaml +++ b/kamelets/aws-kinesis-source.kamelet.yaml @@ -88,4 +88,6 @@ spec: region: "{{region}}" useDefaultCredentialsProvider: "{{useDefaultCredentialsProvider}}" steps: + - set-body: + simple: "${body.data().asInputStream()}" - 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 9b6aea1..d4298ba 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 @@ -88,4 +88,6 @@ spec: region: "{{region}}" useDefaultCredentialsProvider: "{{useDefaultCredentialsProvider}}" steps: + - set-body: + simple: "${body.data().asInputStream()}" - to: "kamelet:sink"
