You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by lb...@apache.org on 2020/07/14 12:59:28 UTC
[camel-k-examples] branch master updated: Camel-AWS-Kinesis
example: Fixed signature issue,
missing region in the chain and align CBOR version
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 <an...@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}}®ion=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