2017-04-28 10:22:32
Full thread dump Java HotSpot(TM) 64-Bit Server VM (25.91-b14 mixed mode):

"Attach Listener" #95 daemon prio=9 os_prio=0 tid=0x00007f79c8001000 nid=0x91bf waiting on condition [0x0000000000000000]
   java.lang.Thread.State: RUNNABLE

"RMI Scheduler(0)" #84 daemon prio=5 os_prio=0 tid=0x00007f7828021000 nid=0x7cb0 waiting on condition [0x00007f794e413000]
   java.lang.Thread.State: WAITING (parking)
	at sun.misc.Unsafe.park(Native Method)
	- parking to wait for  <0x00000004002ffe50> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject)
	at java.util.concurrent.locks.LockSupport.park(LockSupport.java:175)
	at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039)
	at java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:1081)
	at java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:809)
	at java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1067)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1127)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
	at java.lang.Thread.run(Thread.java:745)

"ReplicaFetcherThread-0-72" #82 prio=5 os_prio=0 tid=0x00007f7844036000 nid=0x163d runnable [0x00007f7921416000]
   java.lang.Thread.State: RUNNABLE
	at sun.nio.ch.EPollArrayWrapper.epollWait(Native Method)
	at sun.nio.ch.EPollArrayWrapper.poll(EPollArrayWrapper.java:269)
	at sun.nio.ch.EPollSelectorImpl.doSelect(EPollSelectorImpl.java:93)
	at sun.nio.ch.SelectorImpl.lockAndDoSelect(SelectorImpl.java:86)
	- locked <0x0000000409619f78> (a sun.nio.ch.Util$2)
	- locked <0x0000000409619f88> (a java.util.Collections$UnmodifiableSet)
	- locked <0x0000000409619f30> (a sun.nio.ch.EPollSelectorImpl)
	at sun.nio.ch.SelectorImpl.select(SelectorImpl.java:97)
	at org.apache.kafka.common.network.Selector.select(Selector.java:489)
	at org.apache.kafka.common.network.Selector.poll(Selector.java:298)
	at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:349)
	at kafka.utils.NetworkClientBlockingOps$.recursivePoll$1(NetworkClientBlockingOps.scala:135)
	at kafka.utils.NetworkClientBlockingOps$.pollContinuously$extension(NetworkClientBlockingOps.scala:142)
	at kafka.utils.NetworkClientBlockingOps$.blockingSendAndReceive$extension(NetworkClientBlockingOps.scala:108)
	at kafka.server.ReplicaFetcherThread.sendRequest(ReplicaFetcherThread.scala:249)
	at kafka.server.ReplicaFetcherThread.fetch(ReplicaFetcherThread.scala:234)
	at kafka.server.ReplicaFetcherThread.fetch(ReplicaFetcherThread.scala:42)
	at kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:118)
	at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:103)
	at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:63)

"ReplicaFetcherThread-0-74" #81 prio=5 os_prio=0 tid=0x00007f787805c000 nid=0x163c runnable [0x00007f7921517000]
   java.lang.Thread.State: RUNNABLE
	at sun.nio.ch.EPollArrayWrapper.epollWait(Native Method)
	at sun.nio.ch.EPollArrayWrapper.poll(EPollArrayWrapper.java:269)
	at sun.nio.ch.EPollSelectorImpl.doSelect(EPollSelectorImpl.java:93)
	at sun.nio.ch.SelectorImpl.lockAndDoSelect(SelectorImpl.java:86)
	- locked <0x0000000409419fa0> (a sun.nio.ch.Util$2)
	- locked <0x0000000409419fb0> (a java.util.Collections$UnmodifiableSet)
	- locked <0x0000000409419f58> (a sun.nio.ch.EPollSelectorImpl)
	at sun.nio.ch.SelectorImpl.select(SelectorImpl.java:97)
	at org.apache.kafka.common.network.Selector.select(Selector.java:489)
	at org.apache.kafka.common.network.Selector.poll(Selector.java:298)
	at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:349)
	at kafka.utils.NetworkClientBlockingOps$.recursivePoll$1(NetworkClientBlockingOps.scala:135)
	at kafka.utils.NetworkClientBlockingOps$.pollContinuously$extension(NetworkClientBlockingOps.scala:142)
	at kafka.utils.NetworkClientBlockingOps$.blockingSendAndReceive$extension(NetworkClientBlockingOps.scala:108)
	at kafka.server.ReplicaFetcherThread.sendRequest(ReplicaFetcherThread.scala:249)
	at kafka.server.ReplicaFetcherThread.fetch(ReplicaFetcherThread.scala:234)
	at kafka.server.ReplicaFetcherThread.fetch(ReplicaFetcherThread.scala:42)
	at kafka.server.AbstractFetcherThread.processFetchRequest(AbstractFetcherThread.scala:118)
	at kafka.server.AbstractFetcherThread.doWork(AbstractFetcherThread.scala:103)
	at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:63)

"Controller-73-to-broker-72-send-thread" #80 prio=5 os_prio=0 tid=0x00007f797c00e800 nid=0x1625 waiting on condition [0x00007f7921618000]
   java.lang.Thread.State: WAITING (parking)
	at sun.misc.Unsafe.park(Native Method)
	- parking to wait for  <0x000000040a8191c8> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject)
	at java.util.concurrent.locks.LockSupport.park(LockSupport.java:175)
	at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039)
	at java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442)
	at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:175)
	at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:63)

"executor-Fetch" #79 prio=5 os_prio=0 tid=0x00007f78b8002000 nid=0x15db waiting on condition [0x00007f7921719000]
   java.lang.Thread.State: WAITING (parking)
	at sun.misc.Unsafe.park(Native Method)
	- parking to wait for  <0x0000000400765d68> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject)
	at java.util.concurrent.locks.LockSupport.park(LockSupport.java:175)
	at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039)
	at java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442)
	at java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1067)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1127)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
	at java.lang.Thread.run(Thread.java:745)

"Controller-73-to-broker-74-send-thread" #78 prio=5 os_prio=0 tid=0x00007f797c00b000 nid=0x15da waiting on condition [0x00007f7923f29000]
   java.lang.Thread.State: WAITING (parking)
	at sun.misc.Unsafe.park(Native Method)
	- parking to wait for  <0x00000004f53e58b0> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject)
	at java.util.concurrent.locks.LockSupport.park(LockSupport.java:175)
	at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039)
	at java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442)
	at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:175)
	at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:63)

"kafka-scheduler-9" #77 daemon prio=5 os_prio=0 tid=0x00007f78dc005000 nid=0xc5f waiting on condition [0x00007f792472b000]
   java.lang.Thread.State: WAITING (parking)
	at sun.misc.Unsafe.park(Native Method)
	- parking to wait for  <0x000000040022eec0> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject)
	at java.util.concurrent.locks.LockSupport.park(LockSupport.java:175)
	at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039)
	at java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:1088)
	at java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:809)
	at java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1067)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1127)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
	at java.lang.Thread.run(Thread.java:745)

"kafka-scheduler-8" #76 daemon prio=5 os_prio=0 tid=0x00007f786c02d000 nid=0xc5e waiting on condition [0x00007f7929bf8000]
   java.lang.Thread.State: WAITING (parking)
	at sun.misc.Unsafe.park(Native Method)
	- parking to wait for  <0x000000040022eec0> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject)
	at java.util.concurrent.locks.LockSupport.park(LockSupport.java:175)
	at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039)
	at java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:1088)
	at java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:809)
	at java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1067)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1127)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
	at java.lang.Thread.run(Thread.java:745)

