You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by rs...@apache.org on 2019/03/08 16:58:13 UTC
[kafka] branch trunk updated: KAFKA-8070: Increase consumer startup
timeout in system tests (#6405)
This is an automated email from the ASF dual-hosted git repository.
rsivaram 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 460b3a6 KAFKA-8070: Increase consumer startup timeout in system tests (#6405)
460b3a6 is described below
commit 460b3a6259388733771b312a55ff83805dc36e9b
Author: Rajini Sivaram <ra...@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 <is...@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,