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
commented
2 years ago
Original Issue: apache/pulsar-client-go#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.
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