1. This is true, you need to synchronize these consumer threads when
2. If you are asking what if the consumer thread crashed after
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.
On Wed, Jan 29, 2014 at 12:31 PM, Clark Breyman <[EMAIL PROTECTED]> wrote: