Hi! *Scenario* I want to eventually do a breaking change to a Kafka source (major version change) which requires a new Kafka topic.
*Question* What utilities exist to help with this in Flink? What best practices exist? My plan is roughly the following: 1. Change my Flink job to support both kafka sources. Union them. Deal with idle data sources (either temp with flag or force through watermark events). 2. Change the Kafka producer to write to the new topic. 3. When enough time has passed, delete the old operator (using allowNonRestoredState).
