aiokafka: Consumers start hanging with AIOKafkaConnection._read() Cancelled Error
The consumers start hanging at some point with the following error being logged:
[2017-11-07 18:17:47,547: ERROR] Task exception was never retrieved
future: <Task finished coro=<AIOKafkaConnection._read() done, defined at /home/foo/env/lib/python3.6/site-packages/aiokafka/conn.py:194> exception=CancelledError()>
What might be causing the error? Should we be crashing the consumer upon getting the error?
This is with aiokafka==0.3.1
About this issue
- Original URL
- State: open
- Created 7 years ago
- Reactions: 2
- Comments: 16 (10 by maintainers)
Ok, this is not the
idlething… Theconnections_max_idle_msconfig did not work at all =)Ohh, this is probably a fail on idle connection closure. The connection is closed if not active for some time, probably this log is a side effect there. Will investigate, thank