Hi Clark,

1. This is true, you need to synchronize these consumer threads when
calling commitOffsets();

2. If you are asking what if the consumer thread crashed after

currentTopicInfo.resetConsumeOffset(consumedOffset)

within the next() call, then on its startup, it will lose all these
in-memory offsets, and read from the ZK which will be smaller than the
current value, still leading to duplicates but not data losses.

Guozhang
On Wed, Jan 29, 2014 at 12:31 PM, Clark Breyman <[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