luciano/kinesis-consumer
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Add checkpoint diagram

Browse source
This commit is contained in:
Harlow Ward 2017-11-20 11:06:46 -08:00 committed by GitHub
parent 28837eee9e
commit 9620261104
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
1 changed files with 5 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

5
README.md
View file

@ -71,6 +71,11 @@ c, err := consumer.New(
### Checkpoint
To record the progress of the consumer in the stream we store the last sequence number the consumer has read from a particular shard. This will allow consumers to re-launch and pick up at the position in the stream where they left off.
<img width="694" alt="kinesis-checkpoints" src="https://user-images.githubusercontent.com/739782/33036220-95649ce8-cde2-11e7-99dc-725c38d3d902.png">
The default checkpoint uses Redis on localhost; to set a custom Redis URL use ENV vars:
```