Home | About | Sematext search-lucene.com search-hadoop.com
 Search Hadoop and all its subprojects:

Switch to Threaded View
Kafka, mail # user - RE: Looks like consumer fetchers get stopped we are not getting any data


Copy link to this message
-
Re: Looks like consumer fetchers get stopped we are not getting any data
Guozhang Wang 2014-01-13, 03:21
This might be a issue of KAFKA-992. The title only includes Server but this
bug actually applies to Consumers.

Which version are you using?

Guozhang
On Sun, Jan 12, 2014 at 8:00 AM, Seshadri, Balaji
<[EMAIL PROTECTED]>wrote:

> Please see log.
>
> seshbal:tm1mwdpl03-/apps/tc/tm1-deshdpconsumer101/apache-tomcat-7.0.42/logs
> >ls -1 catalina*|xargs -exec grep "Expired"
> catalina.out.2014-01-08_16-07-05:{2014-01-10 00:58:03,265} DEBUG
> [catalina-exec-3-EventThread] (ZkClient.java:351) - Received event:
> WatchedEvent state:Expired type:None path:null
> catalina.out.2014-01-08_16-07-05:{2014-01-10 00:58:03,265} DEBUG
> [catalina-exec-6-EventThread] (ZkClient.java:351) - Received event:
> WatchedEvent state:Expired type:None path:null
> catalina.out.2014-01-08_16-07-05:{2014-01-10 00:58:03,265} INFO
>  [catalina-exec-6-EventThread] (ZkClient.java:449) - zookeeper state
> changed (Expired)
> catalina.out.2014-01-08_16-07-05:{2014-01-10 00:58:03,265} INFO
>  [catalina-exec-3-EventThread] (ZkClient.java:449) - zookeeper state
> changed (Expired)
> catalina.out.2014-01-08_16-07-05:{2014-01-10 00:58:03,265} DEBUG
> [catalina-exec-3-EventThread] (ZkEventThread.java:88) - New event:
> ZkEvent[State changed to Expired sent to
> kafka.consumer.ZookeeperConsumerConnector$ZKSessionExpireListener@152e95fa
> ]
> catalina.out.2014-01-08_16-07-05:{2014-01-10 00:58:03,265} DEBUG
> [catalina-exec-6-EventThread] (ZkEventThread.java:88) - New event:
> ZkEvent[State changed to Expired sent to
> kafka.consumer.ZookeeperConsumerConnector$ZKSessionExpireListener@4090755c
> ]
> catalina.out.2014-01-08_16-07-05:{2014-01-10 00:58:03,265} DEBUG [
> ZkClient-EventThread-55-tvip-m1-mw-zookeeper.dish.com:2181]
> (ZkEventThread.java:69) - Delivering event #22 ZkEvent[State changed to
> Expired sent to
> kafka.consumer.ZookeeperConsumerConnector$ZKSessionExpireListener@152e95fa
> ]
> catalina.out.2014-01-08_16-07-05:{2014-01-10 00:58:03,265} DEBUG [
> ZkClient-EventThread-90-tvip-m1-mw-zookeeper.dish.com:2181]
> (ZkEventThread.java:69) - Delivering event #23 ZkEvent[State changed to
> Expired sent to
> kafka.consumer.ZookeeperConsumerConnector$ZKSessionExpireListener@4090755c
> ]
> catalina.out.2014-01-08_16-07-05:{2014-01-10 00:58:03,267} DEBUG
> [catalina-exec-10-EventThread] (ZkClient.java:351) - Received event:
> WatchedEvent state:Expired type:None path:null
> catalina.out.2014-01-08_16-07-05:{2014-01-10 00:58:03,267} INFO
>  [catalina-exec-10-EventThread] (ZkClient.java:449) - zookeeper state
> changed (Expired)
> catalina.out.2014-01-08_16-07-05:{2014-01-10 00:58:03,267} DEBUG
> [catalina-exec-5-EventThread] (ZkClient.java:351) - Received event:
> WatchedEvent state:Expired type:None path:null
> catalina.out.2014-01-08_16-07-05:{2014-01-10 00:58:03,267} DEBUG
> [catalina-exec-10-EventThread] (ZkEventThread.java:88) - New event:
> ZkEvent[State changed to Expired sent to
> kafka.consumer.ZookeeperConsumerConnector$ZKSessionExpireListener@1901a132
> ]
> catalina.out.2014-01-08_16-07-05:{2014-01-10 00:58:03,267} INFO
>  [catalina-exec-5-EventThread] (ZkClient.java:449) - zookeeper state
> changed (Expired)
> catalina.out.2014-01-08_16-07-05:{2014-01-10 00:58:03,267} DEBUG [
> ZkClient-EventThread-162-tvip-m1-mw-zookeeper.dish.com:2181]
> (ZkEventThread.java:69) - Delivering event #24 ZkEvent[State changed to
> Expired sent to
> kafka.consumer.ZookeeperConsumerConnector$ZKSessionExpireListener@1901a132
> ]
> catalina.out.2014-01-08_16-07-05:{2014-01-10 00:58:03,267} DEBUG
> [catalina-exec-5-EventThread] (ZkEventThread.java:88) - New event:
> ZkEvent[State changed to Expired sent to
> kafka.consumer.ZookeeperConsumerConnector$ZKSessionExpireListener@10d1a0d2
> ]
> catalina.out.2014-01-08_16-07-05:{2014-01-10 00:58:03,267} DEBUG [
> ZkClient-EventThread-79-tvip-m1-mw-zookeeper.dish.com:2181]
> (ZkEventThread.java:69) - Delivering event #25 ZkEvent[State changed to
> Expired sent to
> kafka.consumer.ZookeeperConsumerConnector$ZKSessionExpireListener@10d1a0d2