kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From gwens...@apache.org
Subject kafka git commit: MINOR: Tuned timeout parameter to reduce chance of transient failure
Date Fri, 13 Nov 2015 02:51:48 GMT
Repository: kafka
Updated Branches:
  refs/heads/0.9.0 c4e069ae5 -> e8f92d620


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 <geoff@confluent.io>

Reviewers: Gwen Shapira

Closes #521 from granders/minor-mm-transient-failure

(cherry picked from commit 2802bd081c9cfd91b8d7aa104c145ef0514ada49)
Signed-off-by: Gwen Shapira <cshapi@gmail.com>


Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/e8f92d62
Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/e8f92d62
Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/e8f92d62

Branch: refs/heads/0.9.0
Commit: e8f92d620360431548cca54d6545d1f44db12d2b
Parents: c4e069a
Author: Geoff Anderson <geoff@confluent.io>
Authored: Thu Nov 12 18:51:26 2015 -0800
Committer: Gwen Shapira <cshapi@gmail.com>
Committed: Thu Nov 12 18:51:39 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/e8f92d62/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


Mime
View raw message