diff options
| -rw-r--r-- | test/test_failover_integration.py | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/test/test_failover_integration.py b/test/test_failover_integration.py index 91e22cf..f156152 100644 --- a/test/test_failover_integration.py +++ b/test/test_failover_integration.py @@ -23,10 +23,10 @@ class TestFailover(KafkaIntegrationTestCase): 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)] |