Mingjie, Controlled shutdown has been fully implemented and is regularly exercised at LinkedIn for version upgrades / rolling bounce tests, etc. As Harsha said you just need to turn on the config in the brokers, and normal shutting down command like control-c will trigger the controlled shutdown.
Guozhang On Wed, Mar 25, 2015 at 12:39 PM, Harsha <ka...@harsha.io> wrote: > 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 > -- -- Guozhang
