This repository has been archived by the owner on Mar 24, 2021. It is now read-only.
2.8.0-dev.1
Pre-release
Pre-release
emmettbutler
released this
14 Mar 18:01
·
278 commits
to master
since this release
Minor Version Features
- Added a
deserializer
kwarg to consumer components to facilitate unicode support - Added a
reset_offset_on_fetch
kwarg to consumer components to support read-only
consumption - Changed the expected type of the consumer's
consumer_group
kwarg tostr
frombytes
- Changed the expected type of
TopicDict.__getitem__
's parameter tostr
frombytes
- Added a
pending_timeout_ms
kwarg toProducer.__init__
to allow delivery report
wait timeouts - Added a
serializer
kwarg toProducer.__init__
to facilitate unicode support - Deprecated the
generation_id
andconsumer_id
parameters onSimpleConsumer
Bugfixes
- Changed consumers to handle valid ascii strings for consumer group names instead of
bytes - Handled
NoNodeException
during consumer ZK node releases - Used
api_versions
to select the version-appropriate implementation for
OffsetFetchRequest
- Adjusted synchronous production logic to avoid infinite blocking when delivery report
is lost - Fixed a bug in
FetchResponseV1
causingthrottle_time
to be returned as a tuple
instead of an integer - Implemented support for all current versions of
OffsetFetchRequest
and
OffsetFetchResponse
Miscellaneous
- Used logging.NullHandler to remove nuisance logs
- Added stock unicode serde to
utils
- Added README to pypi info