Currently, the only way to achieve that is to use the SimpleConsumer API.
We are considering the feature you mentioned for the 0.9 release -
On Mon, Nov 4, 2013 at 9:57 AM, Roman Garcia <[EMAIL PROTECTED]> wrote:
> 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?
> On Mon, Nov 4, 2013 at 1:28 PM, Neha Narkhede <[EMAIL PROTECTED]
> > The API you are looking for is ConsumerConnector.commitOffsets().
> > 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
> > particular consumer connector can change over time.
> > Thanks,
> > Neha
> > On Mon, Nov 4, 2013 at 7:58 AM, Roman Garcia <[EMAIL PROTECTED]>
> > 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
> > >