Retry infinitely on expired shard iterator error

snowplow-devops · Nov 6, 2024 · c4b233c · c4b233c
1 parent 9b8b911
commit c4b233c
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/shard_consumer.go b/shard_consumer.go
@@ -214,8 +214,9 @@ mainloop:
 						return
 					}
 					iterator = newIterator
-					// should retry after expired iterator is renewed successfully
-					shouldRetry = true
+
+					// retry infinitely after expired iterator is renewed successfully
+					continue mainloop
 				}
 
 				if shouldRetry && retryCount < maxErrorRetries {