"Controller-73-to-broker-73-send-thread" #75 prio=5 os_prio=0 tid=0x00007f797c034800 nid=0xc5d waiting on condition [0x00007f7929cf9000]
   java.lang.Thread.State: WAITING (parking)
	at sun.misc.Unsafe.park(Native Method)
	- parking to wait for  <0x000000040076f200> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject)
	at java.util.concurrent.locks.LockSupport.park(LockSupport.java:175)
	at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039)
	at java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442)
	at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:175)
	at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:63)

"kafka-request-handler-14" #74 daemon prio=5 os_prio=0 tid=0x00007f7b04ef0000 nid=0xc5c waiting on condition [0x00007f7929ffa000]
   java.lang.Thread.State: TIMED_WAITING (parking)
	at sun.misc.Unsafe.park(Native Method)
	- parking to wait for  <0x0000000400676168> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject)
	at java.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:215)
	at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(AbstractQueuedSynchronizer.java:2078)
	at java.util.concurrent.ArrayBlockingQueue.poll(ArrayBlockingQueue.java:418)
	at kafka.network.RequestChannel.receiveRequest(RequestChannel.scala:237)
	at kafka.server.KafkaRequestHandler.run(KafkaRequestHandler.scala:50)
	at java.lang.Thread.run(Thread.java:745)

"kafka-request-handler-13" #73 daemon prio=5 os_prio=0 tid=0x00007f7b04eee000 nid=0xc5b waiting on condition [0x00007f792a0fb000]
   java.lang.Thread.State: TIMED_WAITING (parking)
	at sun.misc.Unsafe.park(Native Method)
	- parking to wait for  <0x0000000400676168> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject)
	at java.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:215)
	at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(AbstractQueuedSynchronizer.java:2078)
	at java.util.concurrent.ArrayBlockingQueue.poll(ArrayBlockingQueue.java:418)
	at kafka.network.RequestChannel.receiveRequest(RequestChannel.scala:237)
	at kafka.server.KafkaRequestHandler.run(KafkaRequestHandler.scala:50)
	at java.lang.Thread.run(Thread.java:745)

"kafka-request-handler-12" #72 daemon prio=5 os_prio=0 tid=0x00007f7b04eec800 nid=0xc5a waiting on condition [0x00007f792a1fc000]
   java.lang.Thread.State: TIMED_WAITING (parking)
	at sun.misc.Unsafe.park(Native Method)
	- parking to wait for  <0x0000000400676168> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject)
	at java.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:215)
	at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(AbstractQueuedSynchronizer.java:2078)
	at java.util.concurrent.ArrayBlockingQueue.poll(ArrayBlockingQueue.java:418)
	at kafka.network.RequestChannel.receiveRequest(RequestChannel.scala:237)
	at kafka.server.KafkaRequestHandler.run(KafkaRequestHandler.scala:50)
	at java.lang.Thread.run(Thread.java:745)

"kafka-request-handler-11" #71 daemon prio=5 os_prio=0 tid=0x00007f7b04eea800 nid=0xc59 waiting on condition [0x00007f792a2fd000]
   java.lang.Thread.State: TIMED_WAITING (parking)
	at sun.misc.Unsafe.park(Native Method)
	- parking to wait for  <0x0000000400676168> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject)
	at java.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:215)
	at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(AbstractQueuedSynchronizer.java:2078)
	at java.util.concurrent.ArrayBlockingQueue.poll(ArrayBlockingQueue.java:418)
	at kafka.network.RequestChannel.receiveRequest(RequestChannel.scala:237)
	at kafka.server.KafkaRequestHandler.run(KafkaRequestHandler.scala:50)
	at java.lang.Thread.run(Thread.java:745)

"kafka-request-handler-10" #70 daemon prio=5 os_prio=0 tid=0x00007f7b04ee8800 nid=0xc58 waiting on condition [0x00007f792a3fe000]
   java.lang.Thread.State: TIMED_WAITING (parking)
	at sun.misc.Unsafe.park(Native Method)
	- parking to wait for  <0x0000000400676168> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject)
	at java.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:215)
	at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(AbstractQueuedSynchronizer.java:2078)
	at java.util.concurrent.ArrayBlockingQueue.poll(ArrayBlockingQueue.java:418)
	at kafka.network.RequestChannel.receiveRequest(RequestChannel.scala:237)
	at kafka.server.KafkaRequestHandler.run(KafkaRequestHandler.scala:50)
	at java.lang.Thread.run(Thread.java:745)

"kafka-request-handler-9" #69 daemon prio=5 os_prio=0 tid=0x00007f7b04ee7000 nid=0xc57 waiting on condition [0x00007f792f5f6000]
   java.lang.Thread.State: TIMED_WAITING (parking)
	at sun.misc.Unsafe.park(Native Method)
	- parking to wait for  <0x0000000400676168> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject)
	at java.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:215)
	at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(AbstractQueuedSynchronizer.java:2078)
	at java.util.concurrent.ArrayBlockingQueue.poll(ArrayBlockingQueue.java:418)
	at kafka.network.RequestChannel.receiveRequest(RequestChannel.scala:237)
	at kafka.server.KafkaRequestHandler.run(KafkaRequestHandler.scala:50)
	at java.lang.Thread.run(Thread.java:745)

"kafka-request-handler-8" #68 daemon prio=5 os_prio=0 tid=0x00007f7b04ee5000 nid=0xc56 waiting on condition [0x00007f792f6f7000]
   java.lang.Thread.State: TIMED_WAITING (parking)
	at sun.misc.Unsafe.park(Native Method)
	- parking to wait for  <0x0000000400676168> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject)
	at java.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:215)
	at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(AbstractQueuedSynchronizer.java:2078)
	at java.util.concurrent.ArrayBlockingQueue.poll(ArrayBlockingQueue.java:418)
	at kafka.network.RequestChannel.receiveRequest(RequestChannel.scala:237)
	at kafka.server.KafkaRequestHandler.run(KafkaRequestHandler.scala:50)
	at java.lang.Thread.run(Thread.java:745)

"kafka-request-handler-7" #67 daemon prio=5 os_prio=0 tid=0x00007f7b050c8800 nid=0xc55 waiting on condition [0x00007f792f7f8000]
   java.lang.Thread.State: TIMED_WAITING (parking)
	at sun.misc.Unsafe.park(Native Method)
	- parking to wait for  <0x0000000400676168> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject)
	at java.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:215)
	at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(AbstractQueuedSynchronizer.java:2078)
	at java.util.concurrent.ArrayBlockingQueue.poll(ArrayBlockingQueue.java:418)
	at kafka.network.RequestChannel.receiveRequest(RequestChannel.scala:237)
	at kafka.server.KafkaRequestHandler.run(KafkaRequestHandler.scala:50)
	at java.lang.Thread.run(Thread.java:745)

"kafka-request-handler-6" #66 daemon prio=5 os_prio=0 tid=0x00007f7b050c6800 nid=0xc54 waiting on condition [0x00007f792f8f9000]
   java.lang.Thread.State: TIMED_WAITING (parking)
	at sun.misc.Unsafe.park(Native Method)
	- parking to wait for  <0x0000000400676168> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject)
	at java.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:215)
	at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(AbstractQueuedSynchronizer.java:2078)
	at java.util.concurrent.ArrayBlockingQueue.poll(ArrayBlockingQueue.java:418)
	at kafka.network.RequestChannel.receiveRequest(RequestChannel.scala:237)
	at kafka.server.KafkaRequestHandler.run(KafkaRequestHandler.scala:50)
	at java.lang.Thread.run(Thread.java:745)

