Thanks for providing the links. I 'll test it out using offsetStorageReader.
Kanagha
On Mon, May 16, 2016 at 10:09 AM, Christian Posta wrote:
> If you're using KafkaConnect, it does it for you!
>
> basically you set the sourceRecord's "sourcePartition" and "sourceOffset"
> fields (
>
> https://
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#L5
Hi,
Producers don't track offsets in the same way, so there is no producer
offset API.
Thanks
Tom Crayford
Heroku Kafka
On Mon, May 16, 2016 at 5:25 PM, Kanagha wrote:
> Hi,
>
> I am trying to find out the API for committing producer offset for Kafka
>
> I found this example:
>
> https://cwik
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
