diff options
Diffstat (limited to 'test')
| -rw-r--r-- | test/test_admin_integration.py | 13 |
1 files changed, 8 insertions, 5 deletions
diff --git a/test/test_admin_integration.py b/test/test_admin_integration.py index b3dc0cc..27028ce 100644 --- a/test/test_admin_integration.py +++ b/test/test_admin_integration.py @@ -8,10 +8,13 @@ from kafka.errors import NoError from kafka.admin import KafkaAdminClient, ACLFilter, ACLOperation, ACLPermissionType, ResourcePattern, ResourceType, ACL +# TODO: Convert to pytest / fixtures +# Note that ACL features require broker 0.11, but other admin apis may work on +# earlier broker versions class TestAdminClientIntegration(KafkaIntegrationTestCase): @classmethod def setUpClass(cls): # noqa - if env_kafka_version() < (0, 10): + if env_kafka_version() < (0, 11): return cls.zk = ZookeeperFixture.instance() @@ -19,19 +22,19 @@ class TestAdminClientIntegration(KafkaIntegrationTestCase): @classmethod def tearDownClass(cls): # noqa - if env_kafka_version() < (0, 10): + if env_kafka_version() < (0, 11): return cls.server.close() cls.zk.close() def setUp(self): - if env_kafka_version() < (0, 10): - self.skipTest('Admin Integration test requires KAFKA_VERSION >= 0.10') + if env_kafka_version() < (0, 11): + self.skipTest('Admin ACL Integration test requires KAFKA_VERSION >= 0.11') super(TestAdminClientIntegration, self).setUp() def tearDown(self): - if env_kafka_version() < (0, 10): + if env_kafka_version() < (0, 11): return super(TestAdminClientIntegration, self).tearDown() |