Hi all, I read these instructions for migrating to the KafkaSource: https://nightlies.apache.org/flink/flink-docs-release-1.14/release-notes/flink-1.14/#deprecate-flinkkafkaconsumer .
Do we need to employ any uid/allowNonRestoredState tricks if our Flink job is also stateful outside of the source? Or what is the mechanism that resolves the topic/partition/offsets in the stateful upgrade? Will restoring from FlinkKafkaConsumer cause an exception due to incompatibility of the union state to the current (what is it again)? Best, Mason
