kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jkr...@apache.org
Subject [15/30] git commit: Patching remaining files from KAFKA-644
Date Tue, 18 Dec 2012 17:44:12 GMT
Patching remaining files from KAFKA-644

git-svn-id: https://svn.apache.org/repos/asf/kafka/branches/0.8@1418569 13f79535-47bb-0310-9956-ffa450edef68


Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/8a93698a
Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/8a93698a
Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/8a93698a

Branch: refs/heads/trunk
Commit: 8a93698a75fccb8fbad5c9c24b6657c646e11b3a
Parents: 1270663
Author: Neha Narkhede <nehanarkhede@apache.org>
Authored: Sat Dec 8 00:45:15 2012 +0000
Committer: Neha Narkhede <nehanarkhede@apache.org>
Committed: Sat Dec 8 00:45:15 2012 +0000

----------------------------------------------------------------------
 .../replication_testsuite/replica_basic_test.py    |   14 ++++++++++----
 system_test/testcase_to_run.json                   |    2 +-
 2 files changed, 11 insertions(+), 5 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/kafka/blob/8a93698a/system_test/replication_testsuite/replica_basic_test.py
----------------------------------------------------------------------
diff --git a/system_test/replication_testsuite/replica_basic_test.py b/system_test/replication_testsuite/replica_basic_test.py
index fe309ab..3fc47d9 100644
--- a/system_test/replication_testsuite/replica_basic_test.py
+++ b/system_test/replication_testsuite/replica_basic_test.py
@@ -128,6 +128,11 @@ class ReplicaBasicTest(ReplicationUtils, SetupUtils):
                     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, 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)
+                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                

http://git-wip-us.apache.org/repos/asf/kafka/blob/8a93698a/system_test/testcase_to_run.json
----------------------------------------------------------------------
diff --git a/system_test/testcase_to_run.json b/system_test/testcase_to_run.json
index 9dfa0ec..8252860 100644
--- a/system_test/testcase_to_run.json
+++ b/system_test/testcase_to_run.json
@@ -1,5 +1,5 @@
 {
     "ReplicaBasicTest"   : [
-        "testcase_9051"
+        "testcase_0001"
     ]
 }


Mime
View raw message