Denis Otkidach
Denis Otkidach
Freezegun still hangs multiprocessing (Python 3.7.0). The problem is in the following chain: `Popen.poll(WNOHANG)` -> `multiprocessing.connection.wait(…, timeout=0)`. And in `wait()` there is a loop: ``` if timeout is not None:...
> Can you supply a minimal test case? Sure. But my case is not related to django. The following code hangs when executed as is, but works fine without `with...
Have you tried with code from master branch? It should have been fixed in https://github.com/aio-libs/aiokafka/pull/801
> I've been able to make it happen on Python 3.8.10 and 3.9.6 but it does not occur for Python 3.8.5. This behaviour suggests that it could be related to...
It's possible to monkey-patch `wait_for` with the implementation prior to this bug, which [had another bug](https://bugs.python.org/issue37658). But that means you just have to choose from these two bugs which one...
> Do you have suggestions on the types of tests you'd like to see here. We need to proof, that this new functionality works. There must be some code with...
Would such handling of exception actually fix the problem? You won't receive an exception when new topic is created.
Do you need just to silence those warnings? It can be achieved by adding filter to corresponding logger.
Do you commit offsets manually? If so, the new subscription starts from the last committed offset for each topic, so nothing is lost even if you resubscribe after delay.
Automatic committing in aiokafka itself can cause message loss. See #826 for more info.