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

Back out last change to default sequence numbers.

Browse source
This commit is contained in:
GUY.MOLINARI 2024-12-07 19:21:46 +00:00
parent 192ad8cc39
commit c0ae585296
1 changed files with 0 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

3
store/ddb/ddb.go
View file

@ -116,9 +116,6 @@ func (c *Checkpoint) GetCheckpoint(streamName, shardID string) (string, error) {
var i item var i item
attributevalue.UnmarshalMap(resp.Item, &i) attributevalue.UnmarshalMap(resp.Item, &i)
if i.SequenceNumber == "" {
i.SequenceNumber = "0"
}
return i.SequenceNumber, nil return i.SequenceNumber, nil
} }