[KAFKA-2218] reassignment tool needs to parse and validate the json

• Type: Bug
• Status: Resolved
• Priority: Critical
• Resolution: Duplicate
• Assignee: Unassigned
• Reporter: Joe Stein
• Created: 23/May/15 15:52
• Updated: 17/Aug/17 12:49
• Resolved: 17/Aug/17 12:49

Description

Ran into a production issue with the broker.id being set to a string instead of integer and the controller had nothing in the log and stayed stuck. Eventually we saw this in the log of the brokers where coming from

me 11:42 AM
[2015-05-23 15:41:05,863] 67396362 [ZkClient-EventThread-14-****ERROR org.I0Itec.zkclient.ZkEventThread - Error handling event ZkEvent[Data of /admin/reassign_partitions changed sent to kafka.controller.PartitionsReassignedListener@78c6aab8]
java.lang.ClassCastException: java.lang.String cannot be cast to java.lang.Integer
at scala.runtime.BoxesRunTime.unboxToInt(Unknown Source)
at kafka.controller.KafkaController$$anonfun$4.apply(KafkaController.scala:579)

we then had to delete the znode from zookeeper (admin/reassign_partition) and then fix the json and try it again

Issue Links

• Blocked: KAFKA-4914 Partition re-assignment tool should check types before persisting state in ZooKeeper