Hi,

We are using Flink 1.20.3 and the flink connector 3.4.0-1.20. it's a
streaming application using kafka source and sink.

Was wondering if anyone here has a tip/sample to read the content of the
savepoints to extract the kafka offset per partition.

The scenario is around resuming from a replicated cluster. We plan to
replicate kafka as well as the savepoints. What we do not know is if the
latest savepoint that we replicated contains the kafka offset that flink
would resume from with the latest savepoint, or if we need to resume from a
previous savepoint.

Thanks for any tips.

JM

Reply via email to