Kafka, mail # user - Re: Kafka consumer not consuming events - 2013-07-10, 16:18
 Search Hadoop and all its subprojects:

Switch to Plain View
Jun Rao 2013-07-22, 05:22
Nihit Purwar 2013-07-09, 11:19
Jun Rao 2013-07-09, 15:03
Nihit Purwar 2013-07-09, 15:38
Jun Rao 2013-07-10, 03:43
Nihit Purwar 2013-07-10, 06:12
Jun Rao 2013-07-10, 15:00
Nihit Purwar 2013-07-10, 15:31
Copy link to this message
Re: Kafka consumer not consuming events
The weird part is this. If the consumers are consuming, the following
fetcher thread shouldn't be blocked on enqueuing the data. Could you turn
on TRACE level logging in kafka.server.KafkaRequestHandlers and if there is
any fetch requests issued to the broker when the consumer threads get stuck?

"FetchRunnable-1" prio=10 tid=0x00007fcbc902b800 nid=0x2064 waiting on
condition [0x00007fcb833eb000]
   java.lang.Thread.State: WAITING (parking)
        at sun.misc.Unsafe.park(Native Method)
        - parking to wait for  <0x00000006809e8000> (a
        at java.util.concurrent.locks.LockSupport.park(LockSupport.java:156)
        at java.util.concurrent.LinkedBlockingQueue.put(
        at kafka.consumer.PartitionTopicInfo.enqueue(
        at kafka.consumer.FetcherRunnable$$anonfun$run$
        at kafka.consumer.FetcherRunnable$$anonfun$run$
        at scala.collection.LinearSeqOptimized$class.
        at scala.collection.immutable.List.foreach(List.scala:45)
        at kafka.consumer.FetcherRunnable.run(FetcherRunnable.scala:65)


On Wed, Jul 10, 2013 at 8:30 AM, Nihit Purwar <[EMAIL PROTECTED]> wrote:
Jun Rao 2013-07-10, 17:09
Nihit Purwar 2013-07-11, 11:12
Nihit Purwar 2013-07-19, 07:31
NEW: Monitor These Apps!
elasticsearch, apache solr, apache hbase, hadoop, redis, casssandra, amazon cloudwatch, mysql, memcached, apache kafka, apache zookeeper, apache storm, ubuntu, centOS, red hat, debian, puppet labs, java, senseiDB