apache / apache/pulsar-client-go

Consumer can't receive messag after broker has been restarted

Open
#698 4 comments 0 reactions 0 assignees View on GitHub
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

Open the contributing guide

Assessment

This issue has not been assessed yet.

Get new issues in your inbox

A short digest of beginner-friendly GitHub issues.