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

fix the recoverable error logic to prevent crash

Browse source
This commit is contained in:
dan 2015-04-03 22:48:38 -07:00
parent 6502115563
commit 5301dfe963
1 changed files with 2 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
pipeline.go
View file

@ -81,7 +81,9 @@ func (p Pipeline) ProcessShard(ksis *kinesis.Kinesis, shardID string) {
if err != nil { if err != nil {
if p.isRecoverableError(err) { if p.isRecoverableError(err) {
l4g.Info("recoverable error, %s", err)
consecutiveErrorAttempts++ consecutiveErrorAttempts++
continue
} else { } else {
l4g.Critical("GetRecords ERROR: %v\n", err) l4g.Critical("GetRecords ERROR: %v\n", err)
os.Exit(1) os.Exit(1)