This repository was archived by the owner on Mar 24, 2021. It is now read-only.
2.2.1
Bug Fixes
- Fixed Travis issues related to PyPy testing
- Fixed deprecated dependency on gevent.coros
- Enabled caching in Travis for pip, librdkafka, and kafka installations
- Fixed a crash during metadata updating related to zookeeper fallback
- Unified connection retry logic in
Cluster - Raised an exception if consumer offset reset fails after maximum retries
- Fixed a bug allowing
get_delivery_reportto indefinitely blockproduce() - Fixed a bug causing producers to drop
to_retrymessages onstop() - Added retry logic to offset limit fetching