diff --git a/flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducerMigrationTest.java b/flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducerMigrationTest.java index 10a6fee0cc3b0..0317396e31472 100644 --- a/flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducerMigrationTest.java +++ b/flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducerMigrationTest.java @@ -45,7 +45,8 @@ public class FlinkKafkaProducerMigrationTest extends KafkaMigrationTestBase { public static Collection parameters() { return Arrays.asList( MigrationVersion.v1_8, - MigrationVersion.v1_9); + MigrationVersion.v1_9, + MigrationVersion.v1_10); } public FlinkKafkaProducerMigrationTest(MigrationVersion testMigrateVersion) { diff --git a/flink-connectors/flink-connector-kafka/src/test/resources/kafka-migration-kafka-producer-flink-1.10-snapshot b/flink-connectors/flink-connector-kafka/src/test/resources/kafka-migration-kafka-producer-flink-1.10-snapshot new file mode 100644 index 0000000000000..e7a4f0dad9a25 Binary files /dev/null and b/flink-connectors/flink-connector-kafka/src/test/resources/kafka-migration-kafka-producer-flink-1.10-snapshot differ