Skip to content

Commit fdf44a4

Browse files
committed
fix: prevent backoff delay overflow
1 parent 2956d04 commit fdf44a4

File tree

1 file changed

+3
-3
lines changed

1 file changed

+3
-3
lines changed

consumer.go

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -941,11 +941,11 @@ func exponentialBackoff(min, max time.Duration, retry int) time.Duration {
941941
if retry > 0 {
942942
d = min << uint(retry-1)
943943
}
944+
if (retry > 0 && d <= 0) || d > max {
945+
return max
946+
}
944947
if d < min {
945948
return min
946949
}
947-
if d > max {
948-
return max
949-
}
950950
return d
951951
}

0 commit comments

Comments
 (0)