Hi Can someone please help me understand, where will the offsets be stored when consuming with “KafkaSinglePortStringInputOperator” ?
And, how to handle restarts ? I worked with Storm earlier, Storm maintains the offsets in zookeeper and client id is maintained for every consumer, using which - we can see what is the current offset status for a given partition & modify them as well using zookeeper-cli !! - restarts can be handled As per the Apex documentation, I can see, that using OffsetManager we can handle the restarts effectively, but couldn’t find any examples to refer… How clientId can be used to retrieve offsets status And ability to edit the offsets etc can someone pls help me find this ? Thanks a lot!! -Regards, Raja.