"kafka-request-handler-5" #65 daemon prio=5 os_prio=0 tid=0x00007f7b050c5000 nid=0xc53 waiting on condition [0x00007f792f9fa000]
   java.lang.Thread.State: TIMED_WAITING (parking)
	at sun.misc.Unsafe.park(Native Method)
	- parking to wait for  <0x0000000400676168> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject)
	at java.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:215)
	at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(AbstractQueuedSynchronizer.java:2078)
	at java.util.concurrent.ArrayBlockingQueue.poll(ArrayBlockingQueue.java:418)
	at kafka.network.RequestChannel.receiveRequest(RequestChannel.scala:237)
	at kafka.server.KafkaRequestHandler.run(KafkaRequestHandler.scala:50)
	at java.lang.Thread.run(Thread.java:745)

"kafka-request-handler-4" #64 daemon prio=5 os_prio=0 tid=0x00007f7b050c3000 nid=0xc52 waiting on condition [0x00007f792fafb000]
   java.lang.Thread.State: TIMED_WAITING (parking)
	at sun.misc.Unsafe.park(Native Method)
	- parking to wait for  <0x0000000400676168> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject)
	at java.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:215)
	at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(AbstractQueuedSynchronizer.java:2078)
	at java.util.concurrent.ArrayBlockingQueue.poll(ArrayBlockingQueue.java:418)
	at kafka.network.RequestChannel.receiveRequest(RequestChannel.scala:237)
	at kafka.server.KafkaRequestHandler.run(KafkaRequestHandler.scala:50)
	at java.lang.Thread.run(Thread.java:745)

"kafka-request-handler-3" #63 daemon prio=5 os_prio=0 tid=0x00007f7b050c1800 nid=0xc51 waiting on condition [0x00007f792fbfc000]
   java.lang.Thread.State: TIMED_WAITING (parking)
	at sun.misc.Unsafe.park(Native Method)
	- parking to wait for  <0x0000000400676168> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject)
	at java.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:215)
	at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(AbstractQueuedSynchronizer.java:2078)
	at java.util.concurrent.ArrayBlockingQueue.poll(ArrayBlockingQueue.java:418)
	at kafka.network.RequestChannel.receiveRequest(RequestChannel.scala:237)
	at kafka.server.KafkaRequestHandler.run(KafkaRequestHandler.scala:50)
	at java.lang.Thread.run(Thread.java:745)

"kafka-request-handler-2" #62 daemon prio=5 os_prio=0 tid=0x00007f7b050bf800 nid=0xc50 waiting on condition [0x00007f792fcfd000]
   java.lang.Thread.State: TIMED_WAITING (parking)
	at sun.misc.Unsafe.park(Native Method)
	- parking to wait for  <0x0000000400676168> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject)
	at java.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:215)
	at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(AbstractQueuedSynchronizer.java:2078)
	at java.util.concurrent.ArrayBlockingQueue.poll(ArrayBlockingQueue.java:418)
	at kafka.network.RequestChannel.receiveRequest(RequestChannel.scala:237)
	at kafka.server.KafkaRequestHandler.run(KafkaRequestHandler.scala:50)
	at java.lang.Thread.run(Thread.java:745)

"kafka-request-handler-1" #61 daemon prio=5 os_prio=0 tid=0x00007f7b050be000 nid=0xc4f waiting on condition [0x00007f792fdfe000]
   java.lang.Thread.State: TIMED_WAITING (parking)
	at sun.misc.Unsafe.park(Native Method)
	- parking to wait for  <0x0000000400676168> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject)
	at java.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:215)
	at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(AbstractQueuedSynchronizer.java:2078)
	at java.util.concurrent.ArrayBlockingQueue.poll(ArrayBlockingQueue.java:418)
	at kafka.network.RequestChannel.receiveRequest(RequestChannel.scala:237)
	at kafka.server.KafkaRequestHandler.run(KafkaRequestHandler.scala:50)
	at java.lang.Thread.run(Thread.java:745)

"kafka-request-handler-0" #60 daemon prio=5 os_prio=0 tid=0x00007f7b050cb800 nid=0xc4e waiting on condition [0x00007f7938bf8000]
   java.lang.Thread.State: TIMED_WAITING (parking)
	at sun.misc.Unsafe.park(Native Method)
	- parking to wait for  <0x0000000400676168> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject)
	at java.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:215)
	at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(AbstractQueuedSynchronizer.java:2078)
	at java.util.concurrent.ArrayBlockingQueue.poll(ArrayBlockingQueue.java:418)
	at kafka.network.RequestChannel.receiveRequest(RequestChannel.scala:237)
	at kafka.server.KafkaRequestHandler.run(KafkaRequestHandler.scala:50)
	at java.lang.Thread.run(Thread.java:745)

"group-metadata-manager-0" #59 daemon prio=5 os_prio=0 tid=0x00007f7b05091800 nid=0xc4d waiting on condition [0x00007f7938ef9000]
   java.lang.Thread.State: TIMED_WAITING (parking)
	at sun.misc.Unsafe.park(Native Method)
	- parking to wait for  <0x0000000400788788> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject)
	at java.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:215)
	at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(AbstractQueuedSynchronizer.java:2078)
	at java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:1093)
	at java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:809)
	at java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1067)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1127)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
	at java.lang.Thread.run(Thread.java:745)

"ExpirationReaper-73" #58 prio=5 os_prio=0 tid=0x00007f7b05085000 nid=0xc4c waiting on condition [0x00007f7938ffa000]
   java.lang.Thread.State: TIMED_WAITING (parking)
	at sun.misc.Unsafe.park(Native Method)
	- parking to wait for  <0x000000040076fa10> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject)
	at java.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:215)
	at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(AbstractQueuedSynchronizer.java:2078)
	at java.util.concurrent.DelayQueue.poll(DelayQueue.java:259)
	at kafka.utils.timer.SystemTimer.advanceClock(Timer.scala:105)
	at kafka.server.DelayedOperationPurgatory.advanceClock(DelayedOperation.scala:354)
	at kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper.doWork(DelayedOperation.scala:378)
	at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:63)

"ExpirationReaper-73" #57 prio=5 os_prio=0 tid=0x00007f7b05084000 nid=0xc4b waiting on condition [0x00007f79390fb000]
   java.lang.Thread.State: TIMED_WAITING (parking)
	at sun.misc.Unsafe.park(Native Method)
	- parking to wait for  <0x000000040077bc40> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject)
	at java.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:215)
	at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(AbstractQueuedSynchronizer.java:2078)
	at java.util.concurrent.DelayQueue.poll(DelayQueue.java:259)
	at kafka.utils.timer.SystemTimer.advanceClock(Timer.scala:105)
	at kafka.server.DelayedOperationPurgatory.advanceClock(DelayedOperation.scala:354)
	at kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper.doWork(DelayedOperation.scala:378)
	at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:63)

"ExpirationReaper-73" #56 prio=5 os_prio=0 tid=0x00007f7b0507f800 nid=0xc4a waiting on condition [0x00007f79391fc000]
   java.lang.Thread.State: TIMED_WAITING (parking)
	at sun.misc.Unsafe.park(Native Method)
	- parking to wait for  <0x000000040079bbf8> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject)
	at java.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:215)
	at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(AbstractQueuedSynchronizer.java:2078)
	at java.util.concurrent.DelayQueue.poll(DelayQueue.java:259)
	at kafka.utils.timer.SystemTimer.advanceClock(Timer.scala:105)
	at kafka.server.DelayedOperationPurgatory.advanceClock(DelayedOperation.scala:354)
	at kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper.doWork(DelayedOperation.scala:378)
	at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:63)

