Skip to content
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
Compare
Choose a tag to compare
@emmettbutler 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 to str from bytes
  • Changed the expected type of TopicDict.__getitem__'s parameter to str from bytes
  • Added a pending_timeout_ms kwarg to Producer.__init__ to allow delivery report
    wait timeouts
  • Added a serializer kwarg to Producer.__init__ to facilitate unicode support
  • Deprecated the generation_id and consumer_id parameters on SimpleConsumer

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 causing throttle_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