diff options
Diffstat (limited to 'test/test_client_integration.py')
| -rw-r--r-- | test/test_client_integration.py | 6 |
1 files changed, 4 insertions, 2 deletions
diff --git a/test/test_client_integration.py b/test/test_client_integration.py index df0faef..a983ce1 100644 --- a/test/test_client_integration.py +++ b/test/test_client_integration.py @@ -1,5 +1,7 @@ import os +import pytest + from kafka.errors import KafkaTimeoutError from kafka.protocol import create_message from kafka.structs import ( @@ -7,7 +9,7 @@ from kafka.structs import ( ProduceRequestPayload) from test.fixtures import ZookeeperFixture, KafkaFixture -from test.testutil import KafkaIntegrationTestCase, kafka_versions +from test.testutil import KafkaIntegrationTestCase, env_kafka_version class TestKafkaClientIntegration(KafkaIntegrationTestCase): @@ -80,7 +82,7 @@ class TestKafkaClientIntegration(KafkaIntegrationTestCase): # Offset Tests # #################### - @kafka_versions('>=0.8.1') + @pytest.mark.skipif(not env_kafka_version(), reason="No KAFKA_VERSION set") def test_commit_fetch_offsets(self): req = OffsetCommitRequestPayload(self.topic, 0, 42, 'metadata') (resp,) = self.client.send_offset_commit_request('group', [req]) |