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)

Most upvoted comments

Ok, this is not the idle thing… The connections_max_idle_ms config 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