omnilight opened a new issue #496:
URL: https://github.com/apache/pulsar-client-go/issues/496


   #### Expected behavior
   
   When we set `ConsumerOptions.MaxReconnectToBroker` to some value other than 
infinite, then when reconnection count reaches this value consumer should 
return with an error.
   
   #### Actual behavior
   
   Consumer just stuck, because 
[reconnectToBroker](https://github.com/apache/pulsar-client-go/blob/master/pulsar/consumer_partition.go#L861)
 just exists leaving consumer useless
   
   #### Steps to reproduce
   
   1. Set option to `ConsumerOptions.MaxReconnectToBroker = 2`
   2. Begin consuming messages
   3. Do something with broker (say, stop it)
   4. Messages would stop consuming
   5. Start broker
   6. Messages won't appear because consumer would not reconnect
   
   #### System configuration
   **Pulsar version**: 2.7
   


-- 
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.

For queries about this service, please contact Infrastructure at:
[email protected]


Reply via email to