Updated Branches: refs/heads/0.8 ed3e146cf -> 81a9f6a68
KAFKA-915; Mirror maker system tests should wait for topics to be created. (This patch is a work-around until KAFKA-956 is resolved.); patched by John Fung; reviewed by Joel Koshy. Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/81a9f6a6 Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/81a9f6a6 Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/81a9f6a6 Branch: refs/heads/0.8 Commit: 81a9f6a682e5ca35a041717d6c1d4a60af5fd36a Parents: ed3e146 Author: Joel Koshy <[email protected]> Authored: Fri Aug 2 16:18:25 2013 -0700 Committer: Joel Koshy <[email protected]> Committed: Fri Aug 2 16:18:25 2013 -0700 ---------------------------------------------------------------------- system_test/mirror_maker_testsuite/mirror_maker_test.py | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/kafka/blob/81a9f6a6/system_test/mirror_maker_testsuite/mirror_maker_test.py ---------------------------------------------------------------------- diff --git a/system_test/mirror_maker_testsuite/mirror_maker_test.py b/system_test/mirror_maker_testsuite/mirror_maker_test.py index 4dc3cdf..dfffb4e 100644 --- a/system_test/mirror_maker_testsuite/mirror_maker_test.py +++ b/system_test/mirror_maker_testsuite/mirror_maker_test.py @@ -165,17 +165,17 @@ class MirrorMakerTest(ReplicationUtils, SetupUtils): self.anonLogger.info("sleeping for 5s") time.sleep(5) + self.log_message("creating topics") + kafka_system_test_utils.create_topic(self.systemTestEnv, self.testcaseEnv) + self.anonLogger.info("sleeping for 5s") + time.sleep(5) + self.log_message("starting mirror makers") kafka_system_test_utils.start_mirror_makers(self.systemTestEnv, self.testcaseEnv) self.anonLogger.info("sleeping for 10s") time.sleep(10) - #self.log_message("creating topics") - #kafka_system_test_utils.create_topic(self.systemTestEnv, self.testcaseEnv) - #self.anonLogger.info("sleeping for 5s") - #time.sleep(5) - # ============================================= # starting producer
