subject:"Kafka Simple Cosumer"

Re: Kafka Simple Cosumer

2015-08-06 Thread Grant Henke

I think you are looking for commitOffsets. I pasted the doc code snippet below: /** * Commit offsets for a topic * Version 0 of the request will commit offsets to Zookeeper and version 1 and above will commit offsets to Kafka. * @param request a [[kafka.api.OffsetCommitRequest]] object.

Kafka Simple Cosumer

2015-08-06 Thread uvsd1

Hi All , Does kafka provides a way to store the offset within zookeper while using the simpleConsumer ? Thanks, Prabhakar