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 <[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? Regards, Roman On Mon, Nov 4, 2013 at 1:28 PM, Neha Narkhede <[EMAIL PROTECTED]>wrote:
So, what would be that API for offset commit in 0.8 version? Are there any docs about it? On Thu, Nov 7, 2013 at 10:56 PM, 小宇 <[EMAIL PROTECTED]> wrote:
Roman Garcia 2013-11-08, 16:10
NEW: Monitor These Apps!
Apache Lucene, Apache Solr and all other Apache Software Foundation projects and their respective logos are trademarks of the Apache Software Foundation.
Elasticsearch, Kibana, Logstash, and Beats are trademarks of Elasticsearch BV, registered in the U.S. and in other countries. This site and Sematext Group is in no way affiliated with Elasticsearch BV.
Service operated by Sematext