You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "Arvid Heise (Jira)" <ji...@apache.org> on 2024/10/11 07:18:00 UTC

[jira] [Commented] (FLINK-35109) Add support for Flink 1.20-SNAPSHOT in Flink Kafka connector and drop support for 1.17 and 1.18

    [ https://issues.apache.org/jira/browse/FLINK-35109?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17888544#comment-17888544 ] 

Arvid Heise commented on FLINK-35109:
-------------------------------------

Also merged [c2e11a6e22f0252cecf0d3d519d9fabb08fc102a|https://github.com/apache/flink-connector-kafka/commit/c2e11a6e22f0252cecf0d3d519d9fabb08fc102a] into main.

> Add support for Flink 1.20-SNAPSHOT in Flink Kafka connector and drop support for 1.17 and 1.18
> -----------------------------------------------------------------------------------------------
>
>                 Key: FLINK-35109
>                 URL: https://issues.apache.org/jira/browse/FLINK-35109
>             Project: Flink
>          Issue Type: Technical Debt
>          Components: Connectors / Kafka
>            Reporter: Martijn Visser
>            Assignee: Arvid Heise
>            Priority: Blocker
>              Labels: pull-request-available
>             Fix For: kafka-4.0.0
>
>
> The Flink Kafka connector currently can't compile against Flink 1.20-SNAPSHOT. An example failure can be found at https://github.com/apache/flink-connector-kafka/actions/runs/8659822490/job/23746484721#step:15:169
> The {code:java} TypeSerializerUpgradeTestBase{code} has had issues before, see FLINK-32455. See also specifically the comment in https://issues.apache.org/jira/browse/FLINK-32455?focusedCommentId=17739785&page=com.atlassian.jira.plugin.system.issuetabpanels%3Acomment-tabpanel#comment-17739785
> Next to that, there's also FLINK-25509 which can only be supported with Flink 1.19 and higher. 
> So we should:
> * Drop support for 1.17 and 1.18
> * Refactor the Flink Kafka connector to use the new {code:java}MigrationTest{code}
> We will support the Flink Kafka connector for Flink 1.18 via the v3.1 branch; this change will be a new v4.0 version with support for Flink 1.19 and the upcoming Flink 1.20



--
This message was sent by Atlassian Jira
(v8.20.10#820010)