summaryrefslogtreecommitdiff
path: root/test/test_client_integration.py
Commit message (Collapse)AuthorAgeFilesLines
* Remove SimpleClient, Producer, Consumer, Unittest (#1196)Jeff Widman2019-10-111-95/+0
| | | | | | | | | | | | | | | | | | In the 2.0 release, we're removing: * `SimpleClient` * `SimpleConsumer` * `SimpleProducer` * Old partitioners used by `SimpleProducer`; these are superceded by the `DefaultPartitioner` These have been deprecated for several years in favor of `KafkaClient` / `KafkaConsumer` / `KafkaProducer`. Since 2.0 allows breaking changes, we are removing the deprecated classes. Additionally, since the only usage of `unittest` was in tests for these old Simple* clients, this also drops `unittest` from the library. All tests now run under `pytest`.
* Cleanup handling of KAFKA_VERSION env var in tests (#1887)Jeff Widman2019-08-221-2/+4
| | | | | | | | | | | | | Now that we are using `pytest`, there is no need for a custom decorator because we can use `pytest.mark.skipif()`. This makes the code significantly simpler. In particular, dropping the custom `@kafka_versions()` decorator is necessary because it uses `func.wraps()` which doesn't play nice with `pytest` fixtures: - https://github.com/pytest-dev/pytest/issues/677 - https://stackoverflow.com/a/19614807/770425 So this is a pre-requisite to migrating some of those tests to using pytest fixtures.
* Introduce new fixtures to prepare for migration to pytest.Andre Araujo2018-02-211-1/+1
| | | | | | | 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.
* Update imports from kafka.common -> kafka.errors / kafka.structsDana Powers2016-04-051-4/+4
|
* Merge branch '0.9'Dana Powers2016-01-071-20/+20
|\ | | | | | | | | | | | | | | Conflicts: kafka/codec.py kafka/version.py test/test_producer.py test/test_producer_integration.py
| * Drop kafka_bytestringDana Powers2015-12-101-14/+14
| |
| * Convert OffsetCommit and OffsetFetch protocol encode/decodeDana Powers2015-12-101-3/+3
| |
| * Update references to kafka.common Request/Response (now Payload)Dana Powers2015-12-091-7/+7
| |
* | Refactor kafka_versions to support arbitrary operators (> >= < <= ! =)kafka_version_testsDana Powers2015-12-101-4/+1
|/
* Add kafka 0.8.2.1 to integration tests, remove 0.8.2.0Dana Powers2015-06-101-1/+1
|
* Remove 1 sec timeout on topic creation in client response ordering testDana Powers2015-06-101-2/+2
|
* Add KafkaClient test to show that request / response ordering is brokenDana Powers2015-06-101-1/+31
|
* Import style nits in integration testsDana Powers2015-06-081-3/+2
|
* Make external API consistently support python3 strings for topic.Space2015-04-031-4/+4
|
* Add 0.8.2.0 to some kafka_version testsDana Powers2015-01-141-1/+1
|
* Merge conflict w/ assertEqual (assertEquals deprecated)Dana Powers2014-12-151-8/+8
|
* Merge pull request #227 from wizzat-feature/py3Dana Powers2014-09-071-9/+6
|\ | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | | Python 3 Support Conflicts: kafka/producer.py test/test_client.py test/test_client_integration.py test/test_codec.py test/test_consumer.py test/test_consumer_integration.py test/test_failover_integration.py test/test_producer.py test/test_producer_integration.py test/test_protocol.py test/test_util.py
| * Fix more tests, only multiprocessing consumer ones remainingBruno Renié2014-09-031-5/+5
| |
| * Use base unittest or unittest2 depending on python versionBruno Renié2014-09-031-2/+2
| |
* | Cleanup tests: no more import *; remove unusedDana Powers2014-09-041-4/+9
| |
* | Import cleanups in testsDana Powers2014-09-041-2/+3
| |
* | Fix socket timeout test -- mock the side_effectDana Powers2014-09-011-11/+0
|/
* Add pylint to tox.ini; test both kafka and test; default to error-checking ↵Dana Powers2014-08-251-5/+3
| | | | only; fixup errors; skip kafka/queue.py
* Add KafkaTimeoutError (used by client.ensure_topic_exists) and add a testDana Powers2014-08-141-0/+11
|
* Add kafka 0.8.1.1 to integration tests.Dana Powers2014-08-131-1/+1
| | | | | | - previous 0.8.1 src appears to have actually been 0.8.1.1 based on git submodule commit. So technically this adds back 0.8.1 to the test suite.
* Add missing importMark Roberts2014-04-301-0/+1
|
* Skip flaky test between osx/linuxMark Roberts2014-04-301-1/+1
|
* Fix Python 2.6 supportMark Roberts2014-04-231-1/+0
|
* Split out kafka version environments, default tox no longer runs any ↵Mark Roberts2014-04-231-4/+12
| | | | integration tests, make skipped integration also skip setupClass, implement rudimentary offset support in consumer.py
* Add test support for multiple versions of kafka. Uncomment first 0.8.1 ↵Mark Roberts2014-04-231-3/+3
| | | | specific test. Add rudimentary (failing) consumer resumption test
* Update fixtures to eliminate extraneous logging on non-errors, split out ↵Mark Roberts2014-04-221-2/+3
| | | | mostly unrelated service.py, fix test in client_integration to use get_open_port, fix unintended import cascade in test_producer_integration
* Fix bug in socket timeout per PR #161 by maciejkula, add testMark Roberts2014-04-191-3/+13
|
* Finish breaking out integration testsMark Roberts2014-04-171-0/+47
View Lorry Controller Status