You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
Actually, the IsMaxBackoffReached is incorrect. We should respect the operation timeout and check the whole retired time instead of the backoff delay time.
From the view of API design, we should move the BackoffPolicy out of the internal package.
The text was updated successfully, but these errors were encountered:
I found that there are some issues with the BackoffPolicy:
pulsar-client-go/pulsar/consumer_partition.go
Line 1656 in 35ae051
IsMaxBackoffReached
doesn't respect the pc.options.backoffPolicy.pulsar-client-go/pulsar/consumer_partition.go
Line 1700 in 35ae051
Actually, the
IsMaxBackoffReached
is incorrect. We should respect the operation timeout and check the whole retired time instead of the backoff delay time.internal
package.The text was updated successfully, but these errors were encountered: