MINOR: Reduce required occurrance from 100 to 10 (apache#5048)

Due to apache#4644 the consumer connector logs will be much more clean with fewer "broker may not be available" entries. We need to reduce the required frequency from 100 to a smaller number. I've thought about reducing to just 1, but it may still be transient (i.e. even if broker is starting up you may see a few entries) so I reduced it to 10. Reviewers: Bill Bejeck <[email protected]>, Matthias J. Sax <[email protected]>
liangjiezhu · May 21, 2018 · cbce95d · cbce95d
1 parent 16ad358
commit cbce95d
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/tests/kafkatest/tests/streams/streams_broker_down_resilience_test.py b/tests/kafkatest/tests/streams/streams_broker_down_resilience_test.py
@@ -91,9 +91,9 @@ def test_streams_runs_with_broker_down_initially(self):
         broker_unavailable_message = "Broker may not be available"
 
         # verify streams instances unable to connect to broker, kept trying
-        self.wait_for_verification(processor, broker_unavailable_message, processor.LOG_FILE, 100)
-        self.wait_for_verification(processor_2, broker_unavailable_message, processor_2.LOG_FILE, 100)
-        self.wait_for_verification(processor_3, broker_unavailable_message, processor_3.LOG_FILE, 100)
+        self.wait_for_verification(processor, broker_unavailable_message, processor.LOG_FILE, 10)
+        self.wait_for_verification(processor_2, broker_unavailable_message, processor_2.LOG_FILE, 10)
+        self.wait_for_verification(processor_3, broker_unavailable_message, processor_3.LOG_FILE, 10)
 
         # now start broker
         self.kafka.start_node(node)