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

handle recoverable error properly

Browse source
This commit is contained in:
dan 2015-04-07 08:53:06 -07:00
parent 6f8ff3f11d
commit f1af849e81
1 changed files with 1 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
pipeline.go
View file

@ -28,7 +28,7 @@ func (p Pipeline) isRecoverableError(err error) bool {
r := false r := false
cErr, ok := err.(*kinesis.Error) cErr, ok := err.(*kinesis.Error)
if ok && cErr.Code == "ProvisionedThroughputExceeded" { if ok && cErr.Code == "ProvisionedThroughputExceededException" {
r = true r = true
} }