[GitHub] [pulsar-client-go] hrsakai opened a new pull request, #785: Fix using closed connection in consumer

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

hrsakai opened a new pull request, #785:
URL: https://github.com/apache/pulsar-client-go/pull/785

   ### Motivation
   Related to https://github.com/apache/pulsar-client-go/pull/761
   
   This PR fixed the issue using closed connection at consumer side.
   
   If same issue as https://github.com/apache/pulsar-client-go/pull/761 happens at consumer side, consumer will report the following errors and can't consume any messages.
   ```
   ERRO[0180] [Connection was closed when request flow cmd]  consumerID=1 name=wzrtq subscription=sub1 topic="persistent://public/default/topic-go-1"
   ERRO[0180] [unable to send initial permits to broker]    consumerID=1 error="connection closed" name=wzrtq subscription=sub1 topic="persistent://public/default/topic-go-1"
   ```
   
   ### Modifications
   * return an error when unable to add consumer to handler.
   
   


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

For queries about this service, please contact Infrastructure at:
users@infra.apache.org

[GitHub] [pulsar-client-go] merlimat merged pull request #785: Fix using closed connection in consumer

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

merlimat merged PR #785:
URL: https://github.com/apache/pulsar-client-go/pull/785


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

For queries about this service, please contact Infrastructure at:
users@infra.apache.org