This repository was archived by the owner on Mar 24, 2021. It is now read-only.
2.1.0
Features
- Addded an optional C extension making use of librdkafka for enhanced producer and
consumer performance - Added a delivery report queue to the
Producerallowing per-message errors
to be handled - Added a callback indicating that the
BalancedConsumeris in the process of rebalancing
Bug Fixes
- Fixed a longstanding issue causing certain tests to hang on Travis
- Fixed a bug causing the default error handles in the consumer to mask unknown error
codes - Moved the
Messageclass to using__slots__to minimize its memory footprint