From f370d97b0d08771a36e0d3b128f33f555e9433fb Mon Sep 17 00:00:00 2001 From: Jeff Widman Date: Thu, 22 Aug 2019 17:43:52 -0700 Subject: Bump failing test iterations to 100--is travis happy? Locally I can Kafka 1.0.1 with python 3.7 to pass intermittently. On Travis it's not passing. So wondering if I just need more iterations. Hopefully we only need 20-50, but trying 90 here to see if that truly fixes it without actually going over the 100 messages we sent... ie, cn we fetch from both partitions or does it force us to do 100 messages from first partition before going onto second partition (which would be a problem)?? Note: not guaranteed that 90 cycles isn't getting us all the 100 messages in the first partition since `fetch_max_bytes=300`... but a shot in the dark here... if Travis still fails even with this, then may be something else is the problem. --- test/test_consumer_integration.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/test/test_consumer_integration.py b/test/test_consumer_integration.py index 1dc436c..c7e2ebf 100644 --- a/test/test_consumer_integration.py +++ b/test/test_consumer_integration.py @@ -631,7 +631,7 @@ def test_kafka_consumer_max_bytes_simple(kafka_consumer_factory, topic, send_mes consumer = kafka_consumer_factory( auto_offset_reset='earliest', fetch_max_bytes=300) seen_partitions = set() - for i in range(10): + for i in range(90): poll_res = consumer.poll(timeout_ms=100) for partition, msgs in poll_res.items(): for msg in msgs: -- cgit v1.2.1