This repository has been archived by the owner on Mar 24, 2021. It is now read-only.
2.7.0.dev1
Pre-release
Pre-release
emmettbutler
released this
21 Sep 21:55
·
452 commits
to master
since this release
Minor Version Features
- Added a
broker_version
kwarg toBroker.__init__
for the purpose of setting
api_version
inFetchResponse
- Added a
topic_name
argument toBroker.join_group
for use in protocol metadata,
visible via the Administrative API - Added a function
print_managed_consumer_groups
to the CLI - Added a
timestamp
kwarg toProducer.produce
to pass on messages when the broker
supports newer message formats - Changed
Producer.produce
to return the producedMessage
instance - Added
protocol_version
andtimestamp
kwargs toMessage
- Added support for the
fetch_error_backoff_ms
kwarg onSimpleConsumer
- Added an
unblock_event
kwarg toSimpleConsumer.consume
used to notify the consumer
that its parentBalancedConsumer
is in the process of rebalancing - Added a general-purpose
cleanup
function toSimpleConsumer
Bug Fixes
- Added an
Event
that notifies the internalSimpleConsumer
of aBalancedConsumer
that a rebalance is in progress, fixing a bug causing partitions to be unreleased - Fixed a bug causing busywaiting in the
BalancedConsumer
when there are no partitions
available - Updated the protocol implementation to send non-empty
GroupMembershipProtocol
objects and become compatible with the Administrative API - Fixed a bytestring bug causing
kafka_tools.reset_offsets
not to work in python 3 - Added a separate retry limit on connections to the offset manager
- Improved logging on socket errors
- Fixed a bug causing API version not to be passed on certain requests
- Handled new
MessageSet
compression scheme in API v1 - Fixed a bug in
rdkafka.SimpleConsumer
causing exceptions not to be raised from worker
threads - Fixed a bug causing
fetch_offsets
not to raise exceptions under certain conditions
when it should
Miscellaneous
- Separated gevent tests from other builds in Travis
- Made dependency on gevent optional
- Added a convenient CLI entry point via
__main__
- Fixed exception naming convention to align with naming in the broker
- Avoided building the
rdkafka
extension on platforms that don't support it - Fixed a bug in test harness causing some tests not to be inherited from parent classes