Test failover integration with 3-brokers / replicas / partitions

Dana Powers · Dana Powers · commit 57b9c75df61d · 2015-06-09T22:59:52.000-07:00
diff --git a/test/test_failover_integration.py b/test/test_failover_integration.py
@@ -23,10 +23,10 @@ def setUp(self):
             return
 
         zk_chroot = random_string(10)
-        replicas = 2
-        partitions = 2
+        replicas = 3
+        partitions = 3
 
-        # mini zookeeper, 2 kafka brokers
+        # mini zookeeper, 3 kafka brokers
         self.zk = ZookeeperFixture.instance()
         kk_args = [self.zk.host, self.zk.port, zk_chroot, replicas, partitions]
         self.brokers = [KafkaFixture.instance(i, *kk_args) for i in range(replicas)]