"delete-topics-thread-73" #55 prio=5 os_prio=0 tid=0x00007f7b05079000 nid=0xc49 waiting on condition [0x00007f79392fd000]
   java.lang.Thread.State: WAITING (parking)
	at sun.misc.Unsafe.park(Native Method)
	- parking to wait for  <0x0000000400774998> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject)
	at java.util.concurrent.locks.LockSupport.park(LockSupport.java:175)
	at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039)
	at kafka.controller.TopicDeletionManager.$anonfun$awaitTopicDeletionNotification$1(TopicDeletionManager.scala:238)
	at kafka.controller.TopicDeletionManager$$Lambda$488/109073917.apply$mcV$sp(Unknown Source)
	at scala.runtime.java8.JFunction0$mcV$sp.apply(JFunction0$mcV$sp.java:12)
	at kafka.utils.CoreUtils$.inLock(CoreUtils.scala:213)
	at kafka.controller.TopicDeletionManager.kafka$controller$TopicDeletionManager$$awaitTopicDeletionNotification(TopicDeletionManager.scala:236)
	at kafka.controller.TopicDeletionManager$DeleteTopicsThread.doWork(TopicDeletionManager.scala:404)
	at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:63)

"kafka-scheduler-0" #54 daemon prio=5 os_prio=0 tid=0x00007f7b05075000 nid=0xc48 waiting on condition [0x00007f79393fe000]
   java.lang.Thread.State: TIMED_WAITING (parking)
	at sun.misc.Unsafe.park(Native Method)
	- parking to wait for  <0x00000004007955f0> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject)
	at java.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:215)
	at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(AbstractQueuedSynchronizer.java:2078)
	at java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:1093)
	at java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:809)
	at java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1067)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1127)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
	at java.lang.Thread.run(Thread.java:745)

"kafka-scheduler-7" #53 daemon prio=5 os_prio=0 tid=0x00007f78e4002000 nid=0xc47 waiting on condition [0x00007f78e9f0f000]
   java.lang.Thread.State: WAITING (parking)
	at sun.misc.Unsafe.park(Native Method)
	- parking to wait for  <0x000000040022eec0> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject)
	at java.util.concurrent.locks.LockSupport.park(LockSupport.java:175)
	at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039)
	at java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:1088)
	at java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:809)
	at java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1067)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1127)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
	at java.lang.Thread.run(Thread.java:745)

"kafka-scheduler-6" #52 daemon prio=5 os_prio=0 tid=0x00007f78a4001800 nid=0xc46 waiting on condition [0x00007f78ea010000]
   java.lang.Thread.State: WAITING (parking)
	at sun.misc.Unsafe.park(Native Method)
	- parking to wait for  <0x000000040022eec0> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject)
	at java.util.concurrent.locks.LockSupport.park(LockSupport.java:175)
	at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039)
	at java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:1088)
	at java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:809)
	at java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1067)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1127)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
	at java.lang.Thread.run(Thread.java:745)

"kafka-scheduler-5" #51 daemon prio=5 os_prio=0 tid=0x00007f7b06088800 nid=0xc45 waiting on condition [0x00007f78ea111000]
   java.lang.Thread.State: WAITING (parking)
	at sun.misc.Unsafe.park(Native Method)
	- parking to wait for  <0x000000040022eec0> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject)
	at java.util.concurrent.locks.LockSupport.park(LockSupport.java:175)
	at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039)
	at java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:1088)
	at java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:809)
	at java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1067)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1127)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
	at java.lang.Thread.run(Thread.java:745)

"kafka-scheduler-4" #50 daemon prio=5 os_prio=0 tid=0x00007f7b06087000 nid=0xc44 waiting on condition [0x00007f78ea212000]
   java.lang.Thread.State: WAITING (parking)
	at sun.misc.Unsafe.park(Native Method)
	- parking to wait for  <0x000000040022eec0> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject)
	at java.util.concurrent.locks.LockSupport.park(LockSupport.java:175)
	at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039)
	at java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:1088)
	at java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:809)
	at java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1067)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1127)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
	at java.lang.Thread.run(Thread.java:745)

"metrics-meter-tick-thread-2" #49 daemon prio=5 os_prio=0 tid=0x00007f7b06084000 nid=0xc43 waiting on condition [0x00007f78ea313000]
   java.lang.Thread.State: WAITING (parking)
	at sun.misc.Unsafe.park(Native Method)
	- parking to wait for  <0x0000000400682ca0> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject)
	at java.util.concurrent.locks.LockSupport.park(LockSupport.java:175)
	at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039)
	at java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:1088)
	at java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:809)
	at java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1067)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1127)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
	at java.lang.Thread.run(Thread.java:745)

"ExpirationReaper-73" #48 prio=5 os_prio=0 tid=0x00007f7b06082000 nid=0xc42 waiting on condition [0x00007f78ea414000]
   java.lang.Thread.State: TIMED_WAITING (parking)
	at sun.misc.Unsafe.park(Native Method)
	- parking to wait for  <0x0000000400682f08> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject)
	at java.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:215)
	at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(AbstractQueuedSynchronizer.java:2078)
	at java.util.concurrent.DelayQueue.poll(DelayQueue.java:273)
	at kafka.utils.timer.SystemTimer.advanceClock(Timer.scala:105)
	at kafka.server.DelayedOperationPurgatory.advanceClock(DelayedOperation.scala:354)
	at kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper.doWork(DelayedOperation.scala:378)
	at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:63)

"ExpirationReaper-73" #47 prio=5 os_prio=0 tid=0x00007f7b0607e800 nid=0xc41 waiting on condition [0x00007f78ea515000]
   java.lang.Thread.State: TIMED_WAITING (parking)
	at sun.misc.Unsafe.park(Native Method)
	- parking to wait for  <0x0000000400674db8> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject)
	at java.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:215)
	at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(AbstractQueuedSynchronizer.java:2078)
	at java.util.concurrent.DelayQueue.poll(DelayQueue.java:268)
	at kafka.utils.timer.SystemTimer.advanceClock(Timer.scala:105)
	at kafka.server.DelayedOperationPurgatory.advanceClock(DelayedOperation.scala:354)
	at kafka.server.DelayedOperationPurgatory$ExpiredOperationReaper.doWork(DelayedOperation.scala:378)
	at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:63)

"kafka-socket-acceptor-ListenerName(PLAINTEXT)-PLAINTEXT-9092" #46 prio=5 os_prio=0 tid=0x00007f7b04955800 nid=0xc40 runnable [0x00007f78ea616000]
   java.lang.Thread.State: RUNNABLE
	at sun.nio.ch.EPollArrayWrapper.epollWait(Native Method)
	at sun.nio.ch.EPollArrayWrapper.poll(EPollArrayWrapper.java:269)
	at sun.nio.ch.EPollSelectorImpl.doSelect(EPollSelectorImpl.java:93)
	at sun.nio.ch.SelectorImpl.lockAndDoSelect(SelectorImpl.java:86)
	- locked <0x00000004006888d0> (a sun.nio.ch.Util$2)
	- locked <0x00000004006888c0> (a java.util.Collections$UnmodifiableSet)
	- locked <0x00000004006888e0> (a sun.nio.ch.EPollSelectorImpl)
	at sun.nio.ch.SelectorImpl.select(SelectorImpl.java:97)
	at kafka.network.Acceptor.run(SocketServer.scala:274)
	at java.lang.Thread.run(Thread.java:745)

"kafka-network-thread-73-ListenerName(PLAINTEXT)-PLAINTEXT-4" #45 prio=5 os_prio=0 tid=0x00007f7b053ed800 nid=0xc3f runnable [0x00007f78ea717000]
   java.lang.Thread.State: RUNNABLE
	at sun.nio.ch.EPollArrayWrapper.epollWait(Native Method)
	at sun.nio.ch.EPollArrayWrapper.poll(EPollArrayWrapper.java:269)
	at sun.nio.ch.EPollSelectorImpl.doSelect(EPollSelectorImpl.java:93)
	at sun.nio.ch.SelectorImpl.lockAndDoSelect(SelectorImpl.java:86)
	- locked <0x0000000400675f70> (a sun.nio.ch.Util$2)
	- locked <0x0000000400675f60> (a java.util.Collections$UnmodifiableSet)
	- locked <0x0000000400675f80> (a sun.nio.ch.EPollSelectorImpl)
	at sun.nio.ch.SelectorImpl.select(SelectorImpl.java:97)
	at org.apache.kafka.common.network.Selector.select(Selector.java:489)
	at org.apache.kafka.common.network.Selector.poll(Selector.java:298)
	at kafka.network.Processor.poll(SocketServer.scala:494)
	at kafka.network.Processor.run(SocketServer.scala:432)
	at java.lang.Thread.run(Thread.java:745)

