From c75a9237b68bfe6f7ca25e4cc131c90889e6c807 Mon Sep 17 00:00:00 2001
From: jonandrewj <jonandrewj@gmail.com>
Date: Thu, 25 Feb 2021 15:54:48 -0700
Subject: [PATCH] Add InternalFailureException to the list of retriable errors
 (#132)

* Add InternalFailureException to the list of retriable errors
---
 consumer.go | 1 +
 1 file changed, 1 insertion(+)

diff --git a/consumer.go b/consumer.go
index cd7e448..3f44ba1 100644
--- a/consumer.go
+++ b/consumer.go
@@ -234,6 +234,7 @@ func (c *Consumer) ScanShard(ctx context.Context, shardID string, fn ScanFunc) e
 var retriableErrors = map[string]struct{}{
 	kinesis.ErrCodeExpiredIteratorException:               struct{}{},
 	kinesis.ErrCodeProvisionedThroughputExceededException: struct{}{},
+	kinesis.ErrCodeInternalFailureException:               struct{}{},
 }
 
 func isShardClosed(nextShardIterator, currentShardIterator *string) bool {