From ab78feabaa583718a7b9f7675fa5d88553b5aac9 Mon Sep 17 00:00:00 2001 From: Andrea Cosentino Date: Wed, 9 Mar 2022 10:29:53 +0100 Subject: [PATCH 1/3] 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 9b6aea159..d4298ba95 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 9b6aea159..d4298ba95 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" From 4d0e97833ee7e801048f0712e4c4a17c652ddb77 Mon Sep 17 00:00:00 2001 From: Andrea Cosentino Date: Wed, 9 Mar 2022 10:43:03 +0100 Subject: [PATCH 2/3] AWS Kinesis Source Kamelet Improvements --- kamelets/aws-kinesis-source.kamelet.yaml | 1 + 1 file changed, 1 insertion(+) diff --git a/kamelets/aws-kinesis-source.kamelet.yaml b/kamelets/aws-kinesis-source.kamelet.yaml index d4298ba95..79883229f 100644 --- a/kamelets/aws-kinesis-source.kamelet.yaml +++ b/kamelets/aws-kinesis-source.kamelet.yaml @@ -79,6 +79,7 @@ spec: dependencies: - "camel:aws2-kinesis" - "camel:kamelet" + - "camel:core" template: from: uri: aws2-kinesis:{{stream}} From c8fdf65d92d012c997cc131c6655f6c8c7ffb300 Mon Sep 17 00:00:00 2001 From: Andrea Cosentino Date: Wed, 9 Mar 2022 10:44:31 +0100 Subject: [PATCH 3/3] AWS Kinesis Source Kamelet Improvements --- .../src/main/resources/kamelets/aws-kinesis-source.kamelet.yaml | 1 + 1 file changed, 1 insertion(+) 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 d4298ba95..79883229f 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 @@ -79,6 +79,7 @@ spec: dependencies: - "camel:aws2-kinesis" - "camel:kamelet" + - "camel:core" template: from: uri: aws2-kinesis:{{stream}}