From 6a3e813199f352bf14355ba375d86fc3f1024c9a Mon Sep 17 00:00:00 2001 From: Dana Powers Date: Wed, 10 Jun 2015 11:06:26 -0700 Subject: Use at_least=True when counting messages in leader failover tests --- test/test_failover_integration.py | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) (limited to 'test/test_failover_integration.py') 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,), -- cgit v1.2.1