delta/python-packages/kafka-python.git/test/test_failover_integration.py, branch struct-pre-compilation

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.

Stop shadowing `ConnectionError`

2018-05-23T22:19:01+00:00

In Python3, `ConnectionError` is a native exception. So rename our
custom one to `KafkaConnectionError` to prevent accidentally
shadowing the native one.

Note that there are still valid uses of `ConnectionError` in this code.
They already expect a native Python3 `ConnectionError`, and also already
handle the Python2 compatibility issues.

Change SimpleProducer to use async_send (async is reserved in py37) (#1454)

2018-03-23T12:58:55+00:00

Introduce new fixtures to prepare for migration to pytest.

2018-02-21T21:30:12+00:00

This commits adds new pytest fixtures in prepation for the
migration of unittest.TestCases to pytest test cases. The handling
of temporary dir creation was also changed so that we can use
the pytest tmpdir fixture after the migration.

Minor Exception cleanup

2017-12-12T19:06:44+00:00

Fix typos

2016-11-14T11:16:41+00:00

Speedup some failover tests w/ shorter SimpleClient timeout

2016-04-08T16:23:57+00:00

Catch more producer exceptions in failover tests

2016-04-06T23:24:35+00:00

Update imports from kafka.common -> kafka.errors / kafka.structs

2016-04-05T16:35:45+00:00

Support setting kafka instance port explicitly in fixture

2016-02-16T05:56:10+00:00