Skip to content
This repository has been archived by the owner on Mar 24, 2021. It is now read-only.

2.6.0.dev1

Pre-release
Pre-release
Compare
Choose a tag to compare
@emmettbutler emmettbutler released this 09 Dec 18:42
· 639 commits to master since this release
2.6.0.dev1
de317f5

Minor Version Features

  • Added support to Broker and Cluster for Kafka 0.10's Administrative API
  • Changed the MemberAssignment protocol API to more closely match the schema defined
    by Kafka

Bug Fixes

  • Changed components to use six.reraise to raise worker thread exceptions for easier
    debugging
  • Included message offset in messages returned from Producer delivery reports
  • Handled struct.error exceptions in Producer._send_request
  • Changed protocol implementation to parse ConsumerGroupProtocolMetadata from
    bytestrings returned from Kafka
Assets 2
Loading