Hi , you can enable/disable controlled shutdown using controlled.shutdown.enable in server.properties. This is by default set to “true” in 0.8.2. You can go ahead do a rolling restart and you don’t need ShutdownBroker command which is removed. Regarding KAFKA-2029 talks about improvement to the controlled shutdown especially in case of having high partitions per broker which might degrade the performance as per the JIRA.
Thanks, Harsha On March 25, 2015 at 11:15:21 AM, Mingjie Lai (m...@apache.org) wrote: 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
