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

Make sure sequence number is never an empty value, default to '0'.

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

3
store/ddb/ddb.go
View file

@ -116,6 +116,9 @@ 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
} }