From 4fd29c54ffc216eb34b7f2435699272ce6b07c2b Mon Sep 17 00:00:00 2001 From: Harlow Ward Date: Sun, 2 Jun 2019 17:29:22 -0700 Subject: [PATCH] rever the no-op checkpoint --- consumer.go | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/consumer.go b/consumer.go index af50fa4..8596525 100644 --- a/consumer.go +++ b/consumer.go @@ -23,11 +23,12 @@ func New(streamName string, opts ...Option) (*Consumer, error) { return nil, fmt.Errorf("must provide stream name") } - // new consumer with noop group, counter, and logger + // new consumer with no-op checkpoint, counter, and logger c := &Consumer{ streamName: streamName, initialShardIteratorType: kinesis.ShardIteratorTypeLatest, counter: &noopCounter{}, + checkpoint: &noopCheckpoint{}, logger: &noopLogger{ logger: log.New(ioutil.Discard, "", log.LstdFlags), },