"kafka-network-thread-73-ListenerName(PLAINTEXT)-PLAINTEXT-3" #44 prio=5 os_prio=0 tid=0x00007f7b053ec000 nid=0xc3e runnable [0x00007f78ea818000]
   java.lang.Thread.State: RUNNABLE
	at sun.nio.ch.EPollArrayWrapper.epollWait(Native Method)
	at sun.nio.ch.EPollArrayWrapper.poll(EPollArrayWrapper.java:269)
	at sun.nio.ch.EPollSelectorImpl.doSelect(EPollSelectorImpl.java:93)
	at sun.nio.ch.SelectorImpl.lockAndDoSelect(SelectorImpl.java:86)
	- locked <0x0000000400683190> (a sun.nio.ch.Util$2)
	- locked <0x0000000400683180> (a java.util.Collections$UnmodifiableSet)
	- locked <0x00000004006831a0> (a sun.nio.ch.EPollSelectorImpl)
	at sun.nio.ch.SelectorImpl.select(SelectorImpl.java:97)
	at org.apache.kafka.common.network.Selector.select(Selector.java:489)
	at org.apache.kafka.common.network.Selector.poll(Selector.java:298)
	at kafka.network.Processor.poll(SocketServer.scala:494)
	at kafka.network.Processor.run(SocketServer.scala:432)
	at java.lang.Thread.run(Thread.java:745)

"kafka-network-thread-73-ListenerName(PLAINTEXT)-PLAINTEXT-2" #43 prio=5 os_prio=0 tid=0x00007f7b053ea000 nid=0xc3d runnable [0x00007f78ea919000]
   java.lang.Thread.State: RUNNABLE
	at sun.nio.ch.EPollArrayWrapper.epollWait(Native Method)
	at sun.nio.ch.EPollArrayWrapper.poll(EPollArrayWrapper.java:269)
	at sun.nio.ch.EPollSelectorImpl.doSelect(EPollSelectorImpl.java:93)
	at sun.nio.ch.SelectorImpl.lockAndDoSelect(SelectorImpl.java:86)
	- locked <0x00000004006763d0> (a sun.nio.ch.Util$2)
	- locked <0x00000004006763c0> (a java.util.Collections$UnmodifiableSet)
	- locked <0x00000004006763e0> (a sun.nio.ch.EPollSelectorImpl)
	at sun.nio.ch.SelectorImpl.select(SelectorImpl.java:97)
	at org.apache.kafka.common.network.Selector.select(Selector.java:489)
	at org.apache.kafka.common.network.Selector.poll(Selector.java:298)
	at kafka.network.Processor.poll(SocketServer.scala:494)
	at kafka.network.Processor.run(SocketServer.scala:432)
	at java.lang.Thread.run(Thread.java:745)

"kafka-network-thread-73-ListenerName(PLAINTEXT)-PLAINTEXT-1" #42 prio=5 os_prio=0 tid=0x00007f7b053be800 nid=0xc3c runnable [0x00007f793a92b000]
   java.lang.Thread.State: RUNNABLE
	at sun.nio.ch.EPollArrayWrapper.epollWait(Native Method)
	at sun.nio.ch.EPollArrayWrapper.poll(EPollArrayWrapper.java:269)
	at sun.nio.ch.EPollSelectorImpl.doSelect(EPollSelectorImpl.java:93)
	at sun.nio.ch.SelectorImpl.lockAndDoSelect(SelectorImpl.java:86)
	- locked <0x0000000400686518> (a sun.nio.ch.Util$2)
	- locked <0x0000000400674ff0> (a java.util.Collections$UnmodifiableSet)
	- locked <0x0000000400686528> (a sun.nio.ch.EPollSelectorImpl)
	at sun.nio.ch.SelectorImpl.select(SelectorImpl.java:97)
	at org.apache.kafka.common.network.Selector.select(Selector.java:489)
	at org.apache.kafka.common.network.Selector.poll(Selector.java:298)
	at kafka.network.Processor.poll(SocketServer.scala:494)
	at kafka.network.Processor.run(SocketServer.scala:432)
	at java.lang.Thread.run(Thread.java:745)

"kafka-network-thread-73-ListenerName(PLAINTEXT)-PLAINTEXT-0" #41 prio=5 os_prio=0 tid=0x00007f7b053bc800 nid=0xc3b runnable [0x00007f793aa2c000]
   java.lang.Thread.State: RUNNABLE
	at sun.nio.ch.EPollArrayWrapper.epollWait(Native Method)
	at sun.nio.ch.EPollArrayWrapper.poll(EPollArrayWrapper.java:269)
	at sun.nio.ch.EPollSelectorImpl.doSelect(EPollSelectorImpl.java:93)
	at sun.nio.ch.SelectorImpl.lockAndDoSelect(SelectorImpl.java:86)
	- locked <0x00000004006766b0> (a sun.nio.ch.Util$2)
	- locked <0x00000004006766a0> (a java.util.Collections$UnmodifiableSet)
	- locked <0x00000004006766c0> (a sun.nio.ch.EPollSelectorImpl)
	at sun.nio.ch.SelectorImpl.select(SelectorImpl.java:97)
	at org.apache.kafka.common.network.Selector.select(Selector.java:489)
	at org.apache.kafka.common.network.Selector.poll(Selector.java:298)
	at kafka.network.Processor.poll(SocketServer.scala:494)
	at kafka.network.Processor.run(SocketServer.scala:432)
	at java.lang.Thread.run(Thread.java:745)

"kafka-log-cleaner-thread-0" #36 prio=5 os_prio=0 tid=0x00007f7b0534a000 nid=0xc3a waiting on condition [0x00007f793ab2d000]
   java.lang.Thread.State: TIMED_WAITING (parking)
	at sun.misc.Unsafe.park(Native Method)
	- parking to wait for  <0x00000004006832a0> (a java.util.concurrent.CountDownLatch$Sync)
	at java.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:215)
	at java.util.concurrent.locks.AbstractQueuedSynchronizer.doAcquireSharedNanos(AbstractQueuedSynchronizer.java:1037)
	at java.util.concurrent.locks.AbstractQueuedSynchronizer.tryAcquireSharedNanos(AbstractQueuedSynchronizer.java:1328)
	at java.util.concurrent.CountDownLatch.await(CountDownLatch.java:277)
	at kafka.log.LogCleaner$CleanerThread.cleanOrSleep(LogCleaner.scala:261)
	at kafka.log.LogCleaner$CleanerThread.doWork(LogCleaner.scala:220)
	at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:63)

"kafka-scheduler-3" #40 daemon prio=5 os_prio=0 tid=0x00007f7b05366000 nid=0xc39 waiting on condition [0x00007f793ac2e000]
   java.lang.Thread.State: TIMED_WAITING (parking)
	at sun.misc.Unsafe.park(Native Method)
	- parking to wait for  <0x000000040022eec0> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject)
	at java.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:215)
	at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(AbstractQueuedSynchronizer.java:2078)
	at java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:1093)
	at java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:809)
	at java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1067)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1127)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
	at java.lang.Thread.run(Thread.java:745)

