We see WAITING state in all our thread dumps. We did see data in Kafka but consumer is not able to consume.
-----Original Message----- From: Seshadri, Balaji [mailto:balaji.sesha...@dish.com] Sent: Wednesday, August 14, 2013 8:29 PM To: users@kafka.apache.org Subject: RE: Blocking on Consumer Iterator blocking queue 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:jjkosh...@gmail.com] Sent: Wednesday, August 14, 2013 6:01 PM To: users@kafka.apache.org 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 <balaji.sesha...@dish.com> 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 > >
