The API you are looking for is ConsumerConnector.commitOffsets(). However, not that it will commit offsets for all partitions that the particular consumer connector owns at that time. And the set of partitions owned by a particular consumer connector can change over time.
Thanks, Neha On Mon, Nov 4, 2013 at 7:58 AM, Roman Garcia <romangarc...@gmail.com> wrote: > Hi, I'm still using Kafka 0.7, and was wondering if there's a way I can > "manually" commit offsets per Topic/Partition. > > I was expecting something like KafkaMessageStream#commitOffset() > I couldn't find an API for this. If there isn't any, is there a reason? > > Regards, > Roman >
