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-457232346 Hi @pnowojski Thanks for you last answer, So I have tried what you suggested : "it might be possible to identify the list of files that define the internal state of Kafka that we need to archive, place it in the resources alongside of savepoint and use it during KafkaTestBase initialisation" For that I have a created a new class `KafkaMigrationTestEnvironenmentImpl` (based on `KafkaTestEnvironementImpl` ) that doesn't erase the Kafka Broker tmp folder containing the state, and a `KafkaTestMigration` (based on `KafkaTestBase` ) that points to this last Impl. (Of course this solution would required code refactoring ). Now the producer can connect but the test doesn't pass. The processed element can't be restored after the versioning. More weird the producer doesn't seem to produce anymore .... I don't know if: - this is can be related to your last post on Jira . https://issues.apache.org/jira/browse/FLINK-11249 - my test isn't correct - the state recovery for the Kafka Broker isn't right https://github.com/tvielgouarin/flink/blob/FLINK-11249/flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducerMigrationTest.java I think I have understand how to use testHarness but as always if you look at the code it would be much appreciated.
---------------------------------------------------------------- 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: [email protected] With regards, Apache Git Services
