Hi. I've been trying to figure out the best way to do kafka broker rolling restart, and read the controlled shutdown wiki page:
https://cwiki.apache.org/confluence/display/KAFKA/Replication+tools#Replicationtools-1.ControlledShutdown However I cannot find this kafka.admin.ShutdownBroker class in 0.8.2: /usr/lib/kafka $ bin/kafka-run-class.sh kafka.admin.ShutdownBroker Exception in thread "main" java.lang.NoClassDefFoundError: kafka/admin/ShutdownBroker Caused by: java.lang.ClassNotFoundException: kafka.admin.ShutdownBroker at java.net.URLClassLoader$1.run(URLClassLoader.java:217) at java.security.AccessController.doPrivileged(Native Method) at java.net.URLClassLoader.findClass(URLClassLoader.java:205) at java.lang.ClassLoader.loadClass(ClassLoader.java:323) at sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:294) at java.lang.ClassLoader.loadClass(ClassLoader.java:268) Could not find the main class: kafka.admin.ShutdownBroker. Program will exit. Some other commands are there: /usr/lib/kafka $ bin/kafka-topics.sh --list --zookeeper zk1:2181/kafka | grep test test However, I also see some jira about the bug fixes for ControlledShutdown like https://issues.apache.org/jira/browse/KAFKA-2029. So I kind of got confused. What's the plan for this feature in kafka? I still see the value of it, for example, we can move some the leader partitions around on purpose for a scheduled upgrade or config update, minimize the transition as less as possible. Thanks, Mingjie
