This is an automated email from the ASF dual-hosted git repository. acosentino pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/camel-k-examples.git
commit e67ff88102e1cce36c1a1a23ed4cbd47e46b2695 Author: Andrea Cosentino <[email protected]> AuthorDate: Tue Jul 14 18:34:55 2020 +0200 Camel-AWS-Kinesis-example: Introducing region in the configuration --- 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 | 1 + 3 files changed, 3 insertions(+), 2 deletions(-) diff --git a/04-aws-kinesis-source-basic/aws-kinesis-producer.groovy b/04-aws-kinesis-source-basic/aws-kinesis-producer.groovy index 041a50c..d96a29b 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.secretKey}}®ion=EU_WEST_1') + .to('aws-kinesis:stream?accessKey={{aws.kinesis.accessKey}}&secretKey={{aws.kinesis.secretKey}}®ion={{aws.kinesis.region}}') diff --git a/04-aws-kinesis-source-basic/aws-kinesis-source.yaml b/04-aws-kinesis-source-basic/aws-kinesis-source.yaml index 655daad..8bda7a1 100644 --- a/04-aws-kinesis-source-basic/aws-kinesis-source.yaml +++ b/04-aws-kinesis-source-basic/aws-kinesis-source.yaml @@ -23,7 +23,7 @@ spec: parameters: secretKey: "{{aws.kinesis.secretKey}}" accessKey: "{{aws.kinesis.accessKey}}" - region: "EU_WEST_1" + region: "{{aws.kinesis.region}}" 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 d014874..a9d43a2 100644 --- a/04-aws-kinesis-source-basic/aws-kinesis.properties +++ b/04-aws-kinesis-source-basic/aws-kinesis.properties @@ -1,2 +1,3 @@ aws.kinesis.accessKey=accessKey aws.kinesis.secretKey=secretKey +aws.kinesis.region=region
