[kafka] branch trunk updated: MINOR: Reduce required occurrance from 100 to 10 (#5048)

[gu...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

guozhang pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git


The following commit(s) were added to refs/heads/trunk by this push:
     new cbce95d  MINOR: Reduce required occurrance from 100 to 10 (#5048)
cbce95d is described below

commit cbce95d9a5273a072c6c1e3d489760d5d52e638e
Author: Guozhang Wang <wa...@gmail.com>
AuthorDate: Mon May 21 11:50:19 2018 -0700

    MINOR: Reduce required occurrance from 100 to 10 (#5048)
    
    Due to #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 <bi...@confluent.io>, Matthias J. Sax <ma...@confluent.io>
---
 .../kafkatest/tests/streams/streams_broker_down_resilience_test.py  | 6 +++---
 1 file changed, 3 insertions(+), 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
index 11dc424..3cbf713 100644
--- 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 @@ class StreamsBrokerDownResilience(BaseStreamsTest):
         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)

-- 
To stop receiving notification emails like this one, please contact
guozhang@apache.org.