Thanks for providing the links. I 'll test it out using offsetStorageReader.
Kanagha On Mon, May 16, 2016 at 10:09 AM, Christian Posta <christian.po...@gmail.com > wrote: > If you're using KafkaConnect, it does it for you! > > basically you set the sourceRecord's "sourcePartition" and "sourceOffset" > fields ( > > https://github.com/christian-posta/kafka/blob/8db55618d5d5d5de97feab2bf8da4dc45387a76a/connect/api/src/main/java/org/apache/kafka/connect/source/SourceRecord.java#L51-51 > ) > and Kafka will handle storing the offsets (default in Kafka i believe) > > https://github.com/christian-posta/kafka/blob/1587aeed9a551c7c755666040fe26d066dba6857/connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerSourceTask.java#L198-198 > > If you need to read the offsets, just use the offsetStorageReader ( > > https://github.com/christian-posta/kafka/blob/417e283d643d8865aa3e79dffa373c8cc853d78f/connect/api/src/main/java/org/apache/kafka/connect/source/SourceTaskContext.java#L31-31 > ) > which is automatically available to a source task. > > On Mon, May 16, 2016 at 9:25 AM, Kanagha <er.kana...@gmail.com> wrote: > > > Hi, > > > > I am trying to find out the API for committing producer offset for Kafka > > > > I found this example: > > > > > https://cwiki.apache.org/confluence/display/KAFKA/Committing+and+fetching+consumer+offsets+in+Kafka > > > > Which would work for committing consumer offsets. Is there a separate API > > for committing producer offset using Kafka connect? > > > > Thanks > > Kanagha > > > > > > -- > > Kanagha > > > > > > -- > *Christian Posta* > twitter: @christianposta > http://www.christianposta.com/blog > http://fabric8.io >