"kafka-scheduler-2" #39 daemon prio=5 os_prio=0 tid=0x00007f7b05363800 nid=0xc38 waiting on condition [0x00007f793ad2f000]
   java.lang.Thread.State: WAITING (parking)
	at sun.misc.Unsafe.park(Native Method)
	- parking to wait for  <0x000000040022eec0> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject)
	at java.util.concurrent.locks.LockSupport.park(LockSupport.java:175)
	at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039)
	at java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:1088)
	at java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:809)
	at java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1067)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1127)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
	at java.lang.Thread.run(Thread.java:745)

"kafka-scheduler-1" #38 daemon prio=5 os_prio=0 tid=0x00007f7b05361800 nid=0xc37 waiting on condition [0x00007f793ae30000]
   java.lang.Thread.State: WAITING (parking)
	at sun.misc.Unsafe.park(Native Method)
	- parking to wait for  <0x000000040022eec0> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject)
	at java.util.concurrent.locks.LockSupport.park(LockSupport.java:175)
	at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039)
	at java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:1088)
	at java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:809)
	at java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1067)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1127)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
	at java.lang.Thread.run(Thread.java:745)

"kafka-scheduler-0" #37 daemon prio=5 os_prio=0 tid=0x00007f7b05360000 nid=0xc36 waiting on condition [0x00007f793af31000]
   java.lang.Thread.State: WAITING (parking)
	at sun.misc.Unsafe.park(Native Method)
	- parking to wait for  <0x000000040022eec0> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject)
	at java.util.concurrent.locks.LockSupport.park(LockSupport.java:175)
	at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039)
	at java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:1088)
	at java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:809)
	at java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1067)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1127)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
	at java.lang.Thread.run(Thread.java:745)

"metrics-meter-tick-thread-1" #35 daemon prio=5 os_prio=0 tid=0x00007f7b053a3000 nid=0xc35 waiting on condition [0x00007f79d5468000]
   java.lang.Thread.State: TIMED_WAITING (parking)
	at sun.misc.Unsafe.park(Native Method)
	- parking to wait for  <0x0000000400682ca0> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject)
	at java.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:215)
	at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(AbstractQueuedSynchronizer.java:2078)
	at java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:1093)
	at java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:809)
	at java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1067)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1127)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
	at java.lang.Thread.run(Thread.java:745)

"ThrottledRequestReaper-Produce" #33 prio=5 os_prio=0 tid=0x00007f7b06235000 nid=0xfb6b waiting on condition [0x00007f79d5769000]
   java.lang.Thread.State: TIMED_WAITING (parking)
	at sun.misc.Unsafe.park(Native Method)
	- parking to wait for  <0x00000004004001a0> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject)
	at java.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:215)
	at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(AbstractQueuedSynchronizer.java:2078)
	at java.util.concurrent.DelayQueue.poll(DelayQueue.java:259)
	at kafka.server.ClientQuotaManager$ThrottledRequestReaper.doWork(ClientQuotaManager.scala:158)
	at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:63)

"ThrottledRequestReaper-Fetch" #32 prio=5 os_prio=0 tid=0x00007f7b06233800 nid=0xfb6a waiting on condition [0x00007f79d586a000]
   java.lang.Thread.State: TIMED_WAITING (parking)
	at sun.misc.Unsafe.park(Native Method)
	- parking to wait for  <0x0000000400400388> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject)
	at java.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:215)
	at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(AbstractQueuedSynchronizer.java:2078)
	at java.util.concurrent.DelayQueue.poll(DelayQueue.java:259)
	at kafka.server.ClientQuotaManager$ThrottledRequestReaper.doWork(ClientQuotaManager.scala:158)
	at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:63)

"SensorExpiryThread" #31 daemon prio=5 os_prio=0 tid=0x00007f7b0622c800 nid=0xfb69 waiting on condition [0x00007f79d596b000]
   java.lang.Thread.State: TIMED_WAITING (parking)
	at sun.misc.Unsafe.park(Native Method)
	- parking to wait for  <0x0000000400400548> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject)
	at java.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:215)
	at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(AbstractQueuedSynchronizer.java:2078)
	at java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:1093)
	at java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:809)
	at java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1067)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1127)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
	at java.lang.Thread.run(Thread.java:745)

"main-EventThread" #30 daemon prio=5 os_prio=0 tid=0x00007f7b061ba000 nid=0xfb68 waiting on condition [0x00007f79d5c6c000]
   java.lang.Thread.State: WAITING (parking)
	at sun.misc.Unsafe.park(Native Method)
	- parking to wait for  <0x0000000400060e10> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject)
	at java.util.concurrent.locks.LockSupport.park(LockSupport.java:175)
	at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039)
	at java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442)
	at org.apache.zookeeper.ClientCnxn$EventThread.run(ClientCnxn.java:501)

"main-SendThread(10.52.208.73:2181)" #29 daemon prio=5 os_prio=0 tid=0x00007f7b06193800 nid=0xfb67 runnable [0x00007f79d5d6d000]
   java.lang.Thread.State: RUNNABLE
	at sun.nio.ch.EPollArrayWrapper.epollWait(Native Method)
	at sun.nio.ch.EPollArrayWrapper.poll(EPollArrayWrapper.java:269)
	at sun.nio.ch.EPollSelectorImpl.doSelect(EPollSelectorImpl.java:93)
	at sun.nio.ch.SelectorImpl.lockAndDoSelect(SelectorImpl.java:86)
	- locked <0x00000004000695a0> (a sun.nio.ch.Util$2)
	- locked <0x00000004000695b0> (a java.util.Collections$UnmodifiableSet)
	- locked <0x0000000400060ee0> (a sun.nio.ch.EPollSelectorImpl)
	at sun.nio.ch.SelectorImpl.select(SelectorImpl.java:97)
	at org.apache.zookeeper.ClientCnxnSocketNIO.doTransport(ClientCnxnSocketNIO.java:349)
	at org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1141)

"ZkClient-EventThread-28-10.52.208.72:2181,10.52.208.73:2181,10.52.208.74:2181" #28 daemon prio=5 os_prio=0 tid=0x00007f7b0618b800 nid=0xfb66 waiting on condition [0x00007f79e81c5000]
   java.lang.Thread.State: WAITING (parking)
	at sun.misc.Unsafe.park(Native Method)
	- parking to wait for  <0x0000000400069840> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject)
	at java.util.concurrent.locks.LockSupport.park(LockSupport.java:175)
	at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039)
	at java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442)
	at org.I0Itec.zkclient.ZkEventThread.run(ZkEventThread.java:68)

"RMI TCP Accept-0" #25 daemon prio=5 os_prio=0 tid=0x00007f7b046f3000 nid=0xfb64 runnable [0x00007f79e85c7000]
   java.lang.Thread.State: RUNNABLE
	at java.net.PlainSocketImpl.socketAccept(Native Method)
	at java.net.AbstractPlainSocketImpl.accept(AbstractPlainSocketImpl.java:409)
	at java.net.ServerSocket.implAccept(ServerSocket.java:545)
	at java.net.ServerSocket.accept(ServerSocket.java:513)
	at sun.management.jmxremote.LocalRMIServerSocketFactory$1.accept(LocalRMIServerSocketFactory.java:52)
	at sun.rmi.transport.tcp.TCPTransport$AcceptLoop.executeAcceptLoop(TCPTransport.java:400)
	at sun.rmi.transport.tcp.TCPTransport$AcceptLoop.run(TCPTransport.java:372)
	at java.lang.Thread.run(Thread.java:745)

"RMI TCP Accept-9999" #24 daemon prio=5 os_prio=0 tid=0x00007f7b046d6000 nid=0xfb63 runnable [0x00007f79e86c8000]
   java.lang.Thread.State: RUNNABLE
	at java.net.PlainSocketImpl.socketAccept(Native Method)
	at java.net.AbstractPlainSocketImpl.accept(AbstractPlainSocketImpl.java:409)
	at java.net.ServerSocket.implAccept(ServerSocket.java:545)
	at java.net.ServerSocket.accept(ServerSocket.java:513)
	at sun.rmi.transport.tcp.TCPTransport$AcceptLoop.executeAcceptLoop(TCPTransport.java:400)
	at sun.rmi.transport.tcp.TCPTransport$AcceptLoop.run(TCPTransport.java:372)
	at java.lang.Thread.run(Thread.java:745)

