This repository has been archived by the owner on Mar 24, 2021. It is now read-only.
2.7.0-dev.2
Pre-release
Pre-release
emmettbutler
released this
18 Dec 23:48
·
341 commits
to master
since this release
Minor Version Features
- Added a
membership_protocol
kwarg toBalancedConsumer
that allows switchable and
user-defined membership protocols to be used - Implemented
GroupMembershipProtocol
objects for the two standard partition assignment
strategies - Added an
api_versions
kwarg toBroker
to facilitate switchable API protocol versions - Added support for all versions of the
MetadataRequest
toBroker
- Added the
controller_broker
attribute toCluster
- Added
create_topics
anddelete_topics
toBroker
- Added
fetch_api_versions
toBroker
andCluster
- Added a CLI for creating and deleting topics on the cluster to
kafka_tools
- Added support for LZ4 compression to the
Producer
andSimpleConsumer
Bug Fixes
- Adjusted
Cluster
to become aware of supported API versions immediately upon
instantiation - Refactored code in
Cluster
related to metadata requests to make logic reusable for
pre-bootstrap communication with the cluster - Added the ability to pass arguments to
protocol.Response
instances when waiting
on a future - Adjusted the
RandomPartitioner
to avoid actually callingrandom.choice
to improve
performance - Removed some calls in
Producer.procuce
toisinstance
to improve performance - Simplified retry logic in
SimpleConsumer.fetch_offsets
Miscellaneous
- Used
sudo: required
to get around dead Travis machines - Upgraded Travis tests to use Kafka 1.0.0
- Added Code of Conduct
- Documented release process
- Made PyKafka available via conda-forge
- Fleshed out the beginning of the usage guide
- Made
kafka_instance
fetch its binary fromarchive.apache.org
instead of
mirror.reverse.net
because the latter removed old versions of Kafka