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 <[email protected]> Reviewers: Gwen Shapira Closes apache#521 from granders/minor-mm-transient-failure
AllenRay · Nov 13, 2015 · 2802bd0 · 2802bd0
1 parent 2991c98
commit 2802bd0
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/tests/kafkatest/tests/mirror_maker_test.py b/tests/kafkatest/tests/mirror_maker_test.py
@@ -47,7 +47,7 @@ def __init__(self, test_context):
                                         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