Hey all! I have a flink job that is reading from one kafka topic and writing to another. What would be required to reset the offsets so my job so that it started fresh from the first kafka messages and worked through the entire topic again? Would I delete my checkpoint files? Clear the consumer offset in kafka? Both? Or something else?

Hey, you just start a new job (or delete and start an existing one) without specifying

savepointPath

. This will ensure the state is not passed to the new job, which means no Kafka offsets (but also other state potentially).

@sap1ens thanks for the input! I'll give that a try gratitude thank you