Merge branch 'master' of github.com:rewardStyle/kinetic

rewardStyle · Mar 22, 2016 · cd51a72 · cd51a72
2 parents 396d527 + 4deb99c
commit cd51a72
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 1 deletion.
diff --git a/README.md b/README.md
@@ -36,7 +36,7 @@ import "github.com/rewardStyle/kinetic"
 listener, _ := new(kinetic.Listener).Init()
 
 // Use custom configuration
-producer, _ := new(kinetic.Producer).InitC("your-stream", "0", "shard-type", "accesskey", "secretkey", "region")
+producer, _ := new(kinetic.Producer).InitC("your-stream", "0", "shard-type", "accesskey", "secretkey", "region", 10)
 
 producer.Send(new(kinetic.Message).Init([]byte(`{"foo":"bar"}`), "test"))
 

diff --git a/listener.go b/listener.go
@@ -201,6 +201,9 @@ func (l *Listener) consume() {
 		response, err := l.client.GetRecords(l.args())
 		if err != nil {
 			l.errors <- err
+
+			// Refresh the shard iterator
+			l.initShardIterator()
 		}
 
 		if response != nil {