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: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
