root
/
kafka
mirror of https://github.com/apache/kafka.git
1
0
Fork 0
Code Issues Actions 2 Packages Projects Releases Wiki Activity

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
This commit is contained in:
Geoff Anderson 2015-11-12 18:51:26 -08:00 committed by Gwen Shapira
parent 2991c9865d
commit 2802bd081c
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
tests/kafkatest/tests/mirror_maker_test.py
View File

@ -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