aio-libs / aiokafka

asyncio client for kafka
http://aiokafka.readthedocs.io/
Apache License 2.0
1.08k stars 224 forks source link

Added delay to retry connection #1014

Open camcima opened 2 weeks ago

camcima commented 2 weeks ago

When a consumer connection breaks, aiokafka goes into a loop trying to reconnect every 1ms, generating a mountain of logs. This PR introduces a delay between connection attempts with the configured retry_backoff_ms parameter.

Addresses issues #496 and #830.