You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by ju...@apache.org on 2014/01/16 05:53:44 UTC
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
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 <gu...@linkedin.com>
Authored: Wed Jan 15 20:57:07 2014 -0800
Committer: Jun Rao <ju...@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)