diff options
| author | Jeff Widman <jeff@jeffwidman.com> | 2019-08-22 17:43:52 -0700 |
|---|---|---|
| committer | Jeff Widman <jeff@jeffwidman.com> | 2019-08-22 17:46:24 -0700 |
| commit | f370d97b0d08771a36e0d3b128f33f555e9433fb (patch) | |
| tree | 7e9ade5bae3b4b3172b39771e08eb6b7108092c8 | |
| parent | 20f152bfb3d3ba0b5ac24b8d34ffde3cebccbfff (diff) | |
| download | kafka-python-f370d97b0d08771a36e0d3b128f33f555e9433fb.tar.gz | |
Bump failing test iterations to 100--is travis happy?convert-remaining-unittests-to-pytest
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.
| -rw-r--r-- | test/test_consumer_integration.py | 2 |
1 files changed, 1 insertions, 1 deletions
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: |