kafka-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Neha Narkhede <neha.narkh...@gmail.com>
Subject Re: Commit Offset per topic
Date Mon, 04 Nov 2013 16:28:44 GMT
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.


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

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