You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by gw...@apache.org on 2015/11/13 03:51:36 UTC
kafka git commit: MINOR: Tuned timeout parameter to reduce chance of
transient failure
Repository: kafka
Updated Branches:
refs/heads/trunk 2991c9865 -> 2802bd081
MINOR: Tuned timeout parameter to reduce chance of transient failure
Increased timeout in downstream consumer doing validation step. This addresses a transient failure case in mirror maker tests with mirror maker failover.
Author: Geoff Anderson <ge...@confluent.io>
Reviewers: Gwen Shapira
Closes #521 from granders/minor-mm-transient-failure
Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/2802bd08
Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/2802bd08
Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/2802bd08
Branch: refs/heads/trunk
Commit: 2802bd081c9cfd91b8d7aa104c145ef0514ada49
Parents: 2991c98
Author: Geoff Anderson <ge...@confluent.io>
Authored: Thu Nov 12 18:51:26 2015 -0800
Committer: Gwen Shapira <cs...@gmail.com>
Committed: Thu Nov 12 18:51:26 2015 -0800
----------------------------------------------------------------------
tests/kafkatest/tests/mirror_maker_test.py | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/kafka/blob/2802bd08/tests/kafkatest/tests/mirror_maker_test.py
----------------------------------------------------------------------
diff --git a/tests/kafkatest/tests/mirror_maker_test.py b/tests/kafkatest/tests/mirror_maker_test.py
index d01f6b5..ad252ee 100644
--- a/tests/kafkatest/tests/mirror_maker_test.py
+++ b/tests/kafkatest/tests/mirror_maker_test.py
@@ -47,7 +47,7 @@ class TestMirrorMakerService(ProduceConsumeValidateTest):
whitelist=self.topic, offset_commit_interval_ms=1000)
# This will consume from target kafka cluster
self.consumer = ConsoleConsumer(test_context, num_nodes=1, kafka=self.target_kafka, topic=self.topic,
- message_validator=is_int, consumer_timeout_ms=15000)
+ message_validator=is_int, consumer_timeout_ms=60000)
def setUp(self):
# Source cluster