kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jun...@apache.org
Subject git commit: kafka-1208; Update system test still to use kafka-topics instead of kafka-create-topics shell; patched by Guozhang Wang; reviewed by Jun Rao
Date Thu, 16 Jan 2014 04:53:44 GMT
Updated Branches:
  refs/heads/trunk 855340a2e -> c2ed6415f


kafka-1208; Update system test still to use kafka-topics instead of kafka-create-topics shell;
patched by Guozhang Wang; reviewed by Jun Rao


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

Branch: refs/heads/trunk
Commit: c2ed6415fcfa02d08dde031f0f799f5a0f18d8c5
Parents: 855340a
Author: Guozhang Wang <guwang@linkedin.com>
Authored: Wed Jan 15 20:57:07 2014 -0800
Committer: Jun Rao <junrao@gmail.com>
Committed: Wed Jan 15 20:57:07 2014 -0800

----------------------------------------------------------------------
 system_test/utils/kafka_system_test_utils.py | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/kafka/blob/c2ed6415/system_test/utils/kafka_system_test_utils.py
----------------------------------------------------------------------
diff --git a/system_test/utils/kafka_system_test_utils.py b/system_test/utils/kafka_system_test_utils.py
index 705c917..fb4a9c0 100644
--- a/system_test/utils/kafka_system_test_utils.py
+++ b/system_test/utils/kafka_system_test_utils.py
@@ -1128,7 +1128,7 @@ def create_topic(systemTestEnv, testcaseEnv):
         zkHost          = system_test_utils.get_data_by_lookup_keyval(clusterEntityConfigDictList,
"role", "zookeeper", "hostname")
         kafkaHome       = system_test_utils.get_data_by_lookup_keyval(clusterEntityConfigDictList,
"entity_id", zkEntityId, "kafka_home")
         javaHome        = system_test_utils.get_data_by_lookup_keyval(clusterEntityConfigDictList,
"entity_id", zkEntityId, "java_home")
-        createTopicBin  = kafkaHome + "/bin/kafka-create-topic.sh"
+        createTopicBin  = kafkaHome + "/bin/kafka-topics.sh --create"
 
         logger.debug("zkEntityId     : " + zkEntityId, extra=d)
         logger.debug("createTopicBin : " + createTopicBin, extra=d)
@@ -1155,8 +1155,8 @@ def create_topic(systemTestEnv, testcaseEnv):
                        createTopicBin,
                        " --topic "     + topic,
                        " --zookeeper " + zkConnectStr,
-                       " --replica "   + testcaseEnv.testcaseArgumentsDict["replica_factor"],
-                       " --partition " + testcaseEnv.testcaseArgumentsDict["num_partition"]
+ " >> ",
+                       " --replication-factor "   + testcaseEnv.testcaseArgumentsDict["replica_factor"],
+                       " --partitions " + testcaseEnv.testcaseArgumentsDict["num_partition"]
+ " >> ",
                        testcaseBaseDir + "/logs/create_source_cluster_topic.log'"]
     
             cmdStr = " ".join(cmdList)


Mime
View raw message