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

2.4.0
Compare
Choose a tag to compare
@emmettbutler emmettbutler released this 25 May 22:14
· 762 commits to master since this release
2.4.0
9fb10e7

Minor Version Features

  • Added support for connecting to Kafka brokers using a secure TLS connection
  • Removed the fallback in Cluster that treated hosts as a ZooKeeper
    connection string
  • Removed the block_on_queue_full kwarg from the rdkafka producer
  • Added the max_request_size kwarg to the rdkafka producer

Bug Fixes

  • Performed permissive parameter validation in consumers and producer to avoid
    cryptic errors on threads
  • Allowed more consumers than partitions in a balanced consumer group
  • Fixed python 3 compatibility in kafka_tools.py
  • Fixed a bug causing nuisance errors on interpreter shutdown
  • Removed some uses of deprecated functions in the rdkafka C extension
  • Fixed a bug causing crashes when kafka returns an invalid partition ID in
    partition requests

Miscellaneous

  • Added utilities for testing TLS support to the test suite
  • Made the gevent version requirement slightly more inclusive
Assets 2
Loading