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

2.5.0.dev1

Pre-release
Pre-release
Compare
Choose a tag to compare
@emmettbutler emmettbutler released this 23 Aug 19:02
· 679 commits to master since this release

You can install this release via pip with pip install --pre pykafka==2.5.0.dev1.
It will not automatically install because it's a pre-release.

Minor version Features

  • Added the broker_version kwarg to several components. It's currently only
    used by the librdkafka features. The kwarg is used to facilitate the use of
    librdkafka via pykafka against multiple Kafka broker versions.
  • Changed offset commit requests to include useful information in the offset
    metadata field, including consumer ID and hostname
  • Added the GroupHashingPartitioner

Bug Fixes

  • Fixed the operation of consumer_timeout_ms, which had been broken for
    BalancedConsumer groups
  • Fixed a bug causing Producer.__del__ to crash during finalization
  • Made the consumer's fetch loop nonbusy when the internal queues are full to
    save CPU cycles when message volume is high
  • Fixed a bug causing Producer.flush() to wait for linger_ms during calls initiated
    by _update()
  • Fixed a race condition between Producer._update and OwnedBroker.flush causing
    infinite retry loops
  • Changed Producer.produce to block while the internal broker list is being updated.
    This avoids possible mismatches between old and new cluster metadata used by the
    Producer.

Miscellaneous

  • Upgraded the version of PyPy used in automated tests
  • Upgraded the version of librdkafka used in automated tests
  • Pinned the version of the testinstances library on which the tests depend