You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by ne...@apache.org on 2012/12/08 01:45:16 UTC
svn commit: r1418569 - in /kafka/branches/0.8/system_test:
replication_testsuite/replica_basic_test.py testcase_to_run.json
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"
]
}