xige-16 opened a new issue #698: URL: https://github.com/apache/pulsar-client-go/issues/698
#### Expected behavior creating a consumer firstly, then restart pulsar broker, consumer will reconnect the broker. After successful reconnection, Consumers should receive message normally. #### Actual behavior After successful reconnection, Consumers can't receive message. ``` time="2021-12-29T18:44:13Z" level=info msg="[Reconnecting to broker in 113.697858ms]" consumerID=2 name=ffjdx subscription=by-dev-queryNode-7-430126759589907777-1475776075845522132 topic="persistent://public/default/by-dev-rootcoord-dml_0" time="2021-12-29T18:44:13Z" level=warning msg="Closed connection unable add consumer with id=7" local_addr="10.244.0.16:59042" remote_addr="pulsar://test-pulsar-pod-kill-proxy:6650" time="2021-12-29T18:44:13Z" level=info msg="[Reconnected consumer to broker]" consumerID=7 name=tcsfj subscription=by-dev-queryNode-7-430126759589907777-7790512995060514136 topic="persistent://public/default/by-dev-search-0" time="2021-12-29T18:44:13Z" level=info msg="[Connected consumer]" consumerID=21 name=beiyo subscription=by-dev-queryNode-7-430126770285182977-7074430709130291840 topic="persistent://public/default/by-dev-search-0" ``` Is there a problem with this warning message (Closed connection unable add consumer)？ #### 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]
