delta/python-packages/kafka-python.git/test, branch consumer_rejoin_fixes

Use Popen.communicate() instead of Popen.wait()

2019-01-05T22:38:53+00:00

Popen objects may deadlock when using stdout=PIPE or stderr=PIPE
with Popen.wait(). Using Popen.communicate() avoids the issue.

Cleanup formatting, no functional changes

2018-11-20T19:00:24+00:00

Cleanup the formatting, remove parens, extraneous spaces, etc.

Be explicit with tuples for %s formatting

2018-11-18T08:21:18+00:00

Fix #1633

Migrate from `Unittest` to `pytest` (#1620)

2018-11-10T20:48:33+00:00

Cleanup fixture imports

2018-10-27T09:17:23+00:00

`random_string` now comes from `test.fixtures` and was being
transparently imported via `test.testutil` so this bypasses the
pointless indirect import.

Similarly, `kafka_version` was transparently imported by `test.testutil`
from `test.fixtures`.

Also removed `random_port()` in `test.testutil` because its unused as its been replaced
by the one in `test.fixtures`.

This is part of the pytest migration that was started back in
a1869c4be5f47b4f6433610249aaf29af4ec95e5.

Minor aesthetic cleanup of partitioner tests

2018-10-27T09:16:11+00:00

Remove unused ivy_root variable

2018-10-27T09:12:35+00:00

This is no longer used anywhere in the codebase

Add KafkaAdmin class

2018-10-25T05:42:12+00:00

Requires cluster version > 0.10.0.0, and uses new wire protocol
classes to do many things via broker connection that previously
needed to be done directly in zookeeper.

Vendor `six` consistently

2018-10-22T21:30:33+00:00

Use vendored `six`, and also `six.moves.range` rather than `xrange`

Fix typo in file name

2018-10-22T15:33:13+00:00