questions regarding offset

Posted by avilevi on
URL: http://deprecated-apache-flink-user-mailing-list-archive.369.s1.nabble.com/questions-regarding-offset-tp26939.html

Hi Guys,

I understood that offset is kept as part of the checkpoint and persisted in the state (please correct me if I'm wrong)

1. If I copy my persisted state to another cluster (different kafka servers as well) how is the offset handled ? 

2. In a stateless job how is the offset managed ? since there is no persistency . I mean in aspect of exactly once, recovery ...

BR

Avi