From 27f13ed3fca8d2dae8b728f23ff45e1651a1bdf6 Mon Sep 17 00:00:00 2001 From: Harlow Ward Date: Mon, 18 Feb 2019 10:30:37 -0800 Subject: [PATCH] fix merge conflict --- consumer.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/consumer.go b/consumer.go index 676073a..d2f4b2b 100644 --- a/consumer.go +++ b/consumer.go @@ -225,9 +225,9 @@ func (c *Consumer) getShardIterator(streamName, shardID, seqNum string) (*string StreamName: aws.String(streamName), } - if lastSeqNum != "" { + if seqNum != "" { params.ShardIteratorType = aws.String(kinesis.ShardIteratorTypeAfterSequenceNumber) - params.StartingSequenceNumber = aws.String(lastSeqNum) + params.StartingSequenceNumber = aws.String(seqNum) } else { params.ShardIteratorType = aws.String(c.initialShardIteratorType) }