apache / apache/pulsar-client-go
Consumer can't receive messag after broker has been restarted
- Dominant language
- Go
- Stars
- 745
- Forks
- 389
- Avg merge
- 3d 20h
- Merged PRs (30d)
- 3
Description
#### 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
Contributor guide
Assessment
This issue has not been assessed yet.