tvielgouarin edited a comment on issue #7405: [FLINK-11249] FlinkKafkaProducer011 can not be migrated to FlinkKafkaProducer URL: https://github.com/apache/flink/pull/7405#issuecomment-458558892 Thanks for your reply @pnowojski, Alright, I've made the changed for not running the test against the same KafkaBroker and Zookeeper. For the pending transaction I will just remove it then, and won't test it. What about the migration test `FlinkKafkaProducer011` --> `FlinkKafkaProducer`. Is it feasible with testHarness to from restore a savepoint with a different operator ? Or should I just make the PR for ? : 1. `FlinkKafkaProducer` migration between version test 2. `FlinkKafkaProducer011` migration between version test
---------------------------------------------------------------- This is an automated message from the Apache Git Service. To respond to the message, please log on GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org With regards, Apache Git Services