"RMI TCP Accept-0" #23 daemon prio=5 os_prio=0 tid=0x00007f7b046c1800 nid=0xfb62 runnable [0x00007f79e87c9000]
   java.lang.Thread.State: RUNNABLE
	at java.net.PlainSocketImpl.socketAccept(Native Method)
	at java.net.AbstractPlainSocketImpl.accept(AbstractPlainSocketImpl.java:409)
	at java.net.ServerSocket.implAccept(ServerSocket.java:545)
	at java.net.ServerSocket.accept(ServerSocket.java:513)
	at sun.rmi.transport.tcp.TCPTransport$AcceptLoop.executeAcceptLoop(TCPTransport.java:400)
	at sun.rmi.transport.tcp.TCPTransport$AcceptLoop.run(TCPTransport.java:372)
	at java.lang.Thread.run(Thread.java:745)

"Service Thread" #21 daemon prio=9 os_prio=0 tid=0x00007f7b043a4000 nid=0xfb5e runnable [0x0000000000000000]
   java.lang.Thread.State: RUNNABLE

"C1 CompilerThread14" #20 daemon prio=9 os_prio=0 tid=0x00007f7b04398800 nid=0xfb5d waiting on condition [0x0000000000000000]
   java.lang.Thread.State: RUNNABLE

"C1 CompilerThread13" #19 daemon prio=9 os_prio=0 tid=0x00007f7b04396800 nid=0xfb5c waiting on condition [0x0000000000000000]
   java.lang.Thread.State: RUNNABLE

"C1 CompilerThread12" #18 daemon prio=9 os_prio=0 tid=0x00007f7b04394000 nid=0xfb5b waiting on condition [0x0000000000000000]
   java.lang.Thread.State: RUNNABLE

"C1 CompilerThread11" #17 daemon prio=9 os_prio=0 tid=0x00007f7b04392000 nid=0xfb5a waiting on condition [0x0000000000000000]
   java.lang.Thread.State: RUNNABLE

"C1 CompilerThread10" #16 daemon prio=9 os_prio=0 tid=0x00007f7b04390000 nid=0xfb59 waiting on condition [0x0000000000000000]
   java.lang.Thread.State: RUNNABLE

"C2 CompilerThread9" #15 daemon prio=9 os_prio=0 tid=0x00007f7b0438d000 nid=0xfb58 waiting on condition [0x0000000000000000]
   java.lang.Thread.State: RUNNABLE

"C2 CompilerThread8" #14 daemon prio=9 os_prio=0 tid=0x00007f7b0438b000 nid=0xfb57 waiting on condition [0x0000000000000000]
   java.lang.Thread.State: RUNNABLE

"C2 CompilerThread7" #13 daemon prio=9 os_prio=0 tid=0x00007f7b04388800 nid=0xfb56 waiting on condition [0x0000000000000000]
   java.lang.Thread.State: RUNNABLE

"C2 CompilerThread6" #12 daemon prio=9 os_prio=0 tid=0x00007f7b04386800 nid=0xfb55 waiting on condition [0x0000000000000000]
   java.lang.Thread.State: RUNNABLE

"C2 CompilerThread5" #11 daemon prio=9 os_prio=0 tid=0x00007f7b04384000 nid=0xfb54 waiting on condition [0x0000000000000000]
   java.lang.Thread.State: RUNNABLE

"C2 CompilerThread4" #10 daemon prio=9 os_prio=0 tid=0x00007f7b04382000 nid=0xfb53 waiting on condition [0x0000000000000000]
   java.lang.Thread.State: RUNNABLE

"C2 CompilerThread3" #9 daemon prio=9 os_prio=0 tid=0x00007f7b0437f800 nid=0xfb52 waiting on condition [0x0000000000000000]
   java.lang.Thread.State: RUNNABLE

"C2 CompilerThread2" #8 daemon prio=9 os_prio=0 tid=0x00007f7b0437d800 nid=0xfb51 waiting on condition [0x0000000000000000]
   java.lang.Thread.State: RUNNABLE

"C2 CompilerThread1" #7 daemon prio=9 os_prio=0 tid=0x00007f7b0437b800 nid=0xfb50 waiting on condition [0x0000000000000000]
   java.lang.Thread.State: RUNNABLE

"C2 CompilerThread0" #6 daemon prio=9 os_prio=0 tid=0x00007f7b04379000 nid=0xfb4f waiting on condition [0x0000000000000000]
   java.lang.Thread.State: RUNNABLE

"Signal Dispatcher" #5 daemon prio=9 os_prio=0 tid=0x00007f7b04377000 nid=0xfb4e runnable [0x0000000000000000]
   java.lang.Thread.State: RUNNABLE

"Surrogate Locker Thread (Concurrent GC)" #4 daemon prio=9 os_prio=0 tid=0x00007f7b04375800 nid=0xfb4d waiting on condition [0x0000000000000000]
   java.lang.Thread.State: RUNNABLE

"Finalizer" #3 daemon prio=8 os_prio=0 tid=0x00007f7b04342800 nid=0xfb4c in Object.wait() [0x00007f79ea182000]
   java.lang.Thread.State: WAITING (on object monitor)
	at java.lang.Object.wait(Native Method)
	at java.lang.ref.ReferenceQueue.remove(ReferenceQueue.java:143)
	- locked <0x000000040006acf8> (a java.lang.ref.ReferenceQueue$Lock)
	at java.lang.ref.ReferenceQueue.remove(ReferenceQueue.java:164)
	at java.lang.ref.Finalizer$FinalizerThread.run(Finalizer.java:209)

"Reference Handler" #2 daemon prio=10 os_prio=0 tid=0x00007f7b0433e000 nid=0xfb4b in Object.wait() [0x00007f79ea283000]
   java.lang.Thread.State: WAITING (on object monitor)
	at java.lang.Object.wait(Native Method)
	at java.lang.Object.wait(Object.java:502)
	at java.lang.ref.Reference.tryHandlePending(Reference.java:191)
	- locked <0x000000040006ad38> (a java.lang.ref.Reference$Lock)
	at java.lang.ref.Reference$ReferenceHandler.run(Reference.java:153)

"main" #1 prio=5 os_prio=0 tid=0x00007f7b0400d000 nid=0xfb13 waiting on condition [0x00007f7b0a4e4000]
   java.lang.Thread.State: WAITING (parking)
	at sun.misc.Unsafe.park(Native Method)
	- parking to wait for  <0x00000004007956b8> (a java.util.concurrent.CountDownLatch$Sync)
	at java.util.concurrent.locks.LockSupport.park(LockSupport.java:175)
	at java.util.concurrent.locks.AbstractQueuedSynchronizer.parkAndCheckInterrupt(AbstractQueuedSynchronizer.java:836)
	at java.util.concurrent.locks.AbstractQueuedSynchronizer.doAcquireSharedInterruptibly(AbstractQueuedSynchronizer.java:997)
	at java.util.concurrent.locks.AbstractQueuedSynchronizer.acquireSharedInterruptibly(AbstractQueuedSynchronizer.java:1304)
	at java.util.concurrent.CountDownLatch.await(CountDownLatch.java:231)
	at kafka.server.KafkaServer.awaitShutdown(KafkaServer.scala:624)
	at kafka.server.KafkaServerStartable.awaitShutdown(KafkaServerStartable.scala:70)
	at kafka.Kafka$.main(Kafka.scala:68)
	at kafka.Kafka.main(Kafka.scala)

