Hi Zike,

Did you run the latest example? I still see the exceptional info:

```
line 1243, in receive
    msg = self._consumer.receive()
_pulsar.Interrupted: Pulsar error: ResultInterrupted
```

However, with the latest example, the output should be the following
logs if you pressed the Ctrl+C:

```
^CStop receiving messages
```

Because the exception from `consumer.receive()`  is caught.

```python3
    try:
        msg = consumer.receive()
        # ...
    except pulsar.Interrupted:
        print("Stop receiving messages")
        break
```

Thanks,
Yunze

On Thu, Mar 9, 2023 at 3:02 PM Zike Yang <z...@apache.org> wrote:
>
> Hi Yunze
>
> The crash issue still exists in python 3.7. Here is the log
> ```
> ^CTraceback (most recent call last):
>   File 
> "/Users/aaronrobert/codebase/pulsar-client-python/examples/consumer.py",
> line 32, in <module>
>     msg = consumer.receive()
>   File 
> "/Users/aaronrobert/.pyenv/versions/3.7.16/lib/python3.7/site-packages/pulsar/__init__.py",
> line 1243, in receive
>     msg = self._consumer.receive()
> _pulsar.Interrupted: Pulsar error: ResultInterrupted
> 2023-03-09 12:18:14.326 WARN  [0x110900600] ConsumerImpl:126 |
> [persistent://public/default/my-topic, my-subscription, 0] Destroyed
> consumer which was not properly closed
> 2023-03-09 12:18:14.326 INFO  [0x110900600] ConsumerImpl:134 |
> [persistent://public/default/my-topic, my-subscription, 0] Closed
> consumer for race condition: 0
> libc++abi: terminating with uncaught exception of type
> std::__1::bad_weak_ptr: bad_weak_ptr
> [1]    52874 abort      python37
> ~/codebase/pulsar-client-python/examples/consumer.py
> ```
>
> This issue also exists in python 3.10.8. But it worked fine when I
> upgraded it to the latest version of python 3.10: 3.10.10.
> However, python 3.7.16, which is the latest version of python 3.7
> still not working.
>
> Not sure if it's a python issue, but only some python versions have
> fixed it. Could you take a look again?
>
> Thanks,
> Zike Yang
>
> On Wed, Mar 8, 2023 at 5:51 PM Yunze Xu <y...@streamnative.io.invalid> wrote:
> >
> > This is the 4th release candidate for Apache Pulsar Client Python,
> > version 3.1.0.
> >
> > It fixes the following issues:
> > https://github.com/apache/pulsar-client-python/milestone/2?closed=1
> >
> > *** Please download, test and vote on this release. This vote will
> > stay open for at least 72 hours ***
> >
> > Python wheels:
> > https://dist.apache.org/repos/dist/dev/pulsar/pulsar-client-python-3.1.0-candidate-4/
> >
> > The supported python versions are 3.7, 3.8, 3.9, 3.10 and 3.11. The
> > supported platforms and architectures are:
> > - Windows x86_64 (windows/)
> > - glibc-based Linux x86_64 (linux-glibc-x86_64/)
> > - glibc-based Linux arm64 (linux-glibc-arm64/)
> > - musl-based Linux x86_64 (linux-musl-x86_64/)
> > - musl-based Linux arm64 (linux-musl-arm64/)
> > - macOS universal 2 (macos/)
> >
> > You can download the wheel (the `.whl` file) according to your own OS
> > and Python version
> > and install the wheel:
> > - Windows: `py -m pip install *.whl --force-reinstall`
> > - Linux or macOS: `python3 -m pip install *.whl --force-reinstall`
> >
> > The tag to be voted upon: v3.1.0-candidate-4
> > (b883f42aa4287d46423b85f7af77f604cacf2a7e)
> > https://github.com/apache/pulsar-client-python/releases/tag/v3.1.0-candidate-4
> >
> > Pulsar's KEYS file containing PGP keys you use to sign the release:
> > https://downloads.apache.org/pulsar/KEYS
> >
> > Please download the Python wheels and follow the README to test.

Reply via email to