This repository was archived by the owner on Mar 24, 2021. It is now read-only.
2.8.0-dev.1
Pre-release
Pre-release
·
278 commits
to master
since this release
Minor Version Features
- Added a
deserializerkwarg to consumer components to facilitate unicode support - Added a
reset_offset_on_fetchkwarg to consumer components to support read-only
consumption - Changed the expected type of the consumer's
consumer_groupkwarg tostrfrombytes - Changed the expected type of
TopicDict.__getitem__'s parameter tostrfrombytes - Added a
pending_timeout_mskwarg toProducer.__init__to allow delivery report
wait timeouts - Added a
serializerkwarg toProducer.__init__to facilitate unicode support - Deprecated the
generation_idandconsumer_idparameters onSimpleConsumer
Bugfixes
- Changed consumers to handle valid ascii strings for consumer group names instead of
bytes - Handled
NoNodeExceptionduring consumer ZK node releases - Used
api_versionsto select the version-appropriate implementation for
OffsetFetchRequest - Adjusted synchronous production logic to avoid infinite blocking when delivery report
is lost - Fixed a bug in
FetchResponseV1causingthrottle_timeto be returned as a tuple
instead of an integer - Implemented support for all current versions of
OffsetFetchRequestand
OffsetFetchResponse
Miscellaneous
- Used logging.NullHandler to remove nuisance logs
- Added stock unicode serde to
utils - Added README to pypi info