"VM Thread" os_prio=0 tid=0x00007f7b04336000 nid=0xfb4a runnable 

"Gang worker#0 (Parallel GC Threads)" os_prio=0 tid=0x00007f7b04025000 nid=0xfb14 runnable 

"Gang worker#1 (Parallel GC Threads)" os_prio=0 tid=0x00007f7b04027000 nid=0xfb15 runnable 

"Gang worker#2 (Parallel GC Threads)" os_prio=0 tid=0x00007f7b04029000 nid=0xfb16 runnable 

"Gang worker#3 (Parallel GC Threads)" os_prio=0 tid=0x00007f7b0402a800 nid=0xfb17 runnable 

"Gang worker#4 (Parallel GC Threads)" os_prio=0 tid=0x00007f7b0402c800 nid=0xfb18 runnable 

"Gang worker#5 (Parallel GC Threads)" os_prio=0 tid=0x00007f7b0402e800 nid=0xfb19 runnable 

"Gang worker#6 (Parallel GC Threads)" os_prio=0 tid=0x00007f7b04030000 nid=0xfb1a runnable 

"Gang worker#7 (Parallel GC Threads)" os_prio=0 tid=0x00007f7b04032000 nid=0xfb1b runnable 

"Gang worker#8 (Parallel GC Threads)" os_prio=0 tid=0x00007f7b04034000 nid=0xfb1c runnable 

"Gang worker#9 (Parallel GC Threads)" os_prio=0 tid=0x00007f7b04035800 nid=0xfb1d runnable 

"Gang worker#10 (Parallel GC Threads)" os_prio=0 tid=0x00007f7b04037800 nid=0xfb1e runnable 

"Gang worker#11 (Parallel GC Threads)" os_prio=0 tid=0x00007f7b04039000 nid=0xfb1f runnable 

"Gang worker#12 (Parallel GC Threads)" os_prio=0 tid=0x00007f7b0403b000 nid=0xfb20 runnable 

"Gang worker#13 (Parallel GC Threads)" os_prio=0 tid=0x00007f7b0403d000 nid=0xfb21 runnable 

"Gang worker#14 (Parallel GC Threads)" os_prio=0 tid=0x00007f7b0403e800 nid=0xfb22 runnable 

"Gang worker#15 (Parallel GC Threads)" os_prio=0 tid=0x00007f7b04040800 nid=0xfb23 runnable 

"Gang worker#16 (Parallel GC Threads)" os_prio=0 tid=0x00007f7b04042800 nid=0xfb24 runnable 

"Gang worker#17 (Parallel GC Threads)" os_prio=0 tid=0x00007f7b04044000 nid=0xfb25 runnable 

"Gang worker#18 (Parallel GC Threads)" os_prio=0 tid=0x00007f7b04046000 nid=0xfb26 runnable 

"Gang worker#19 (Parallel GC Threads)" os_prio=0 tid=0x00007f7b04047800 nid=0xfb27 runnable 

"Gang worker#20 (Parallel GC Threads)" os_prio=0 tid=0x00007f7b04049800 nid=0xfb28 runnable 

"Gang worker#21 (Parallel GC Threads)" os_prio=0 tid=0x00007f7b0404b800 nid=0xfb29 runnable 

"Gang worker#22 (Parallel GC Threads)" os_prio=0 tid=0x00007f7b0404d000 nid=0xfb2a runnable 

"G1 Main Concurrent Mark GC Thread" os_prio=0 tid=0x00007f7b0408f000 nid=0xfb43 runnable 

"Gang worker#0 (G1 Parallel Marking Threads)" os_prio=0 tid=0x00007f7b04090800 nid=0xfb44 runnable 

"Gang worker#1 (G1 Parallel Marking Threads)" os_prio=0 tid=0x00007f7b04092800 nid=0xfb45 runnable 

"Gang worker#2 (G1 Parallel Marking Threads)" os_prio=0 tid=0x00007f7b04094800 nid=0xfb46 runnable 

"Gang worker#3 (G1 Parallel Marking Threads)" os_prio=0 tid=0x00007f7b04096000 nid=0xfb47 runnable 

"Gang worker#4 (G1 Parallel Marking Threads)" os_prio=0 tid=0x00007f7b04098000 nid=0xfb48 runnable 

"Gang worker#5 (G1 Parallel Marking Threads)" os_prio=0 tid=0x00007f7b0409a000 nid=0xfb49 runnable 

"G1 Concurrent Refinement Thread#0" os_prio=0 tid=0x00007f7b0407b000 nid=0xfb42 runnable 

"G1 Concurrent Refinement Thread#1" os_prio=0 tid=0x00007f7b04079800 nid=0xfb41 runnable 

"G1 Concurrent Refinement Thread#2" os_prio=0 tid=0x00007f7b04077800 nid=0xfb40 runnable 

"G1 Concurrent Refinement Thread#3" os_prio=0 tid=0x00007f7b04075800 nid=0xfb3f runnable 

"G1 Concurrent Refinement Thread#4" os_prio=0 tid=0x00007f7b04074000 nid=0xfb3e runnable 

"G1 Concurrent Refinement Thread#5" os_prio=0 tid=0x00007f7b04072000 nid=0xfb3d runnable 

"G1 Concurrent Refinement Thread#6" os_prio=0 tid=0x00007f7b04070000 nid=0xfb3c runnable 

"G1 Concurrent Refinement Thread#7" os_prio=0 tid=0x00007f7b0406e800 nid=0xfb3b runnable 

"G1 Concurrent Refinement Thread#8" os_prio=0 tid=0x00007f7b0406c800 nid=0xfb3a runnable 

"G1 Concurrent Refinement Thread#9" os_prio=0 tid=0x00007f7b0406a800 nid=0xfb39 runnable 

"G1 Concurrent Refinement Thread#10" os_prio=0 tid=0x00007f7b04069000 nid=0xfb38 runnable 

"G1 Concurrent Refinement Thread#11" os_prio=0 tid=0x00007f7b04067000 nid=0xfb37 runnable 

"G1 Concurrent Refinement Thread#12" os_prio=0 tid=0x00007f7b04065000 nid=0xfb36 runnable 

"G1 Concurrent Refinement Thread#13" os_prio=0 tid=0x00007f7b04063000 nid=0xfb35 runnable 

"G1 Concurrent Refinement Thread#14" os_prio=0 tid=0x00007f7b04061800 nid=0xfb34 runnable 

"G1 Concurrent Refinement Thread#15" os_prio=0 tid=0x00007f7b0405f800 nid=0xfb33 runnable 

"G1 Concurrent Refinement Thread#16" os_prio=0 tid=0x00007f7b0405d800 nid=0xfb32 runnable 

"G1 Concurrent Refinement Thread#17" os_prio=0 tid=0x00007f7b0405c000 nid=0xfb31 runnable 

"G1 Concurrent Refinement Thread#18" os_prio=0 tid=0x00007f7b0405a000 nid=0xfb30 runnable 

"G1 Concurrent Refinement Thread#19" os_prio=0 tid=0x00007f7b04058000 nid=0xfb2f runnable 

"G1 Concurrent Refinement Thread#20" os_prio=0 tid=0x00007f7b04056800 nid=0xfb2e runnable 

"G1 Concurrent Refinement Thread#21" os_prio=0 tid=0x00007f7b04054800 nid=0xfb2d runnable 

"G1 Concurrent Refinement Thread#22" os_prio=0 tid=0x00007f7b04052800 nid=0xfb2c runnable 

"G1 Concurrent Refinement Thread#23" os_prio=0 tid=0x00007f7b04051000 nid=0xfb2b runnable 

"VM Periodic Task Thread" os_prio=0 tid=0x00007f7b046f5000 nid=0xfb65 waiting on condition 

JNI global references: 2536