Prevent exponential backoff delay from overflowing

vmihailenco · Oct 16, 2023 · 8f03fe4 · 8f03fe4
1 parent 2956d04
commit 8f03fe4
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/consumer.go b/consumer.go
@@ -941,11 +941,11 @@ func exponentialBackoff(min, max time.Duration, retry int) time.Duration {
 	if retry > 0 {
 		d = min << uint(retry-1)
 	}
+	if (retry > 0 && d <= 0) || d > max {
+		return max
+	}
 	if d < min {
 		return min
 	}
-	if d > max {
-		return max
-	}
 	return d
 }