Right Neha, thanks. I was aware of that particular API, but I process topics within separate threads (actors) so I cannot assume every topic/partition is supposed to commit its offset. Instead, I could use a per-stream (topic-partition) commit. Is this use case valid? Should there be a ticket to implement this? Regards, Roman
On Mon, Nov 4, 2013 at 1:28 PM, Neha Narkhede <neha.narkh...@gmail.com>wrote: > 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 > > >
