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
Producer
allowing per-message errors
to be handled - Added a callback indicating that the
BalancedConsumer
is 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
Message
class to using__slots__
to minimize its memory footprint