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 {