kafka-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Roman Garcia <romangarc...@gmail.com>
Subject Re: Commit Offset per topic
Date Mon, 04 Nov 2013 17:57:51 GMT
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.narkhede@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 <romangarciam@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
> >
>

Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message