[GitHub] [pulsar-client-go] cameronbroe opened a new issue #519: Connection health checks

[GitBox <gi...@apache.org>]

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


   **Is your feature request related to a problem? Please describe.**
   As an application, I am unable to determine the current state of health of the Pulsar client. If my connection dies, my application ends up in a hanging state with infinite retries. Setting a maximum number of retries through the currently provided interface just causes a hanging state, with no notification that my application can respond to handle the error.
   
   **Describe the solution you'd like**
   The Client should have an `ErrorChannel` that my application is able to consume messages from with information about where an error has happened, such as a connection being killed and retries failing. This will allow applications to detect when Pulsar is an unhealthy state and respond appropriately. The errors should identify whether it is a consumer or producer that failed as well, so applications can handle them different.
   
   **Describe alternatives you've considered**
   For a Consumer specifically, I tried to patch so the ConsumerMessage channel is closed after a maximum number of retries have failed, but it seems there are still retries from the client end as well.
   


-- 
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:
users@infra.apache.org

[GitHub] [pulsar-client-go] omnilight commented on issue #519: Connection health checks

[GitBox <gi...@apache.org>]

omnilight commented on issue #519:
URL: https://github.com/apache/pulsar-client-go/issues/519#issuecomment-854919638


   #496 is for consumer


-- 
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:
users@infra.apache.org