From 9620261104ec2d86dccdd8059d104bbcdc185620 Mon Sep 17 00:00:00 2001 From: Harlow Ward Date: Mon, 20 Nov 2017 11:06:46 -0800 Subject: [PATCH] Add checkpoint diagram --- README.md | 5 +++++ 1 file changed, 5 insertions(+) diff --git a/README.md b/README.md index a45db6b..cd54cff 100644 --- a/README.md +++ b/README.md @@ -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. + +kinesis-checkpoints + + The default checkpoint uses Redis on localhost; to set a custom Redis URL use ENV vars: ```