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