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?


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