Hi Anyone any thoughts?
On Fri 29 Jun, 2018, 11:07 PM Debraj Manna, <subharaj.ma...@gmail.com> wrote: > Hi > > I altered a topic like below in kafka 1.1.0 > > /home/ubuntu/deploy/kafka/bin/kafka-topics.sh --zookeeper 127.0.0.1:2181 > --alter --topic Topic3 --config min.insync.replicas=2 > > But whenever I am trying to verify the reassignment it is showing the > below exception > > /home/ubuntu/deploy/kafka/bin/kafka-reassign-partitions.sh --zookeeper > 127.0.0.1:2181 --reassignment-json-file > /home/ubuntu/deploy/kafka/reassignment.json --verify > > Partitions reassignment failed due to Size of replicas list Vector(3, 0, 2) > is different from size of log dirs list Vector(any) for partition Topic3-7 > kafka.common.AdminCommandFailedException: Size of replicas list Vector(3, 0, > 2) is different from size of log dirs list Vector(any) for partition Topic3-7 > at > kafka.admin.ReassignPartitionsCommand$$anonfun$parsePartitionReassignmentData$1$$anonfun$apply$4$$anonfun$apply$5.apply(ReassignPartitionsCommand.scala:262) > at > kafka.admin.ReassignPartitionsCommand$$anonfun$parsePartitionReassignmentData$1$$anonfun$apply$4$$anonfun$apply$5.apply(ReassignPartitionsCommand.scala:251) > at scala.collection.Iterator$class.foreach(Iterator.scala:891) > at scala.collection.AbstractIterator.foreach(Iterator.scala:1334) > at > kafka.admin.ReassignPartitionsCommand$$anonfun$parsePartitionReassignmentData$1$$anonfun$apply$4.apply(ReassignPartitionsCommand.scala:251) > at > kafka.admin.ReassignPartitionsCommand$$anonfun$parsePartitionReassignmentData$1$$anonfun$apply$4.apply(ReassignPartitionsCommand.scala:250) > at scala.collection.immutable.List.foreach(List.scala:392) > at > kafka.admin.ReassignPartitionsCommand$$anonfun$parsePartitionReassignmentData$1.apply(ReassignPartitionsCommand.scala:250) > at > kafka.admin.ReassignPartitionsCommand$$anonfun$parsePartitionReassignmentData$1.apply(ReassignPartitionsCommand.scala:249) > at scala.collection.immutable.List.foreach(List.scala:392) > at > kafka.admin.ReassignPartitionsCommand$.parsePartitionReassignmentData(ReassignPartitionsCommand.scala:249) > at > kafka.admin.ReassignPartitionsCommand$.verifyAssignment(ReassignPartitionsCommand.scala:90) > at > kafka.admin.ReassignPartitionsCommand$.verifyAssignment(ReassignPartitionsCommand.scala:84) > at > kafka.admin.ReassignPartitionsCommand$.main(ReassignPartitionsCommand.scala:58) > at > kafka.admin.ReassignPartitionsCommand.main(ReassignPartitionsCommand.scala) > > > My reassignment.json & server.properties is attached. Same thing used to > work fine in kafka 0.10. Can someone let me what is going wrong? Is > anything changed related to this in kafka 1.1.0 ? >
