Repository: kafka Updated Branches: refs/heads/trunk b46cb3b29 -> a0ca8f642
KAFKA-2573: Mirror maker system test hangs and eventually fails Author: Ashish Singh <[email protected]> Reviewers: Geoff Anderson, Guozhang Wang Closes #234 from SinghAsDev/KAFKA-2573 Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/a0ca8f64 Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/a0ca8f64 Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/a0ca8f64 Branch: refs/heads/trunk Commit: a0ca8f6422e031c58e3a832852ba105e0f2efbad Parents: b46cb3b Author: Ashish Singh <[email protected]> Authored: Tue Oct 6 14:11:06 2015 -0700 Committer: Guozhang Wang <[email protected]> Committed: Tue Oct 6 14:11:06 2015 -0700 ---------------------------------------------------------------------- tests/kafkatest/sanity_checks/test_mirror_maker.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/kafka/blob/a0ca8f64/tests/kafkatest/sanity_checks/test_mirror_maker.py ---------------------------------------------------------------------- diff --git a/tests/kafkatest/sanity_checks/test_mirror_maker.py b/tests/kafkatest/sanity_checks/test_mirror_maker.py index 3481d7a..0b0eca3 100644 --- a/tests/kafkatest/sanity_checks/test_mirror_maker.py +++ b/tests/kafkatest/sanity_checks/test_mirror_maker.py @@ -77,9 +77,9 @@ class TestMirrorMakerService(Test): "grep \"consumer\.timeout\.ms\" %s" % MirrorMaker.CONSUMER_CONFIG, allow_fail=False) self.producer.start() - self.producer.wait() + self.producer.wait(10) self.consumer.start() - self.consumer.wait() + self.consumer.wait(10) num_consumed = len(self.consumer.messages_consumed[1]) num_produced = self.producer.num_acked
