Re: Question about ZookeeperConsumerConnector

2014-11-11 Thread Guozhang Wang
Thanks Jun! Jiangjie, could you file a JIRA? Thanks. Guozhang On Tue, Nov 11, 2014 at 9:27 AM, Jun Rao wrote: > Hi, Jiangjie, > > Thanks for the investigation. Yes, this seems like a real issue. > > 1. It doesn't seem that we need to put the shutdownCommand back into the > queue. Once an itera

Re: Question about ZookeeperConsumerConnector

2014-11-11 Thread Jun Rao
Hi, Jiangjie, Thanks for the investigation. Yes, this seems like a real issue. 1. It doesn't seem that we need to put the shutdownCommand back into the queue. Once an iterator receives a shutdownCommand, it will be in a Done state and will remain in that state forever. 2. Yes, we just need to ge