This repository was archived by the owner on Mar 24, 2021. It is now read-only.
2.8.0-dev.2
Pre-release
Pre-release
·
226 commits
to master
since this release
Minor Version Features
- Added a
partition_offsetskwarg to consumers'commit_offsetsmethod to decouple
the notions of "committed" vs "consumed" messages - Added an
attemptskwarg toBroker.connectthat controls retries during broker
connection - Added a
queue_empty_timeout_mskwarg toProducer.__init__that creates an "empty
wait" state in theProducerwhen no messages are available to produce
Bugfixes
- Updated some
cli.print_managed_consumer_groupsto be Py3 compatible - Updated the topic creation/deletion CLI to avoid trying to talk to 0.10.0 brokers
- Improved error handling in
Cluster.get_group_coordinator - Added retry logic to
BrokerConnection.connect - Handled some nuisance errors when shutting down in
handlers.py - Added a
threading.Eventinstance toProducerindicating the presence of at least
one message in the queue to enable nonbusy "empty waiting" - Added logic to
SimpleConsumer.commit_offsetsand
OwnedPartition.build_offset_commit_requestthat handles user-specified offset
information and sends it in requests
Miscellaneous
- Updated version of Kafka used in Travis tests to 1.0.1
- Added usage guide section on connection loss
- Updated test harness to allow simulated killing of brokers
- Added a giant explanatory docstring to
Topic.fetch_offset_limitsclarifying how the
ListOffsetsAPI works - Pinned
geventdependency to avoid breaking change inkazoo, which depends on it - Added tests for retrying broker connections
- Added tests for user-specified offset commits