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 <ge...@confluent.io> Reviewers: Gwen Shapira Closes #521 from granders/minor-mm-transient-failure (cherry picked from commit 2802bd081c9cfd91b8d7aa104c145ef0514ada49) Signed-off-by: Gwen Shapira <csh...@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 <ge...@confluent.io> Authored: Thu Nov 12 18:51:26 2015 -0800 Committer: Gwen Shapira <csh...@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
