You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by ju...@apache.org on 2013/09/11 19:04:00 UTC
[15/36] git commit: 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.
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/trunk
Commit: 81a9f6a682e5ca35a041717d6c1d4a60af5fd36a
Parents: ed3e146
Author: Joel Koshy <jj...@gmail.com>
Authored: Fri Aug 2 16:18:25 2013 -0700
Committer: Joel Koshy <jj...@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