openstack/deb-python-kafka
Code Issues Proposed changes

Test failover integration with 3-brokers / replicas / partitions

Browse Source
This commit is contained in:
Dana Powers
2015-06-09 22:59:52 -07:00
parent 8b0a598045
commit 57b9c75df6
1 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
test/test_failover_integration.py
View File

@@ -23,10 +23,10 @@ class TestFailover(KafkaIntegrationTestCase):
return return
zk_chroot = random_string(10) zk_chroot = random_string(10)
replicas = 2 replicas = 3
partitions = 2 partitions = 3
# mini zookeeper, 2 kafka brokers # mini zookeeper, 3 kafka brokers
self.zk = ZookeeperFixture.instance() self.zk = ZookeeperFixture.instance()
kk_args = [self.zk.host, self.zk.port, zk_chroot, replicas, partitions] kk_args = [self.zk.host, self.zk.port, zk_chroot, replicas, partitions]
self.brokers = [KafkaFixture.instance(i, *kk_args) for i in range(replicas)] self.brokers = [KafkaFixture.instance(i, *kk_args) for i in range(replicas)]