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

fix periodic checkpoint not triggered

Browse source 
when initialized, largestPair is empty and IsLessThan always return
false
This commit is contained in:
Tony Wang 2018-11-09 15:08:47 +08:00
parent 33d58bc6e0
commit 2f722d9cd2
No known key found for this signature in database
GPG key ID: 624D973D837983DF
1 changed files with 1 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
cmd/consumer/main.go
View file

@ -29,7 +29,7 @@ func (srp *sampleRecordProcessor) Initialize(shardID string, checkpointer kcl.Ch
} }
func (srp *sampleRecordProcessor) shouldUpdateSequence(pair kcl.SequencePair) bool { func (srp *sampleRecordProcessor) shouldUpdateSequence(pair kcl.SequencePair) bool {
return srp.largestPair.IsLessThan(pair) return srp.largestPair.IsNil() || srp.largestPair.IsLessThan(pair)
} }
func (srp *sampleRecordProcessor) ProcessRecords(records []kcl.Record) error { func (srp *sampleRecordProcessor) ProcessRecords(records []kcl.Record) error {