Skip to content

Commit 2ea58e8

Browse files
committed
fix: prevent exponential backoff delay overflow
1 parent 2956d04 commit 2ea58e8

1 file changed

Lines changed: 3 additions & 3 deletions

File tree

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)