This repository was archived by the owner on Mar 24, 2021. It is now read-only.
2.7.0-dev.2
Pre-release
Pre-release
·
341 commits
to master
since this release
Minor Version Features
- Added a
membership_protocolkwarg toBalancedConsumerthat allows switchable and
user-defined membership protocols to be used - Implemented
GroupMembershipProtocolobjects for the two standard partition assignment
strategies - Added an
api_versionskwarg toBrokerto facilitate switchable API protocol versions - Added support for all versions of the
MetadataRequesttoBroker - Added the
controller_brokerattribute toCluster - Added
create_topicsanddelete_topicstoBroker - Added
fetch_api_versionstoBrokerandCluster - Added a CLI for creating and deleting topics on the cluster to
kafka_tools - Added support for LZ4 compression to the
ProducerandSimpleConsumer
Bug Fixes
- Adjusted
Clusterto become aware of supported API versions immediately upon
instantiation - Refactored code in
Clusterrelated to metadata requests to make logic reusable for
pre-bootstrap communication with the cluster - Added the ability to pass arguments to
protocol.Responseinstances when waiting
on a future - Adjusted the
RandomPartitionerto avoid actually callingrandom.choiceto improve
performance - Removed some calls in
Producer.procucetoisinstanceto improve performance - Simplified retry logic in
SimpleConsumer.fetch_offsets
Miscellaneous
- Used
sudo: requiredto 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_instancefetch its binary fromarchive.apache.orginstead of
mirror.reverse.netbecause the latter removed old versions of Kafka