Skip to content
This repository has been archived by the owner on Mar 24, 2021. It is now read-only.

2.8.0-dev.3

Pre-release
Pre-release
Compare
Choose a tag to compare
@emmettbutler emmettbutler released this 22 Aug 21:21
· 146 commits to master since this release
2.8.0-dev.3
8747398

Minor Version Features

  • Added the zookeeper_hosts kwarg to BalancedConsumer to standardize kwarg naming
  • Implemented versioning for ListOffsetRequest
  • Changed the behavior of integer arguments passed to reset_offsets

Bugfixes

  • Fixed the internal logic of reset_offsets to be more predictable and user-friendly,
    and to better handle the case where the topic has a single log segment
  • Standardized the handling of offsets_before arguments across the API
  • Added cluster update attempts to produce() retries

Miscellaneous

  • Added usage example on consuming the last N messages from a topic
  • Deprecated the zookeeper_connect kwarg on BalancedConsumer
  • Split the protocol.py file into multiple smaller files via the protocol module
  • Changed the lag monitor CLI to avoid resetting offsets
  • Added InvalidTopic to the list of supported exceptions
  • Updated requirement versions: lz4, pytest, xxhash
  • Removed hacky test-skipping logic from test suite
Assets 2
Loading