Merge pull request #27 from apache/1.1.0-kinesis-update
Kinesis Firehose S3 Source example update
diff --git a/06-aws-kinesis-firehose-basic/aws-s3-source.yaml b/06-aws-kinesis-firehose-basic/aws-s3-source.yaml
index d0ff2ae..e0fa44c 100644
--- a/06-aws-kinesis-firehose-basic/aws-s3-source.yaml
+++ b/06-aws-kinesis-firehose-basic/aws-s3-source.yaml
@@ -23,8 +23,9 @@
secretKey: "{{aws.s3.secretKey}}"
accessKey: "{{aws.s3.accessKey}}"
region: "{{aws.s3.region}}"
- moveAfterRead: "false"
- deleteAfterRead: "false"
+ moveAfterRead: "true"
+ deleteAfterRead: "true"
+ destinationBucket: "backupdatalake25"
autocloseBody: "false"
steps:
- to: "log:received?showAll=true&multiline=true"
diff --git a/06-aws-kinesis-firehose-basic/readme.didact.md b/06-aws-kinesis-firehose-basic/readme.didact.md
index 8264d75..864e468 100644
--- a/06-aws-kinesis-firehose-basic/readme.didact.md
+++ b/06-aws-kinesis-firehose-basic/readme.didact.md
@@ -15,6 +15,7 @@
You should open this file with [Didact](https://marketplace.visualstudio.com/items?itemName=redhat.vscode-didact) if available on your IDE.
You must create an AWS Kinesis Firehose delivery stream named `stream` and point it to an S3 bucket called `datalake` followed by a random number on your AWS account.
+Also you'll need to create a bucket `backupdatalake` followed by a random number on your AWS account. This bucket will be used to move the file once consumed from the bucket `datalake` as backup.
## Requirements
