https://kafka.apache.org/30/documentation/streams/developer-guide/app-reset-tool.html User would just need to execute ``kafkactl reset-stream <application.id> [options]``