kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jjko...@apache.org
Subject 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.
Date Fri, 02 Aug 2013 23:18:32 GMT
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 


Mime
View raw message