diff options
| author | Dana Powers <dana.powers@rd.io> | 2015-12-10 12:21:37 -0800 |
|---|---|---|
| committer | Dana Powers <dana.powers@rd.io> | 2015-12-10 13:31:59 -0800 |
| commit | 4bd20aad2b7a0710458545009328f8729c89fee1 (patch) | |
| tree | eab1c86b1e63418b8d7f7fe13e66d354c3178082 /test/test_client_integration.py | |
| parent | 1856063f4e0c36a8ec6266358d82432adf879170 (diff) | |
| download | kafka-python-kafka_version_tests.tar.gz | |
Refactor kafka_versions to support arbitrary operators (> >= < <= ! =)kafka_version_tests
Diffstat (limited to 'test/test_client_integration.py')
| -rw-r--r-- | test/test_client_integration.py | 5 |
1 files changed, 1 insertions, 4 deletions
diff --git a/test/test_client_integration.py b/test/test_client_integration.py index 8853350..6872dbf 100644 --- a/test/test_client_integration.py +++ b/test/test_client_integration.py @@ -27,7 +27,6 @@ class TestKafkaClientIntegration(KafkaIntegrationTestCase): cls.server.close() cls.zk.close() - @kafka_versions("all") def test_consume_none(self): fetch = FetchRequest(self.bytes_topic, 0, 0, 1024) @@ -39,7 +38,6 @@ class TestKafkaClientIntegration(KafkaIntegrationTestCase): messages = list(fetch_resp.messages) self.assertEqual(len(messages), 0) - @kafka_versions("all") def test_ensure_topic_exists(self): # assume that self.topic was created by setUp @@ -50,7 +48,6 @@ class TestKafkaClientIntegration(KafkaIntegrationTestCase): with self.assertRaises(KafkaTimeoutError): self.client.ensure_topic_exists(b"this_topic_doesnt_exist", timeout=0) - @kafka_versions('all') def test_send_produce_request_maintains_request_response_order(self): self.client.ensure_topic_exists(b'foo') @@ -83,7 +80,7 @@ class TestKafkaClientIntegration(KafkaIntegrationTestCase): # Offset Tests # #################### - @kafka_versions("0.8.1", "0.8.1.1", "0.8.2.1") + @kafka_versions('>=0.8.1') def test_commit_fetch_offsets(self): req = OffsetCommitRequest(self.bytes_topic, 0, 42, b"metadata") (resp,) = self.client.send_offset_commit_request(b"group", [req]) |