kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From rsiva...@apache.org
Subject [kafka] branch 2.2 updated: KAFKA-8070: Increase consumer startup timeout in system tests (#6405)
Date Fri, 08 Mar 2019 16:59:34 GMT
This is an automated email from the ASF dual-hosted git repository.

rsivaram 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 cec1dfa  KAFKA-8070: Increase consumer startup timeout in system tests (#6405)
cec1dfa is described below

commit cec1dfab3ff6c66c4457f147c0d567dd99c54957
Author: Rajini Sivaram <rajinisivaram@googlemail.com>
AuthorDate: Fri Mar 8 16:57:58 2019 +0000

    KAFKA-8070: Increase consumer startup timeout in system tests (#6405)
    
    For consumers using SSL, this timeout includes the time to create and copy keystores and
truststores and sometime it takes longer than 10s to complete the security setup before starting
the consumer process.
    
    Reviewers: Ismael Juma <ismael@juma.me.uk>
---
 tests/kafkatest/sanity_checks/test_console_consumer.py    | 2 +-
 tests/kafkatest/tests/core/consumer_group_command_test.py | 2 +-
 tests/kafkatest/tests/core/get_offset_shell_test.py       | 2 +-
 tests/kafkatest/tests/tools/log4j_appender_test.py        | 2 +-
 4 files changed, 4 insertions(+), 4 deletions(-)

diff --git a/tests/kafkatest/sanity_checks/test_console_consumer.py b/tests/kafkatest/sanity_checks/test_console_consumer.py
index 061bc3a..acf1184 100644
--- a/tests/kafkatest/sanity_checks/test_console_consumer.py
+++ b/tests/kafkatest/sanity_checks/test_console_consumer.py
@@ -63,7 +63,7 @@ class ConsoleConsumerTest(Test):
         node = self.consumer.nodes[0]
 
         wait_until(lambda: self.consumer.alive(node),
-            timeout_sec=10, backoff_sec=.2, err_msg="Consumer was too slow to start")
+            timeout_sec=20, backoff_sec=.2, err_msg="Consumer was too slow to start")
         self.logger.info("consumer started in %s seconds " % str(time.time() - t0))
 
         # Verify that log output is happening
diff --git a/tests/kafkatest/tests/core/consumer_group_command_test.py b/tests/kafkatest/tests/core/consumer_group_command_test.py
index 4976f3b..871e276 100644
--- a/tests/kafkatest/tests/core/consumer_group_command_test.py
+++ b/tests/kafkatest/tests/core/consumer_group_command_test.py
@@ -67,7 +67,7 @@ class ConsumerGroupCommandTest(Test):
         self.start_consumer()
         consumer_node = self.consumer.nodes[0]
         wait_until(lambda: self.consumer.alive(consumer_node),
-                   timeout_sec=10, backoff_sec=.2, err_msg="Consumer was too slow to start")
+                   timeout_sec=20, backoff_sec=.2, err_msg="Consumer was too slow to start")
         kafka_node = self.kafka.nodes[0]
         if security_protocol is not SecurityConfig.PLAINTEXT:
             prop_file = str(self.kafka.security_config.client_config())
diff --git a/tests/kafkatest/tests/core/get_offset_shell_test.py b/tests/kafkatest/tests/core/get_offset_shell_test.py
index b0f67ac..8fbba17 100644
--- a/tests/kafkatest/tests/core/get_offset_shell_test.py
+++ b/tests/kafkatest/tests/core/get_offset_shell_test.py
@@ -85,7 +85,7 @@ class GetOffsetShellTest(Test):
 
         node = self.consumer.nodes[0]
 
-        wait_until(lambda: self.consumer.alive(node), timeout_sec=10, backoff_sec=.2, err_msg="Consumer
was too slow to start")
+        wait_until(lambda: self.consumer.alive(node), timeout_sec=20, backoff_sec=.2, err_msg="Consumer
was too slow to start")
 
         # Assert that offset is correctly indicated by GetOffsetShell tool
         wait_until(lambda: "%s:%s:%s" % (TOPIC, NUM_PARTITIONS - 1, MAX_MESSAGES) in self.kafka.get_offset_shell(TOPIC,
None, 1000, 1, -1), timeout_sec=10,
diff --git a/tests/kafkatest/tests/tools/log4j_appender_test.py b/tests/kafkatest/tests/tools/log4j_appender_test.py
index 6c268da..03879e1 100644
--- a/tests/kafkatest/tests/tools/log4j_appender_test.py
+++ b/tests/kafkatest/tests/tools/log4j_appender_test.py
@@ -87,7 +87,7 @@ class Log4jAppenderTest(Test):
         node = self.consumer.nodes[0]
 
         wait_until(lambda: self.consumer.alive(node),
-            timeout_sec=10, backoff_sec=.2, err_msg="Consumer was too slow to start")
+            timeout_sec=20, backoff_sec=.2, err_msg="Consumer was too slow to start")
 
         # Verify consumed messages count
         wait_until(lambda: self.messages_received_count == MAX_MESSAGES, timeout_sec=10,


Mime
View raw message