You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by GitBox <gi...@apache.org> on 2022/08/12 17:10:14 UTC
[GitHub] [pulsar-client-go] simonisacoder opened a new issue, #827: Error comment/behavior of default negative backoff policy
simonisacoder opened a new issue, #827:
URL: https://github.com/apache/pulsar-client-go/issues/827
#### Expected behavior
int the pulsar/negative_backoff_policy.go file, the Next function declare two variables
minNackTimeMs := int64(1000 * 30) and comment "30 sec"
maxNackTimeMs := 1000 * 60 * 10 and comment "10 min"
But the Next function which is called in pulsar/consumer_partition.go reconnectToBroker(or maybe other places),
and we can see that the return value of used in time.Sleep() which means its unit should be nanosecond(same as time.Duration).
So if we want a "30 sec" or "10 min", than we should declare below:
minNackTimeMs := int64(30 * 1000 * 1000 * 1000) // 30sec
maxNackTimeMs := int64(10 * 60 * 1000 * 1000 * 1000) // 10min
#### Actual behavior
Tell us what happens instead
#### Steps to reproduce
How can we reproduce the issue
#### System configuration
**Pulsar version**: x.y
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: commits-unsubscribe@pulsar.apache.org.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org