kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From nehanarkh...@apache.org
Subject svn commit: r1418569 - in /kafka/branches/0.8/system_test: replication_testsuite/replica_basic_test.py testcase_to_run.json
Date Sat, 08 Dec 2012 00:45:16 GMT
Author: nehanarkhede
Date: Sat Dec  8 00:45:15 2012
New Revision: 1418569

URL: http://svn.apache.org/viewvc?rev=1418569&view=rev
Log:
Patching remaining files from KAFKA-644

Modified:
    kafka/branches/0.8/system_test/replication_testsuite/replica_basic_test.py
    kafka/branches/0.8/system_test/testcase_to_run.json

Modified: kafka/branches/0.8/system_test/replication_testsuite/replica_basic_test.py
URL: http://svn.apache.org/viewvc/kafka/branches/0.8/system_test/replication_testsuite/replica_basic_test.py?rev=1418569&r1=1418568&r2=1418569&view=diff
==============================================================================
--- kafka/branches/0.8/system_test/replication_testsuite/replica_basic_test.py (original)
+++ kafka/branches/0.8/system_test/replication_testsuite/replica_basic_test.py Sat Dec  8
00:45:15 2012
@@ -128,6 +128,11 @@ class ReplicaBasicTest(ReplicationUtils,
                     consumerMultiTopicsMode = self.testcaseEnv.testcaseArgumentsDict["consumer_multi_topics_mode"]
                 except:
                     pass
+                autoCreateTopic = "false"
+                try:
+                    autoCreateTopic = self.testcaseEnv.testcaseArgumentsDict["auto_create_topic"]
+                except:
+                    pass
 
 
                 # initialize self.testcaseEnv with user-defined environment variables (product
specific)
@@ -179,10 +184,11 @@ class ReplicaBasicTest(ReplicationUtils,
                 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)
+                if autoCreateTopic.lower() == "false":
+                    self.log_message("creating topics")
+                    kafka_system_test_utils.create_topic(self.systemTestEnv, self.testcaseEnv)
+                    self.anonLogger.info("sleeping for 5s")
+                    time.sleep(5)
 
                 # =============================================
                 # start ConsoleConsumer if this is a Log Retention test                

Modified: kafka/branches/0.8/system_test/testcase_to_run.json
URL: http://svn.apache.org/viewvc/kafka/branches/0.8/system_test/testcase_to_run.json?rev=1418569&r1=1418568&r2=1418569&view=diff
==============================================================================
--- kafka/branches/0.8/system_test/testcase_to_run.json (original)
+++ kafka/branches/0.8/system_test/testcase_to_run.json Sat Dec  8 00:45:15 2012
@@ -1,5 +1,5 @@
 {
     "ReplicaBasicTest"   : [
-        "testcase_9051"
+        "testcase_0001"
     ]
 }



Mime
View raw message