delta/python-packages/kafka-python.git/test/test_failover_integration.py, branch connect_blocking_fixups

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

Merge branch '0.9'

2016-01-08T02:51:14+00:00

Conflicts:
	kafka/codec.py
	kafka/version.py
	test/test_producer.py
	test/test_producer_integration.py