Skip to content

Instantly share code, notes, and snippets.

Embed
What would you like to do?
The following non-daemon threads are still running (DestroyJavaVM is OK):
Thread[ProducerSendThread-,5,main], stackTrace:sun.misc.Unsafe#park
java.util.concurrent.locks.LockSupport#parkNanos at line:226
java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject#awaitNanos at line:2082
java.util.concurrent.LinkedBlockingQueue#poll at line:467
kafka.producer.async.ProducerSendThread$$anonfun$processEvents$1#apply at line:65
kafka.producer.async.ProducerSendThread$$anonfun$processEvents$1#apply at line:65
scala.collection.immutable.Stream$#continually at line:1104
scala.collection.immutable.Stream$$anonfun$continually$1#apply at line:1104
scala.collection.immutable.Stream$$anonfun$continually$1#apply at line:1104
scala.collection.immutable.Stream$Cons#tail at line:1060
scala.collection.immutable.Stream$Cons#tail at line:1052
scala.collection.immutable.Stream$$anonfun$takeWhile$1#apply at line:782
scala.collection.immutable.Stream$$anonfun$takeWhile$1#apply at line:782
scala.collection.immutable.Stream$Cons#tail at line:1060
scala.collection.immutable.Stream$Cons#tail at line:1052
scala.collection.immutable.Stream#foreach at line:527
kafka.producer.async.ProducerSendThread#processEvents at line:66
kafka.producer.async.ProducerSendThread#run at line:44
Thread[pool-2-thread-2,5,main], stackTrace:sun.misc.Unsafe#park
java.util.concurrent.locks.LockSupport#park at line:186
java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject#await at line:2043
com.lmax.disruptor.BlockingWaitStrategy#waitFor at line:45
com.lmax.disruptor.ProcessingSequenceBarrier#waitFor at line:55
com.lmax.disruptor.WorkProcessor#run at line:143
java.util.concurrent.ThreadPoolExecutor#runWorker at line:1145
java.util.concurrent.ThreadPoolExecutor$Worker#run at line:615
java.lang.Thread#run at line:724
Thread[ProducerSendThread-,5,main], stackTrace:sun.misc.Unsafe#park
java.util.concurrent.locks.LockSupport#parkNanos at line:226
java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject#awaitNanos at line:2082
java.util.concurrent.LinkedBlockingQueue#poll at line:467
kafka.producer.async.ProducerSendThread$$anonfun$processEvents$1#apply at line:65
kafka.producer.async.ProducerSendThread$$anonfun$processEvents$1#apply at line:65
scala.collection.immutable.Stream$#continually at line:1104
scala.collection.immutable.Stream$$anonfun$continually$1#apply at line:1104
scala.collection.immutable.Stream$$anonfun$continually$1#apply at line:1104
scala.collection.immutable.Stream$Cons#tail at line:1060
scala.collection.immutable.Stream$Cons#tail at line:1052
scala.collection.immutable.Stream$$anonfun$takeWhile$1#apply at line:782
scala.collection.immutable.Stream$$anonfun$takeWhile$1#apply at line:782
scala.collection.immutable.Stream$Cons#tail at line:1060
scala.collection.immutable.Stream$Cons#tail at line:1052
scala.collection.immutable.Stream#foreach at line:527
kafka.producer.async.ProducerSendThread#processEvents at line:66
kafka.producer.async.ProducerSendThread#run at line:44
Thread[pool-2-thread-1,5,main], stackTrace:sun.misc.Unsafe#park
java.util.concurrent.locks.LockSupport#park at line:186
java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject#await at line:2043
com.lmax.disruptor.BlockingWaitStrategy#waitFor at line:45
com.lmax.disruptor.ProcessingSequenceBarrier#waitFor at line:55
com.lmax.disruptor.WorkProcessor#run at line:143
java.util.concurrent.ThreadPoolExecutor#runWorker at line:1145
java.util.concurrent.ThreadPoolExecutor$Worker#run at line:615
java.lang.Thread#run at line:724
Thread[ProducerSendThread-,5,main], stackTrace:sun.misc.Unsafe#park
java.util.concurrent.locks.LockSupport#parkNanos at line:226
java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject#awaitNanos at line:2082
java.util.concurrent.LinkedBlockingQueue#poll at line:467
kafka.producer.async.ProducerSendThread$$anonfun$processEvents$1#apply at line:65
kafka.producer.async.ProducerSendThread$$anonfun$processEvents$1#apply at line:65
scala.collection.immutable.Stream$#continually at line:1104
scala.collection.immutable.Stream$$anonfun$continually$1#apply at line:1104
scala.collection.immutable.Stream$$anonfun$continually$1#apply at line:1104
scala.collection.immutable.Stream$Cons#tail at line:1060
scala.collection.immutable.Stream$Cons#tail at line:1052
scala.collection.immutable.Stream$$anonfun$takeWhile$1#apply at line:782
scala.collection.immutable.Stream$$anonfun$takeWhile$1#apply at line:782
scala.collection.immutable.Stream$Cons#tail at line:1060
scala.collection.immutable.Stream$Cons#tail at line:1052
scala.collection.immutable.Stream#foreach at line:527
kafka.producer.async.ProducerSendThread#processEvents at line:66
kafka.producer.async.ProducerSendThread#run at line:44
Thread[ProducerSendThread-,5,main], stackTrace:sun.misc.Unsafe#park
java.util.concurrent.locks.LockSupport#parkNanos at line:226
java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject#awaitNanos at line:2082
java.util.concurrent.LinkedBlockingQueue#poll at line:467
kafka.producer.async.ProducerSendThread$$anonfun$processEvents$1#apply at line:65
kafka.producer.async.ProducerSendThread$$anonfun$processEvents$1#apply at line:65
scala.collection.immutable.Stream$#continually at line:1104
scala.collection.immutable.Stream$$anonfun$continually$1#apply at line:1104
scala.collection.immutable.Stream$$anonfun$continually$1#apply at line:1104
scala.collection.immutable.Stream$Cons#tail at line:1060
scala.collection.immutable.Stream$Cons#tail at line:1052
scala.collection.immutable.Stream$$anonfun$takeWhile$1#apply at line:782
scala.collection.immutable.Stream$$anonfun$takeWhile$1#apply at line:782
scala.collection.immutable.Stream$Cons#tail at line:1060
scala.collection.immutable.Stream$Cons#tail at line:1052
scala.collection.immutable.Stream#foreach at line:527
kafka.producer.async.ProducerSendThread#processEvents at line:66
kafka.producer.async.ProducerSendThread#run at line:44
Thread[ProducerSendThread-,5,main], stackTrace:sun.misc.Unsafe#park
java.util.concurrent.locks.LockSupport#parkNanos at line:226
java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject#awaitNanos at line:2082
java.util.concurrent.LinkedBlockingQueue#poll at line:467
kafka.producer.async.ProducerSendThread$$anonfun$processEvents$1#apply at line:65
kafka.producer.async.ProducerSendThread$$anonfun$processEvents$1#apply at line:65
scala.collection.immutable.Stream$#continually at line:1104
scala.collection.immutable.Stream$$anonfun$continually$1#apply at line:1104
scala.collection.immutable.Stream$$anonfun$continually$1#apply at line:1104
scala.collection.immutable.Stream$Cons#tail at line:1060
scala.collection.immutable.Stream$Cons#tail at line:1052
scala.collection.immutable.Stream$$anonfun$takeWhile$1#apply at line:782
scala.collection.immutable.Stream$$anonfun$takeWhile$1#apply at line:782
scala.collection.immutable.Stream$Cons#tail at line:1060
scala.collection.immutable.Stream$Cons#tail at line:1052
scala.collection.immutable.Stream#foreach at line:527
kafka.producer.async.ProducerSendThread#processEvents at line:66
kafka.producer.async.ProducerSendThread#run at line:44
Thread[DestroyJavaVM,5,main], stackTrace:
Thread[ProducerSendThread-,5,main], stackTrace:sun.misc.Unsafe#park
java.util.concurrent.locks.LockSupport#parkNanos at line:226
java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject#awaitNanos at line:2082
java.util.concurrent.LinkedBlockingQueue#poll at line:467
kafka.producer.async.ProducerSendThread$$anonfun$processEvents$1#apply at line:65
kafka.producer.async.ProducerSendThread$$anonfun$processEvents$1#apply at line:65
scala.collection.immutable.Stream$#continually at line:1104
scala.collection.immutable.Stream$$anonfun$continually$1#apply at line:1104
scala.collection.immutable.Stream$$anonfun$continually$1#apply at line:1104
scala.collection.immutable.Stream$Cons#tail at line:1060
scala.collection.immutable.Stream$Cons#tail at line:1052
scala.collection.immutable.Stream$$anonfun$takeWhile$1#apply at line:782
scala.collection.immutable.Stream$$anonfun$takeWhile$1#apply at line:782
scala.collection.immutable.Stream$Cons#tail at line:1060
scala.collection.immutable.Stream$Cons#tail at line:1052
scala.collection.immutable.Stream#foreach at line:527
kafka.producer.async.ProducerSendThread#processEvents at line:66
kafka.producer.async.ProducerSendThread#run at line:44
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
You can’t perform that action at this time.