openstack/deb-python-kafka
Code Issues Proposed changes

Fix zk_chroot in consumer integration kafka fixtures

Browse Source
This commit is contained in:
Dana Powers
2015-12-10 16:26:14 -08:00
parent d54980a2cd
commit b3bd4cf09b
1 changed files with 3 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
test/test_consumer_integration.py
View File

@@ -25,8 +25,9 @@ class TestConsumerIntegration(KafkaIntegrationTestCase):
return return
cls.zk = ZookeeperFixture.instance() cls.zk = ZookeeperFixture.instance()
cls.server1 = KafkaFixture.instance(0, cls.zk.host, cls.zk.port) chroot = random_string(10)
cls.server2 = KafkaFixture.instance(1, cls.zk.host, cls.zk.port) cls.server1 = KafkaFixture.instance(0, cls.zk.host, cls.zk.port, chroot)
cls.server2 = KafkaFixture.instance(1, cls.zk.host, cls.zk.port, chroot)
cls.server = cls.server1 # Bootstrapping server cls.server = cls.server1 # Bootstrapping server