Hello all!

We have a need where, for specific recovery cases, we would need to
manually reset our Flink kafka consumer offset to a given date but have the
Flink job restore its state. As I understand, restoring from a checkpoint
necessarily sets the group's offset to the one that was in the checkpoint.
Is there a way to disable this behavior so that Flink will restore the
state from the checkpoint, but use the offset that was manually set in
kafka?

Thanks!

Robin

Reply via email to