camel-kafka-connector icon indicating copy to clipboard operation
camel-kafka-connector copied to clipboard

Published 20 hours ago • verified publisher icon apache

Set replayId from kafka OffsetStorageReader

Open Ziauddin135 opened this issue 3 years ago • 0 comments

Hi Team,

We are using Camel Salesforce source connector, Camel kafka source connector starts from replayId config from connector config. I would like to start connector from the stored offset in kafka, reading it from offset storage reader and set replayId to this offset. My question is How can we set replayId programatically in camelSourcetask so that consumer read from saleaforce from the stoed offset instead of -2/-1? Please help

Ziauddin135 avatar Mar 07 '22 08:03 Ziauddin135