On restart, the consumer starts fetching from the offset stored in ZK. So,
the issue is why the offset in ZK is not updated. Do you do auto offset
commit? If so, what's the commit interval?

Thanks,

Jun
On Fri, Aug 16, 2013 at 1:02 AM, Pavitar Singh <[EMAIL PROTECTED]> wrote:
 
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