[ https://issues.apache.org/jira/browse/KAFKA-1947?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Honghai Chen updated KAFKA-1947: -------------------------------- Comment: was deleted (was: After fix the command line, the command still not work, seemly more bugs in it. Try below command bin\kafka.cmd topiccmd --create --topic mvlogs --partition 1 --replication-factor 2 --zookeeper localhost bin\kafka.cmd topiccmd --alter --topic mvlogs --partitions 2 --replica-assignment "2:3" --zookeeper localhost The log say: [2015-02-11 19:18:30,791] INFO zookeeper state changed (SyncConnected) (org.I0It ec.zkclient.ZkClient) WARNING: If partitions are increased for a topic that has a key, the partition l ogic or ordering of the messages will be affected [2015-02-11 19:18:31,427] INFO Add partition list for mvlogs is Map() (kafka.adm in.AdminUtils$) [2015-02-11 19:18:31,470] INFO Topic update {"version":1,"partitions":{"0":[3,1]}} (kafka.admin.AdminUtils$) Adding partitions succeeded! [2015-02-11 19:18:31,479] INFO Terminate ZkClient event thread. (org.I0Itec.zkcl ient.ZkEventThread) Seemly the JSON string is wrong! Will continue check it. ) > can't explicitly set replica-assignment when add partitions > ----------------------------------------------------------- > > Key: KAFKA-1947 > URL: https://issues.apache.org/jira/browse/KAFKA-1947 > Project: Kafka > Issue Type: Bug > Components: core > Affects Versions: 0.8.1.1 > Environment: Windows > Reporter: Honghai Chen > > When create topic, the replicaAssignmentOpt should not appear with partitions. > But when add partitions, they should can appear together, from the code > below, you can see when alter topic, and has partitions in arguments, it try > get "replica-assignment" > https://git1-us-west.apache.org/repos/asf?p=kafka.git;a=blob;f=core/src/main/scala/kafka/admin/TopicCommand.scala;h=285c0333ff43543d3e46444c1cd9374bb883bb59;hb=HEAD#l114 > > The root cause is below code: > CommandLineUtils.checkInvalidArgs(parser, options, replicaAssignmentOpt, > 305 allTopicLevelOpts -- Set(alterOpt, createOpt) + partitionsOpt + > replicationFactorOpt) > https://git1-us-west.apache.org/repos/asf?p=kafka.git;a=blob;f=core/src/main/scala/kafka/admin/TopicCommand.scala;h=285c0333ff43543d3e46444c1cd9374bb883bb59;hb=HEAD#l304 > Related: > https://issues.apache.org/jira/browse/KAFKA-1052 -- This message was sent by Atlassian JIRA (v6.3.4#6332)