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

[guozhang]

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 <wangg...@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 <b...@confluent.io>, Matthias J. Sax 
<matth...@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
guozh...@apache.org.