From f1af849e810d6773ec53b4c83f5cbfd7afa72985 Mon Sep 17 00:00:00 2001 From: dan Date: Tue, 7 Apr 2015 08:53:06 -0700 Subject: [PATCH] handle recoverable error properly --- pipeline.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/pipeline.go b/pipeline.go index 4b4e809..09f6ac2 100644 --- a/pipeline.go +++ b/pipeline.go @@ -28,7 +28,7 @@ func (p Pipeline) isRecoverableError(err error) bool { r := false cErr, ok := err.(*kinesis.Error) - if ok && cErr.Code == "ProvisionedThroughputExceeded" { + if ok && cErr.Code == "ProvisionedThroughputExceededException" { r = true }