kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From j...@apache.org
Subject [kafka] branch 2.2 updated: MINOR: Increase security test timeouts for transient failures (#6760)
Date Sat, 18 May 2019 23:53:37 GMT
This is an automated email from the ASF dual-hosted git repository.

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


The following commit(s) were added to refs/heads/2.2 by this push:
     new 7b8db0d  MINOR: Increase security test timeouts for transient failures (#6760)
7b8db0d is described below

commit 7b8db0d7907f59549624307440e5fc4a906d2512
Author: Jason Gustafson <jason@confluent.io>
AuthorDate: Sat May 18 16:52:18 2019 -0700

    MINOR: Increase security test timeouts for transient failures (#6760)
    
    Reviewers: Ismael Juma <ismael@juma.me.uk>
---
 tests/kafkatest/tests/core/security_test.py | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/tests/kafkatest/tests/core/security_test.py b/tests/kafkatest/tests/core/security_test.py
index d0bebfe..5469df1 100644
--- a/tests/kafkatest/tests/core/security_test.py
+++ b/tests/kafkatest/tests/core/security_test.py
@@ -81,7 +81,7 @@ class SecurityTest(EndToEndTest):
         self.create_and_start_clients(log_level="DEBUG")
 
         try:
-            wait_until(lambda: self.producer.num_acked > 0, timeout_sec=5)
+            wait_until(lambda: self.producer.num_acked > 0, timeout_sec=30)
 
             # Fail quickly if messages are successfully acked
             raise RuntimeError("Messages published successfully but should not have!"
@@ -91,7 +91,7 @@ class SecurityTest(EndToEndTest):
             pass
 
         error = 'SSLHandshakeException' if security_protocol == 'SSL' else 'LEADER_NOT_AVAILABLE'
-        wait_until(lambda: self.producer_consumer_have_expected_error(error), timeout_sec=5)
+        wait_until(lambda: self.producer_consumer_have_expected_error(error), timeout_sec=30)
         self.producer.stop()
         self.consumer.stop()
 


Mime
View raw message