diff options
| author | Dana Powers <dana.powers@rd.io> | 2015-06-10 11:06:26 -0700 |
|---|---|---|
| committer | Dana Powers <dana.powers@rd.io> | 2015-06-10 11:06:26 -0700 |
| commit | 6a3e813199f352bf14355ba375d86fc3f1024c9a (patch) | |
| tree | 0ca38df94f3acfe5ce249d33cb3587795614fd8c /test/test_failover_integration.py | |
| parent | 043e9bb04f1149ab8f9f8942ee591227f659128d (diff) | |
| download | kafka-python-6a3e813199f352bf14355ba375d86fc3f1024c9a.tar.gz | |
Use at_least=True when counting messages in leader failover tests
Diffstat (limited to 'test/test_failover_integration.py')
| -rw-r--r-- | test/test_failover_integration.py | 5 |
1 files changed, 4 insertions, 1 deletions
diff --git a/test/test_failover_integration.py b/test/test_failover_integration.py index e27f12b..91779d7 100644 --- a/test/test_failover_integration.py +++ b/test/test_failover_integration.py @@ -90,7 +90,9 @@ class TestFailover(KafkaIntegrationTestCase): # count number of messages # Should be equal to 100 before + 1 recovery + 100 after - self.assert_message_count(topic, 201, partitions=(partition,)) + # at_least=True because exactly once delivery isn't really a thing + self.assert_message_count(topic, 201, partitions=(partition,), + at_least=True) @kafka_versions("all") def test_switch_leader_async(self): @@ -134,6 +136,7 @@ class TestFailover(KafkaIntegrationTestCase): # count number of messages # Should be equal to 10 before + 1 recovery + 10 after + # at_least=True because exactly once delivery isn't really a thing self.assert_message_count(topic, 21, partitions=(partition,), at_least=True) self.assert_message_count(topic, 21, partitions=(partition + 1,), |