Dana Powers

Defer version check until after bootstrap succeeds

4

Separated from #1411 . This PR moves version checking from `__init__` into `_bootstrap` . This means that if a cluster is down and bootstrapping fails, version checking will not cause...

Producer thread crashes if client hits fd limit

1

We should handle this a bit more gracefully. ``` Uncaught error in kafka producer I/O thread Traceback (most recent call last): File "venv/lib/python3.5/site-packages/kafka/producer/sender.py", line 55, in run self.run_once() File "venv/lib/python3.5/site-packages/kafka/producer/sender.py",...

Use Open3.capture3 to avoid deadlock between stdout/stderr in subprocess

1

While investigating a possible issue with our internal use of wicked_pdf / wkhtmltopdf, I found this issue in the source. After opening the wkhtmltopdf subprocess we attempt to read stderr,...

KAFKA-4160: Ensure rebalance listener not called with coordinator lock

2

See https://issues.apache.org/jira/browse/KAFKA-4160 . The original fix was intended to support rebalance listeners that may run longer than the session timeout. --- This change is [](https://reviewable.io/reviews/dpkp/kafka-python/1438)

Every release needs a decent changelog. Here's a very minimal first stab at what I have done for past releases. Goal is to roughly group all changes into functional/feature categories...

sys.version_info[1] checks the minor version, so on python 2.7 string_type is set to `str` instead of `basestring`. This causes unicode strings to fail when bernhard attempts to convert them to...