Hi Piotr, Thank you for looking into this. Do you have an idea when next version (1.7.2) will be available ?
Also, could you validate / invalidate the approach I proposed in the previous comment ? Edward Rojas wrote > Regarding the kafka producer I am just updating the job with the new > connector and removing the previous one and upgrading the job by using a > savepoint and the --allowNonRestoredState. > So far my tests with this option are successful. Is there any risk of using this approach and just ignore the state of the previous Producer ? Thanks again for your help. Edward -- Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/
