You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by jg...@apache.org on 2019/05/18 23:54:08 UTC
[kafka] branch 2.1 updated: MINOR: Increase security test timeouts
for transient failures (#6760)
This is an automated email from the ASF dual-hosted git repository.
jgus pushed a commit to branch 2.1
in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/2.1 by this push:
new 8ba7173 MINOR: Increase security test timeouts for transient failures (#6760)
8ba7173 is described below
commit 8ba7173da2c412b448c5754644f62447c2a5b333
Author: Jason Gustafson <ja...@confluent.io>
AuthorDate: Sat May 18 16:52:18 2019 -0700
MINOR: Increase security test timeouts for transient failures (#6760)
Reviewers: Ismael Juma <is...@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()