kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From guozh...@apache.org
Subject [kafka] branch trunk updated: MINOR: Reduce required occurrance from 100 to 10 (#5048)
Date Mon, 21 May 2018 18:50:24 GMT
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 <wangguoz@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 <bill@confluent.io>, Matthias J. Sax <matthias@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.

Mime
View raw message