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 <[email protected]> Authored: Wed Jan 15 20:57:07 2014 -0800 Committer: Jun Rao <[email protected]> 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)
