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
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 forlinger_ms
during calls initiated
by_update()
- Fixed a race condition between
Producer._update
andOwnedBroker.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