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 <jjkoshy@gmail.com>
Authored: Fri Aug 2 16:18:25 2013 -0700
Committer: Joel Koshy <jjkoshy@gmail.com>
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
|