[
https://issues.apache.org/jira/browse/FLINK-25509?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17798066#comment-17798066
]
Martijn Visser commented on FLINK-25509:
----------------------------------------
[~lindong] Yes, that's what I suggest. The one thing I would like to check with
[~tzulitai] is if we want to cut {{main}} now first and create a Flink Kafka
v3.1 branch, which would (at this point) have support for both Flink 1.17 and
Flink 1.18. Then with the PR for this ticket opened, we would drop support for
Flink 1.17 and therefore release it as part of a new Flink Kafka v4.0
branch/release which only would support Flink 1.18 and newer. For users of
Flink 1.17, they would stick with the v3.1 version (until support for Flink
1.17 is stopped completely)
> FLIP-208: Add RecordEvaluator to dynamically stop source based on
> de-serialized records
> ---------------------------------------------------------------------------------------
>
> Key: FLINK-25509
> URL: https://issues.apache.org/jira/browse/FLINK-25509
> Project: Flink
> Issue Type: New Feature
> Components: Connectors / Common, Connectors / Kafka
> Reporter: Dong Lin
> Assignee: Hang Ruan
> Priority: Major
> Labels: pull-request-available, stale-assigned
>
> This feature is needed to migrate applications which uses
> KafkaDeserializationSchema::isEndOfStream() from using FlinkKafkaConsumer to
> using KafkaSource.
> Please checkout
> https://cwiki.apache.org/confluence/display/FLINK/FLIP-208%3A+Add+RecordEvaluator+to+dynamically+stop+source+based+on+de-serialized+records
> for the motivation and the proposed changes.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
