Dana Powers

I'm also seeing a free error when using `lz4f.freeDecompContext`: ``` pypy: free(): invalid pointer: 0x00007fc96e5543b0 ``` I wonder if this is related?

Historically the kafka-python project philosophy has been to be pure-python and not have any required dependencies. I recognize that the python packaging ecosystem has improved substantially in the past several...

Wouldn't this prevent retrying exceptions that are likely to be resolved within the timeout? Are there specific exceptions that you are concerned about here?

It looks like the java client only raises on invalid or unauthorized topics, or on a connection authentication failure. Other failures are not raised and will get retried subject to...

Looks like there are some master tests failing, but also this PR triggers a Metrics/CyclomaticComplexity rubocop issue. Let me know how you'd prefer to manage that.

I appreciate the motivation here, but I think a better solution would be to pass a timeout parameter to `ensure_coordinator_known` . That is the approach taken in the java client...

This should not be merged until locking / deadlock issues are addressed. At least it should be rebased onto master after latest lock changes, and then I think we need...

I don't feel like maintaining py2 + py3 compatibility has been much of a burden for this library. I would prefer to keep compatibility.

Probably today or tomorrow!

Available at https://pypi.org/project/kafka-python/ (`pip install kafka-python`)