zbentley commented on issue #11823: URL: https://github.com/apache/pulsar/issues/11823#issuecomment-909262051
The contents of my `scratch.py` were the snippet in the description of the bug. When I run your code exactly as written, I get this output: ``` INFO:foo:Subscribing on Topic :sometopic INFO:foo:Created connection for pulsar://localhost:6650/ INFO:foo:[127.0.0.1:61188 -> 127.0.0.1:6650] Connected to broker INFO:foo:[persistent://public/default/sometopic, somesub, 0] Getting connection from pool INFO:foo:Created connection for pulsar://localhost:6650 INFO:foo:[127.0.0.1:61189 -> 127.0.0.1:6650] Connected to broker through proxy. Logical broker: pulsar://localhost:6650 INFO:foo:[persistent://public/default/sometopic, somesub, 0] Created consumer on broker [127.0.0.1:61189 -> 127.0.0.1:6650] INFO:foo:[persistent://public/default/sometopic, somesub, 0] Closing consumer for topic persistent://public/default/sometopic INFO:foo:[persistent://public/default/sometopic, somesub, 0] Closed consumer 0 async returning bar StopIteration: bar returned: None INFO:foo:Closing Pulsar client INFO:foo:[127.0.0.1:61189 -> 127.0.0.1:6650] Connection closed INFO:foo:[127.0.0.1:61188 -> 127.0.0.1:6650] Connection closed ``` ...after which the code hangs (per the other bug linked). I'm using python 3.9.6 installed via `brew`, in a clean virtual environment; the only commands I've issued other than venv creation are `pip install pulsar-client` and `pip install fastavro`. -- 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: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
