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. * @return a [[kafka.api.OffsetCommitResponse]] object. */ def commitOffsets(request: OffsetCommitRequest) Thanks, Grant On Thu, Aug 6, 2015 at 12:09 AM, uvsd1 <prabhakar.digumar...@gmail.com> wrote: > Hi All , > > Does kafka provides a way to store the offset within zookeper while using > the simpleConsumer ? > > > Thanks, > Prabhakar > -- Grant Henke Software Engineer | Cloudera gr...@cloudera.com | twitter.com/gchenke | linkedin.com/in/granthenke
