Hi All, I am running: kafka_2.10-0.8.1.1, and when I run the reassign-partitions.sh script, I get this:
Partitions reassignment failed due to Partition reassignment currently in progress for Map(). Aborting operation kafka.common.AdminCommandFailedException: Partition reassignment currently in progress for Map(). Aborting operation at kafka.admin.ReassignPartitionsCommand.reassignPartitions(ReassignPartitionsCommand.scala:204) at kafka.admin.ReassignPartitionsCommand$.executeAssignment(ReassignPartitionsCommand.scala:124) at kafka.admin.ReassignPartitionsCommand$.main(ReassignPartitionsCommand.scala:49) at kafka.admin.ReassignPartitionsCommand.main(ReassignPartitionsCommand.scala) I'm running it as: /opt/kafka/kafka/bin/kafka-reassign-partitions.sh --zookeeper $ZOOKEEPER --reassignment-json-file ./$1.json --execute and my json file looks like: {"version":1, "partitions":[ {"topic":"perf_mytopic_raw", "partition":0,"replicas":[0,1]}, {"topic":"perf_mytopic_raw","partition":1,"replicas":[0,1]}]} The empty Map() looks suspicious, and I found another post from about a year ago where it was thought that this might be a bug? I looked through JIRA and didn't see anything that looked like this issue was created or fixed, so I wanted to ask again about it. Any ideas why this might be failing? There is definitely not another reassignment in progress. :) Thanks very much for your time. Chris