From 5301dfe963130733f5e6f0b036b143795cad4fe5 Mon Sep 17 00:00:00 2001
From: dan <dan@ezoic.com>
Date: Fri, 3 Apr 2015 22:48:38 -0700
Subject: [PATCH] fix the recoverable error logic to prevent crash

---
 pipeline.go | 2 ++
 1 file changed, 2 insertions(+)

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