kafka-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Grant Henke <ghe...@cloudera.com>
Subject Re: Kafka Simple Cosumer
Date Thu, 06 Aug 2015 14:56:22 GMT
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.digumarthi@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
grant@cloudera.com | twitter.com/gchenke | linkedin.com/in/granthenke

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