ISSUE-698: Consumer can't receive messag after broker has been restarted

[sijie]

Original Issue: apache#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: 2.7.3
Pulsar Go Client version: 0.6.1

[xige-16]

Anyone can help?