thank you !! now i ok ! because : ./kafka-reassign-partitions.sh --zookeeper localhost:2181/cluster_1 --reassignment-json-file AddNewNode_Reassign-Partitions.json --execute : OK ./kafka-reassign-partitions.sh --zookeeper localhost:2181 --reassignment-json-file AddNewNode_Reassign-Partitions.json --execute : Exception
------------------ 原始邮件 ------------------ 发件人: "Sönke Liebau"<soenke.lie...@opencore.com.INVALID>; 发送时间: 2020年4月16日(星期四) 晚上7:42 收件人: "users"<users@kafka.apache.org>; 主题: Re: who show this execption:The proposed assignment contains non-existent partitions: ListBuffer??? Hi there, I'm not sure if I understand your question correctly, but that error will be shown if your AddNewNode_Reassign-Partitions.json file contains partitions that don't exist on the cluster. In your case, I suspect that "my-replicated-topic" simply doesn't exist, if you create it with at least 3 partitions that error should go away. Does that answer your question or did I misunderstand? Best regards, Sönke On Thu, 16 Apr 2020 at 13:20, 一直以来 <279377...@qq.com> wrote: > ghy@ghy-VirtualBox:~/T/k/bin$ ./kafka-reassign-partitions.sh --zookeeper > localhost:2181 --reassignment-json-file AddNewNode_Reassign-Partitions.json > --execute > Partitions reassignment failed due to The proposed assignment contains > non-existent partitions: ListBuffer(my-replicated-topic-0, > my-replicated-topic-1, my-replicated-topic-2) > kafka.common.AdminCommandFailedException: The proposed assignment contains > non-existent partitions: ListBuffer(my-replicated-topic-0, > my-replicated-topic-1, my-replicated-topic-2) > at > kafka.admin.ReassignPartitionsCommand$.parseAndValidate(ReassignPartitionsCommand.scala:342) > at > kafka.admin.ReassignPartitionsCommand$.executeAssignment(ReassignPartitionsCommand.scala:209) > at > kafka.admin.ReassignPartitionsCommand$.executeAssignment(ReassignPartitionsCommand.scala:205) > at > kafka.admin.ReassignPartitionsCommand$.main(ReassignPartitionsCommand.scala:65) > at > kafka.admin.ReassignPartitionsCommand.main(ReassignPartitionsCommand.scala) > > > ghy@ghy-VirtualBox:~/T/k/bin$&nbsp; -- Sönke Liebau Partner Tel. +49 179 7940878 OpenCore GmbH & Co. KG - Thomas-Mann-Straße 8 - 22880 Wedel - Germany