Mingtao, How many partitions of the consumed topic has? Basically the data is distributed per-partition, and hence if the number of consumers is larger than the number of partitions, some consumers will not get any data.
Guozhang On Mon, Aug 11, 2014 at 3:29 PM, Mingtao Zhang <mail2ming...@gmail.com> wrote: > Is it anyhow related to the issue? > > WARN No previously checkpointed highwatermark value found for topic RAW > partition 0. Returning 0 as the highwatermark > (kafka.server.HighwaterMarkCheckpoint) > > Mingtao > -- -- Guozhang
