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

lburgazzoli pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/camel-k-examples.git


The following commit(s) were added to refs/heads/master by this push:
     new 2031eea  Camel-AWS-Kinesis example: Fixed signature issue, missing 
region in the chain and align CBOR version
2031eea is described below

commit 2031eea281995734f72ffdf8737c525eaeec6591
Author: Andrea Cosentino <anco...@gmail.com>
AuthorDate: Tue Jul 14 14:50:37 2020 +0200

    Camel-AWS-Kinesis example: Fixed signature issue, missing region in the 
chain and align CBOR version
---
 04-aws-kinesis-source-basic/aws-kinesis-producer.groovy | 2 +-
 04-aws-kinesis-source-basic/aws-kinesis-source.yaml     | 2 ++
 04-aws-kinesis-source-basic/aws-kinesis.properties      | 4 ++--
 3 files changed, 5 insertions(+), 3 deletions(-)

diff --git a/04-aws-kinesis-source-basic/aws-kinesis-producer.groovy 
b/04-aws-kinesis-source-basic/aws-kinesis-producer.groovy
index 78f9e20..041a50c 100644
--- a/04-aws-kinesis-source-basic/aws-kinesis-producer.groovy
+++ b/04-aws-kinesis-source-basic/aws-kinesis-producer.groovy
@@ -10,4 +10,4 @@ from('timer:java?period=3000&repeatCount=100')
         .constant(1)
     .setBody()
         .simple('Hello Camel K')
-    
.to('aws-kinesis:stream?accessKey={{aws.kinesis.accessKey}}&secretKey={{aws.kinesis.accessKey}}')
+    
.to('aws-kinesis:stream?accessKey={{aws.kinesis.accessKey}}&secretKey={{aws.kinesis.secretKey}}&region=EU_WEST_1')
diff --git a/04-aws-kinesis-source-basic/aws-kinesis-source.yaml 
b/04-aws-kinesis-source-basic/aws-kinesis-source.yaml
index a302a1d..655daad 100644
--- a/04-aws-kinesis-source-basic/aws-kinesis-source.yaml
+++ b/04-aws-kinesis-source-basic/aws-kinesis-source.yaml
@@ -16,12 +16,14 @@ spec:
         - camel:jackson
         # Needed for the AWS Kinesis component
         - camel:camel-aws-kinesis
+        - mvn:com.fasterxml.jackson.dataformat/jackson-dataformat-cbor/2.10.4
     flow:
       from:
         uri: aws-kinesis:stream
         parameters:
           secretKey: "{{aws.kinesis.secretKey}}"
           accessKey: "{{aws.kinesis.accessKey}}"
+          region: "EU_WEST_1"
         steps:
         - to: "log:received?showAll=true&multiline=true"
         - marshal:
diff --git a/04-aws-kinesis-source-basic/aws-kinesis.properties 
b/04-aws-kinesis-source-basic/aws-kinesis.properties
index 446bf1d..d014874 100644
--- a/04-aws-kinesis-source-basic/aws-kinesis.properties
+++ b/04-aws-kinesis-source-basic/aws-kinesis.properties
@@ -1,2 +1,2 @@
-aws.kinesis.accessKey=accesskey
-aws.kinesis.secretKey=secretkey
\ No newline at end of file
+aws.kinesis.accessKey=accessKey
+aws.kinesis.secretKey=secretKey

Reply via email to