2015-04-14 05:56:10,951 INFO [Thread-38] server.KafkaServer - [Kafka Server 45], Controlled shutdown succeeded 2015-04-14 05:56:10,956 INFO [Thread-38] network.SocketServer - [Socket Server on Broker 45], Shutting down at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:60) at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:60) at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:60) at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:60) at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:60) at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:60) at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:60) // this repeated 500 times or so (removed for brevity) // these 2 lines are from the container that we use to embed kafka 2015-04-14 05:58:50,121 WARN [Thread-4] server.KafkaServer - KafkaServer shutdown timed out, exiting anyway 2015-04-14 05:58:50,121 INFO [Thread-4] server.KafkaServer - Shut down complete for KafkaServer // I included this exception, as it seems to show where the thread was when it go an InterruptedException, might be useful 2015-04-14 05:58:50,121 WARN [Thread-38] utils.Utils$ - null java.lang.InterruptedException at java.util.concurrent.locks.AbstractQueuedSynchronizer.doAcquireSharedInterruptibly(AbstractQueuedSynchronizer.java:998) at java.util.concurrent.locks.AbstractQueuedSynchronizer.acquireSharedInterruptibly(AbstractQueuedSynchronizer.java:1304) at java.util.concurrent.CountDownLatch.await(CountDownLatch.java:231) at kafka.network.AbstractServerThread.shutdown(SocketServer.scala:121) at kafka.network.SocketServer$$anonfun$shutdown$2.apply(SocketServer.scala:100) at kafka.network.SocketServer$$anonfun$shutdown$2.apply(SocketServer.scala:99) at scala.collection.IndexedSeqOptimized$class.foreach(IndexedSeqOptimized.scala:33) at scala.collection.mutable.ArrayOps$ofRef.foreach(ArrayOps.scala:186) at kafka.network.SocketServer.shutdown(SocketServer.scala:99) at kafka.server.KafkaServer$$anonfun$shutdown$2.apply$mcV$sp(KafkaServer.scala:272) at kafka.utils.Utils$.swallow(Utils.scala:172) at kafka.utils.Logging$class.swallowWarn(Logging.scala:92) at kafka.utils.Utils$.swallowWarn(Utils.scala:45) at kafka.utils.Logging$class.swallow(Logging.scala:94) at kafka.utils.Utils$.swallow(Utils.scala:45) at kafka.server.KafkaServer.shutdown(KafkaServer.scala:272) at com.squareup.kafka.ng.server.KafkaServer$1.run(KafkaServer.java:154) 2015-04-14 05:58:50,143 INFO [Thread-38] server.KafkaRequestHandlerPool - [Kafka Request Handler on Broker 45], shutting down 2015-04-14 05:58:50,150 INFO [Thread-38] server.KafkaRequestHandlerPool - [Kafka Request Handler on Broker 45], shut down completely