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

2.0.1
Compare
Choose a tag to compare
@emmettbutler emmettbutler released this 19 Oct 23:49
· 1490 commits to master since this release
2.0.1
b01c62b

Features

  • Added support for python 3.5
  • Added iteration to the BalancedConsumer
  • Disallowed min_queued_messages<1 in Producer
  • Made SimpleConsumer commit offsets on stop()
  • Supported None in message values

Bug Fixes

  • Improved BalancedConsumer's handling of an external KazooClient instance
  • Fixed kafka_tools.py for Python 3
  • Removed the unused use_greenlets kwarg from KafkaClient
  • Improved Cluster's ability to reconnect to brokers during metadata updates
  • Fixed an interpreter error in conncection.py
  • Fixed failure case in Producer when required_acks==0
  • Fixed a bug causing SimpleConsumer to leave zombie threads after disconnected brokers
  • Improved SimpleConsumer's worker thread exception reporting
  • Simplified SimpleConsumer's partition locking logic during fetch by using RLock
  • Fixed SimpleConsumer off-by-one error causing lag to never reach 0

Miscellaneous

  • Switched from Coveralls to Codecov for converage tracking
Assets 2
Loading