This repository has been 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_report
to indefinitely blockproduce()
- Fixed a bug causing producers to drop
to_retry
messages onstop()
- Added retry logic to offset limit fetching