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


------------------ 原始邮件 ------------------
发件人:&nbsp;"Sönke Liebau"<soenke.lie...@opencore.com.INVALID&gt;;
发送时间:&nbsp;2020年4月16日(星期四) 晚上7:42
收件人:&nbsp;"users"<users@kafka.apache.org&gt;;

主题:&nbsp;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&gt; wrote:

&gt; ghy@ghy-VirtualBox:~/T/k/bin$ ./kafka-reassign-partitions.sh --zookeeper
&gt; localhost:2181 --reassignment-json-file AddNewNode_Reassign-Partitions.json
&gt; --execute
&gt; Partitions reassignment failed due to The proposed assignment contains
&gt; non-existent partitions: ListBuffer(my-replicated-topic-0,
&gt; my-replicated-topic-1, my-replicated-topic-2)
&gt; kafka.common.AdminCommandFailedException: The proposed assignment contains
&gt; non-existent partitions: ListBuffer(my-replicated-topic-0,
&gt; my-replicated-topic-1, my-replicated-topic-2)
&gt;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; at
&gt; 
kafka.admin.ReassignPartitionsCommand$.parseAndValidate(ReassignPartitionsCommand.scala:342)
&gt;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; at
&gt; 
kafka.admin.ReassignPartitionsCommand$.executeAssignment(ReassignPartitionsCommand.scala:209)
&gt;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; at
&gt; 
kafka.admin.ReassignPartitionsCommand$.executeAssignment(ReassignPartitionsCommand.scala:205)
&gt;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; at
&gt; 
kafka.admin.ReassignPartitionsCommand$.main(ReassignPartitionsCommand.scala:65)
&gt;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; at
&gt; kafka.admin.ReassignPartitionsCommand.main(ReassignPartitionsCommand.scala)
&gt;
&gt;
&gt; ghy@ghy-VirtualBox:~/T/k/bin$&amp;nbsp;



-- 
Sönke Liebau
Partner
Tel. +49 179 7940878
OpenCore GmbH &amp; Co. KG - Thomas-Mann-Straße 8 - 22880 Wedel - Germany

Reply via email to