Hi Balaji, Short answer is "all partitions in all the iterators of the consumer".
Long answer: the commitOffset will commit the currently consumed offset for all the partitions that the consumer is currently fetching from. For example, say you have a topic with 4 partitions and you have two consumer each with two stream iterators, then each iterator will get 1 partition and each consumer will get 2. If consumer is fetching from partition 1 and 2, then commitOffset will only record the consumed offsets for partition 1 and 2. Guozhang On Fri, Apr 11, 2014 at 3:15 PM, Seshadri, Balaji <[email protected]>wrote: > Hi, > > Currently we are using 0.8.1 version of Kafka ?. > > Does this ConsumerConenctor.commitOffset method commits all partitions for > messages in iterator or only the offset of message that is currently > consumed. > > Please clarify as we are manually committing offsets and this would create > bigger issue for us. > > Thanks, > > Balaji > > > -- -- Guozhang
