You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by GitBox <gi...@apache.org> on 2021/12/02 08:58:47 UTC
[GitHub] [pulsar] xiaofan-luan opened a new issue #13084: Go client keep receive close from broker
xiaofan-luan opened a new issue #13084:
URL: https://github.com/apache/pulsar/issues/13084
**Describe the bug**
We've seen that go client keep receive closed info from broker, the log as following, is that correct behaviour?
time="2021-12-02T01:21:39Z" level=info msg="[Reconnected consumer to broker]" consumerID=8 name=dhnik subscription=by-dev-queryNode-13-429498844746874881-6545233210522002565 topic="persistent://public/default/by-dev-rootcoord-dml_5"
time="2021-12-02T01:21:39Z" level=info msg="[Connected consumer]" consumerID=9 name=cqkwv subscription=by-dev-queryNode-13-429498844746874881-4863815511074142649 topic="persistent://public/default/by-dev-search-0"
time="2021-12-02T01:21:39Z" level=info msg="[Created consumer]" consumerID=9 name=cqkwv subscription=by-dev-queryNode-13-429498844746874881-4863815511074142649 topic="persistent://public/default/by-dev-search-0"
time="2021-12-02T01:21:39Z" level=info msg="[Created producer]" cnx="10.26.55.44:41262 -> 10.27.241.73:6650" producerID=10 producer_name=milvus-pulsar-23-2723 topic="persistent://public/default/by-dev-searchResult-0"
time="2021-12-02T01:21:39Z" level=info msg="Broker notification of Closed consumer: 9" local_addr="10.26.55.44:41262" remote_addr="pulsar://milvus-pulsar-proxy:6650"
time="2021-12-02T01:21:39Z" level=info msg="[Reconnecting to broker in 105.683492ms]" consumerID=9 name=cqkwv subscription=by-dev-queryNode-13-429498844746874881-4863815511074142649 topic="persistent://public/default/by-dev-search-0"
time="2021-12-02T01:21:39Z" level=info msg="[Connected consumer]" consumerID=9 name=cqkwv subscription=by-dev-queryNode-13-429498844746874881-4863815511074142649 topic="persistent://public/default/by-dev-search-0"
time="2021-12-02T01:21:39Z" level=info msg="[Reconnected consumer to broker]" consumerID=9 name=cqkwv subscription=by-dev-queryNode-13-429498844746874881-4863815511074142649 topic="persistent://public/default/by-dev-search-0"
time="2021-12-02T02:15:58Z" level=info msg="[Created producer]" cnx="10.26.55.44:41262 -> 10.27.241.73:6650" producerID=11 producer_name=milvus-pulsar-23-2951 topic="persistent://public/default/query-node-time-tick-0"
time="2021-12-02T02:15:58Z" level=info msg="[Connected consumer]" consumerID=10 name=rxkxg subscription=by-dev-queryNode-13-429499676778823681-4290867280910344190 topic="persistent://public/default/by-dev-rootcoord-dml_7"
time="2021-12-02T02:15:58Z" level=info msg="[Created consumer]" consumerID=10 name=rxkxg subscription=by-dev-queryNode-13-429499676778823681-4290867280910344190 topic="persistent://public/default/by-dev-rootcoord-dml_7"
time="2021-12-02T02:15:58Z" level=info msg="Broker notification of Closed consumer: 10" local_addr="10.26.55.44:41262" remote_addr="pulsar://milvus-pulsar-proxy:6650"
time="2021-12-02T02:15:58Z" level=info msg="[Reconnecting to broker in 106.244662ms]" consumerID=10 name=rxkxg subscription=by-dev-queryNode-13-429499676778823681-4290867280910344190 topic="persistent://public/default/by-dev-rootcoord-dml_7"
time="2021-12-02T02:15:58Z" level=info msg="[Connected consumer]" consumerID=10 name=rxkxg subscription=by-dev-queryNode-13-429499676778823681-4290867280910344190 topic="persistent://public/default/by-dev-rootcoord-dml_7"
time="2021-12-02T02:15:58Z" level=info msg="[Reconnected consumer to broker]" consumerID=10 name=rxkxg subscription=by-dev-queryNode-13-429499676778823681-4290867280910344190 topic="persistent://public/default/by-dev-rootcoord-dml_7"
time="2021-12-02T02:15:58Z" level=info msg="[Created producer]" cnx="10.26.55.44:41262 -> 10.27.241.73:6650" producerID=12 producer_name=milvus-pulsar-23-2952 topic="persistent://public/default/query-node-time-tick-0"
time="2021-12-02T02:15:58Z" level=info msg="[Connected consumer]" consumerID=11 name=pdqni subscription=by-dev-queryNode-13-429499676778823681-5511517715403210568 topic="persistent://public/default/by-dev-rootcoord-dml_6"
time="2021-12-02T02:15:58Z" level=info msg="[Created consumer]" consumerID=11 name=pdqni subscription=by-dev-queryNode-13-429499676778823681-5511517715403210568 topic="persistent://public/default/by-dev-rootcoord-dml_6"
time="2021-12-02T02:15:58Z" level=info msg="Broker notification of Closed consumer: 11" local_addr="10.26.55.44:41262" remote_addr="pulsar://milvus-pulsar-proxy:6650"
time="2021-12-02T02:15:58Z" level=info msg="[Reconnecting to broker in 117.945466ms]" consumerID=11 name=pdqni subscription=by-dev-queryNode-13-429499676778823681-5511517715403210568 topic="persistent://public/default/by-dev-rootcoord-dml_6"
time="2021-12-02T02:15:59Z" level=info msg="[Connected consumer]" consumerID=11 name=pdqni subscription=by-dev-queryNode-13-429499676778823681-5511517715403210568 topic="persistent://public/default/by-dev-rootcoord-dml_6"
time="2021-12-02T02:15:59Z" level=info msg="[Reconnected consumer to broker]" consumerID=11 name=pdqni subscription=by-dev-queryNode-13-429499676778823681-5511517715403210568 topic="persistent://public/default/by-dev-rootcoord-dml_6"
time="2021-12-02T02:15:59Z" level=info msg="[Connected consumer]" consumerID=12 name=glqvr subscription=by-dev-queryNode-13-429499676778823681-169579361635081028 topic="persistent://public/default/by-dev-search-0"
time="2021-12-02T02:15:59Z" level=info msg="[Created consumer]" consumerID=12 name=glqvr subscription=by-dev-queryNode-13-429499676778823681-169579361635081028 topic="persistent://public/default/by-dev-search-0"
**To Reproduce**
Steps to reproduce the behavior:
1. Go to '...'
2. Click on '....'
3. Scroll down to '....'
4. See error
**Expected behavior**
just wondering if that is the correct behavior, because we've seen the backlog is keep increasing
**Screenshots**
If applicable, add screenshots to help explain your problem.
**Desktop (please complete the following information):**
- OS: [e.g. iOS]
**Additional context**
broker log is list below
--
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: commits-unsubscribe@pulsar.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [pulsar] github-actions[bot] commented on issue #13084: Go client keep receive close from broker
Posted by GitBox <gi...@apache.org>.
github-actions[bot] commented on issue #13084:
URL: https://github.com/apache/pulsar/issues/13084#issuecomment-1051440394
The issue had no activity for 30 days, mark with Stale label.
--
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: commits-unsubscribe@pulsar.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [pulsar] xiaofan-luan commented on issue #13084: Go client keep receive close from broker
Posted by GitBox <gi...@apache.org>.
xiaofan-luan commented on issue #13084:
URL: https://github.com/apache/pulsar/issues/13084#issuecomment-984423758
[milvus-pulsar-broker-58bc5db7cc-ws225.log.zip](https://github.com/apache/pulsar/files/7640518/milvus-pulsar-broker-58bc5db7cc-ws225.log.zip)
--
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: commits-unsubscribe@pulsar.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [pulsar] hangc0276 commented on issue #13084: Go client keep receive close from broker
Posted by GitBox <gi...@apache.org>.
hangc0276 commented on issue #13084:
URL: https://github.com/apache/pulsar/issues/13084#issuecomment-984732895
It looks like the consumer doing reconnecting to the broker. Does this logs keep appear?
--
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: commits-unsubscribe@pulsar.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org