diff options
| author | Dana Powers <dana.powers@rd.io> | 2015-06-09 22:59:52 -0700 |
|---|---|---|
| committer | Dana Powers <dana.powers@rd.io> | 2015-06-09 22:59:52 -0700 |
| commit | 57b9c75df61d1ec6edb5430e75a7e3a80cae76b5 (patch) | |
| tree | 387c3c45f395190dc4c15ccf6edb9d6c9ae6d7cd /test/test_failover_integration.py | |
| parent | 8b0a598045c010756e79d059736de06423b728c5 (diff) | |
| download | kafka-python-57b9c75df61d1ec6edb5430e75a7e3a80cae76b5.tar.gz | |
Test failover integration with 3-brokers / replicas / partitions
Diffstat (limited to 'test/test_failover_integration.py')
| -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)] |