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

Reply via email to