pool-3-thread-26" Id=74 WAITING on
java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject@424fc8ad
at sun.misc.Unsafe.park(Native Method)
at java.util.concurrent.locks.LockSupport.park(LockSupport.java:186)
at
java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2043)
at
java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442)
at kafka.consumer.ConsumerIterator.makeNext(ConsumerIterator.scala:63)
at kafka.consumer.ConsumerIterator.makeNext(ConsumerIterator.scala:33)
at
kafka.utils.IteratorTemplate.maybeComputeNext(IteratorTemplate.scala:61)
at kafka.utils.IteratorTemplate.hasNext(IteratorTemplate.scala:53)
at scala.collection.Iterator$class.foreach(Iterator.scala:631)
at kafka.utils.IteratorTemplate.foreach(IteratorTemplate.scala:32)
-----Original Message-----
From: Joel Koshy [mailto:[email protected]]
Sent: Wednesday, August 14, 2013 6:01 PM
To: [email protected]
Subject: Re: Blocking on Consumer Iterator blocking queue
I don't think this mailing list takes attachments. Can you provide more details
and paste your threaddump?
Thanks,
Joel
On Wed, Aug 14, 2013 at 1:50 PM, Seshadri, Balaji <[email protected]>
wrote:
> We are getting hanged on consumer side when we try to consume data
> using Scala API.
>
>
> We found it when we did load test.Attaching thread dump,please let us
> know if we have any fix.
>
>
>
> Thanks,
>
>
>
> Balaji
>
>
