wolfstudy commented on issue #144: For a pulsar.Client instance, Once 
Client.Subscribe() times out, all subsequent Client.Subscribe() fail
URL: 
https://github.com/apache/pulsar-client-go/issues/144#issuecomment-569258146
 
 
   @dsmlily Thanks work for this, I tried using the reproduce you provided, but 
everything is ok, the output as follows:
   
   ```
   to creat room consumer SubscriptionName:sub-name-0 .....
   time="2019-12-27T20:12:16+08:00" level=info msg="Connecting to broker" 
remote_addr="pulsar://127.0.0.1:6650"
   time="2019-12-27T20:12:16+08:00" level=info msg="TCP connection established" 
local_addr="127.0.0.1:63012" remote_addr="pulsar://127.0.0.1:6650"
   time="2019-12-27T20:12:16+08:00" level=info msg="Connection is ready" 
local_addr="127.0.0.1:63012" remote_addr="pulsar://127.0.0.1:6650"
   time="2019-12-27T20:12:16+08:00" level=info msg="Connected consumer" 
name=pbmat subscription=sub-name-0 topic="persistent://public/default/0"
   time="2019-12-27T20:12:16+08:00" level=info msg="Created consumer" 
name=pbmat subscription=sub-name-0 topic="persistent://public/default/0"
   creat room consumer done, SubscriptionName:sub-name-0  ***creat done
   wait group -- 0 done
   to close room sub-name-0.....
   time="2019-12-27T20:12:17+08:00" level=info msg="Closing consumer=1" 
name=pbmat subscription=sub-name-0 topic="persistent://public/default/0"
   time="2019-12-27T20:12:17+08:00" level=warning msg="Failed to close 
consumer" error="server error: MetadataError: Consumer not found" name=pbmat 
subscription=sub-name-0 topic="persistent://public/default/0"
   time="2019-12-27T20:12:17+08:00" level=info msg="exiting events loop" 
name=pbmat subscription=sub-name-0 topic="persistent://public/default/0"
   to close room [sub-name-0 close done***]
   time="2019-12-27T20:12:17+08:00" level=info msg="exiting dispatch loop" 
name=pbmat subscription=sub-name-0 topic="persistent://public/default/0"
   to creat room consumer SubscriptionName:sub-name-1 .....
   time="2019-12-27T20:12:19+08:00" level=info msg="Connected consumer" 
name=iuque subscription=sub-name-1 topic="persistent://public/default/1"
   time="2019-12-27T20:12:19+08:00" level=info msg="Created consumer" 
name=iuque subscription=sub-name-1 topic="persistent://public/default/1"
   creat room consumer done, SubscriptionName:sub-name-1  ***creat done
   to close room sub-name-1.....
   wait group -- 1 done
   time="2019-12-27T20:12:20+08:00" level=info msg="Closing consumer=2" 
name=iuque subscription=sub-name-1 topic="persistent://public/default/1"
   to close room [sub-name-1 close done***]
   time="2019-12-27T20:12:20+08:00" level=warning msg="Failed to close 
consumer" error="server error: MetadataError: Consumer not found" name=iuque 
subscription=sub-name-1 topic="persistent://public/default/1"
   time="2019-12-27T20:12:20+08:00" level=info msg="exiting events loop" 
name=iuque subscription=sub-name-1 topic="persistent://public/default/1"
   time="2019-12-27T20:12:20+08:00" level=info msg="exiting dispatch loop" 
name=iuque subscription=sub-name-1 topic="persistent://public/default/1"
   to creat room consumer SubscriptionName:sub-name-2 .....
   time="2019-12-27T20:12:22+08:00" level=info msg="Connected consumer" 
name=vloqq subscription=sub-name-2 topic="persistent://public/default/2"
   time="2019-12-27T20:12:22+08:00" level=info msg="Created consumer" 
name=vloqq subscription=sub-name-2 topic="persistent://public/default/2"
   creat room consumer done, SubscriptionName:sub-name-2  ***creat done
   wait group -- 2 done
   to close room sub-name-2.....
   time="2019-12-27T20:12:23+08:00" level=info msg="Closing consumer=3" 
name=vloqq subscription=sub-name-2 topic="persistent://public/default/2"
   time="2019-12-27T20:12:23+08:00" level=warning msg="Failed to close 
consumer" error="server error: MetadataError: Consumer not found" name=vloqq 
subscription=sub-name-2 topic="persistent://public/default/2"
   time="2019-12-27T20:12:23+08:00" level=info msg="exiting events loop" 
name=vloqq subscription=sub-name-2 topic="persistent://public/default/2"
   to close room [sub-name-2 close done***]
   time="2019-12-27T20:12:23+08:00" level=info msg="exiting dispatch loop" 
name=vloqq subscription=sub-name-2 topic="persistent://public/default/2"
   to creat room consumer SubscriptionName:sub-name-3 .....
   time="2019-12-27T20:12:25+08:00" level=info msg="Connected consumer" 
name=bizzv subscription=sub-name-3 topic="persistent://public/default/3"
   time="2019-12-27T20:12:25+08:00" level=info msg="Created consumer" 
name=bizzv subscription=sub-name-3 topic="persistent://public/default/3"
   creat room consumer done, SubscriptionName:sub-name-3  ***creat done
   wait group -- 3 done
   to close room sub-name-3.....
   time="2019-12-27T20:12:26+08:00" level=info msg="Closing consumer=4" 
name=bizzv subscription=sub-name-3 topic="persistent://public/default/3"
   time="2019-12-27T20:12:26+08:00" level=warning msg="Failed to close 
consumer" error="server error: MetadataError: Consumer not found" name=bizzv 
subscription=sub-name-3 topic="persistent://public/default/3"
   time="2019-12-27T20:12:26+08:00" level=info msg="exiting events loop" 
name=bizzv subscription=sub-name-3 topic="persistent://public/default/3"
   time="2019-12-27T20:12:26+08:00" level=info msg="exiting dispatch loop" 
name=bizzv subscription=sub-name-3 topic="persistent://public/default/3"
   to close room [sub-name-3 close done***]
   to creat room consumer SubscriptionName:sub-name-4 .....
   time="2019-12-27T20:12:28+08:00" level=info msg="Connected consumer" 
name=afrvi subscription=sub-name-4 topic="persistent://public/default/4"
   creat room consumer done, SubscriptionName:sub-name-4  ***creat done
   time="2019-12-27T20:12:28+08:00" level=info msg="Created consumer" 
name=afrvi subscription=sub-name-4 topic="persistent://public/default/4"
   wait group -- 4 done
   to close room sub-name-4.....
   time="2019-12-27T20:12:29+08:00" level=info msg="Closing consumer=5" 
name=afrvi subscription=sub-name-4 topic="persistent://public/default/4"
   time="2019-12-27T20:12:29+08:00" level=warning msg="Failed to close 
consumer" error="server error: MetadataError: Consumer not found" name=afrvi 
subscription=sub-name-4 topic="persistent://public/default/4"
   to close room [sub-name-4 close done***]
   time="2019-12-27T20:12:29+08:00" level=info msg="exiting events loop" 
name=afrvi subscription=sub-name-4 topic="persistent://public/default/4"
   time="2019-12-27T20:12:29+08:00" level=info msg="exiting dispatch loop" 
name=afrvi subscription=sub-name-4 topic="persistent://public/default/4"
   to creat room consumer SubscriptionName:sub-name-5 .....
   creat room consumer done, SubscriptionName:sub-name-5  ***creat done
   time="2019-12-27T20:12:31+08:00" level=info msg="Connected consumer" 
name=gjcig subscription=sub-name-5 topic="persistent://public/default/5"
   time="2019-12-27T20:12:31+08:00" level=info msg="Created consumer" 
name=gjcig subscription=sub-name-5 topic="persistent://public/default/5"
   wait group -- 5 done
   to close room sub-name-5.....
   time="2019-12-27T20:12:32+08:00" level=info msg="Closing consumer=6" 
name=gjcig subscription=sub-name-5 topic="persistent://public/default/5"
   to close room [sub-name-5 close done***]
   time="2019-12-27T20:12:32+08:00" level=warning msg="Failed to close 
consumer" error="server error: MetadataError: Consumer not found" name=gjcig 
subscription=sub-name-5 topic="persistent://public/default/5"
   time="2019-12-27T20:12:32+08:00" level=info msg="exiting events loop" 
name=gjcig subscription=sub-name-5 topic="persistent://public/default/5"
   time="2019-12-27T20:12:32+08:00" level=info msg="exiting dispatch loop" 
name=gjcig subscription=sub-name-5 topic="persistent://public/default/5"
   to creat room consumer SubscriptionName:sub-name-6 .....
   time="2019-12-27T20:12:34+08:00" level=info msg="Connected consumer" 
name=dqljx subscription=sub-name-6 topic="persistent://public/default/6"
   creat room consumer done, SubscriptionName:sub-name-6  ***creat done
   time="2019-12-27T20:12:34+08:00" level=info msg="Created consumer" 
name=dqljx subscription=sub-name-6 topic="persistent://public/default/6"
   wait group -- 6 done
   to close room sub-name-6.....
   time="2019-12-27T20:12:35+08:00" level=info msg="Closing consumer=7" 
name=dqljx subscription=sub-name-6 topic="persistent://public/default/6"
   time="2019-12-27T20:12:35+08:00" level=warning msg="Failed to close 
consumer" error="server error: MetadataError: Consumer not found" name=dqljx 
subscription=sub-name-6 topic="persistent://public/default/6"
   time="2019-12-27T20:12:35+08:00" level=info msg="exiting events loop" 
name=dqljx subscription=sub-name-6 topic="persistent://public/default/6"
   time="2019-12-27T20:12:35+08:00" level=info msg="exiting dispatch loop" 
name=dqljx subscription=sub-name-6 topic="persistent://public/default/6"
   to close room [sub-name-6 close done***]
   to creat room consumer SubscriptionName:sub-name-7 .....
   time="2019-12-27T20:12:37+08:00" level=info msg="Connected consumer" 
name=azdpt subscription=sub-name-7 topic="persistent://public/default/7"
   time="2019-12-27T20:12:37+08:00" level=info msg="Created consumer" 
name=azdpt subscription=sub-name-7 topic="persistent://public/default/7"
   creat room consumer done, SubscriptionName:sub-name-7  ***creat done
   wait group -- 7 done
   to close room sub-name-7.....
   time="2019-12-27T20:12:38+08:00" level=info msg="Closing consumer=8" 
name=azdpt subscription=sub-name-7 topic="persistent://public/default/7"
   time="2019-12-27T20:12:38+08:00" level=warning msg="Failed to close 
consumer" error="server error: MetadataError: Consumer not found" name=azdpt 
subscription=sub-name-7 topic="persistent://public/default/7"
   time="2019-12-27T20:12:38+08:00" level=info msg="exiting events loop" 
name=azdpt subscription=sub-name-7 topic="persistent://public/default/7"
   to close room [sub-name-7 close done***]
   time="2019-12-27T20:12:38+08:00" level=info msg="exiting dispatch loop" 
name=azdpt subscription=sub-name-7 topic="persistent://public/default/7"
   to creat room consumer SubscriptionName:sub-name-8 .....
   time="2019-12-27T20:12:40+08:00" level=info msg="Connected consumer" 
name=eyzgv subscription=sub-name-8 topic="persistent://public/default/8"
   time="2019-12-27T20:12:40+08:00" level=info msg="Created consumer" 
name=eyzgv subscription=sub-name-8 topic="persistent://public/default/8"
   creat room consumer done, SubscriptionName:sub-name-8  ***creat done
   wait group -- 8 done
   to close room sub-name-8.....
   time="2019-12-27T20:12:41+08:00" level=info msg="Closing consumer=9" 
name=eyzgv subscription=sub-name-8 topic="persistent://public/default/8"
   time="2019-12-27T20:12:41+08:00" level=warning msg="Failed to close 
consumer" error="server error: MetadataError: Consumer not found" name=eyzgv 
subscription=sub-name-8 topic="persistent://public/default/8"
   time="2019-12-27T20:12:41+08:00" level=info msg="exiting events loop" 
name=eyzgv subscription=sub-name-8 topic="persistent://public/default/8"
   to close room [sub-name-8 close done***]
   time="2019-12-27T20:12:41+08:00" level=info msg="exiting dispatch loop" 
name=eyzgv subscription=sub-name-8 topic="persistent://public/default/8"
   to creat room consumer SubscriptionName:sub-name-9 .....
   time="2019-12-27T20:12:43+08:00" level=info msg="Connected consumer" 
name=dbysg subscription=sub-name-9 topic="persistent://public/default/9"
   creat room consumer done, SubscriptionName:sub-name-9  ***creat done
   time="2019-12-27T20:12:43+08:00" level=info msg="Created consumer" 
name=dbysg subscription=sub-name-9 topic="persistent://public/default/9"
   wait group -- 9 done
   to close room sub-name-9.....
   time="2019-12-27T20:12:44+08:00" level=info msg="Closing consumer=10" 
name=dbysg subscription=sub-name-9 topic="persistent://public/default/9"
   time="2019-12-27T20:12:44+08:00" level=info msg="Closed consumer" name=dbysg 
subscription=sub-name-9 topic="persistent://public/default/9"
   time="2019-12-27T20:12:44+08:00" level=info msg="exiting events loop" 
name=dbysg subscription=sub-name-9 topic="persistent://public/default/9"
   ```

----------------------------------------------------------------
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.
 
For queries about this service, please contact Infrastructure at:
[email protected]


With regards,
Apache Git Services

Reply via email to