Close this vote by 3 binding +1s:
* Penghui
* Matteo
* Bo
and 1 non-binding +1:
* Zike
Thanks,
Yunze
On Mon, Mar 13, 2023 at 11:14 AM Zike Yang wrote:
>
> > It's not a regression. This error applies for Python client 3.0.0 as
> > well. Before 3.0.0, the Python client cannot be interrupted by a
> It's not a regression. This error applies for Python client 3.0.0 as
> well. Before 3.0.0, the Python client cannot be interrupted by a
> signal.I'd rather treat it as the case that the implementation of
> handling the UNIX signals is not so perfect.I'd rather treat it as the case
> that the imp
+1 (binding)
python version: 3.7.6
- Checked the signature
- Install the python .whl file
(pulsar_client-3.1.0-cp37-cp37m-macosx_10_15_universal2.whl) on macOS
12.3.1
- Start the standalone (2.11.0)
- Start consumer (python3 ./examples/consumer.py)
- Start producer (python3 ./examples/producer.py)
+1 (binding)
--
Matteo Merli
On Fri, Mar 10, 2023 at 7:44 AM Yunze Xu
wrote:
> Hi Zike,
>
> It's not a regression. This error applies for Python client 3.0.0 as
> well. Before 3.0.0, the Python client cannot be interrupted by a
> signal. I'd rather treat it as the case that the implementation
Hi Zike,
It's not a regression. This error applies for Python client 3.0.0 as
well. Before 3.0.0, the Python client cannot be interrupted by a
signal. I'd rather treat it as the case that the implementation of
handling the UNIX signals is not so perfect. Here is the issue:
https://github.com/apach
+1 (non-binding)
My environment:
* macOS x86_64
* python 3.7, 3.9, and 3.10
- Check sha512 checksum
- Check gpg signature
- Install the wheel
- Run the producer and consumer example
Thanks,
Zike Yang
On Fri, Mar 10, 2023 at 4:27 PM PengHui Li wrote:
>
> +1(binding)
>
> - Install the wheel on m
+1(binding)
- Install the wheel on macOS (python 3.9)
- Start a standalone
- Run the consumer and producer example
Thanks,
Penghui
On Fri, Mar 10, 2023 at 4:25 PM Zike Yang wrote:
> Hi, Yunze
>
> > However, with the latest example, the output should be the following
> > logs if you pressed the
Hi, Yunze
> However, with the latest example, the output should be the following
> logs if you pressed the Ctrl+C:
Thanks for your explanation. It works fine for me now.
> I think it should not be a blocker, we can open an issue for that. The
> official example uses a try-except block to avoid t
The reason is caused by the `client.close()` not being called. You
should make sure `client.close()` is called when receiving a SIGINT
signal.
```
#8 0x7f194f6aca99 in pulsar::ConsumerImpl::shutdown() [clone .cold] ()
from
/usr/local/lib/python3.7/site-packages/pulsar_client.libs/libpulsa
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:
`
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
msg = consumer.receive()
File
"/Users/aaronrobert/.pyenv/versions/3.7.16/lib/python3.7/s
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 wheel
12 matches
Mail list logo
