You are viewing a plain text version of this content. The canonical link for it is here.

Posted to dev@flink.apache.org by Sergey Troshkov <ka...@yandex.ru> on 2022/10/12 08:35:47 UTC

RE: [DISCUSS] FLIP-208: Update KafkaSource to detect EOF based on de-serialized record

Hi everyone! What is the status of this FLIP? I am really interested
in moving this forward.

Best regards,
Sergey

On 2022/01/04 07:04:01 Dong Lin wrote:
> Hi all,
>
> We created FLIP-208: Update KafkaSource to detect EOF based on
> de-serialized records. Please find the KIP wiki in the link
> https://cwiki.apache.org/confluence/display/FLINK/FLIP-208%3A+Update+KafkaSource+to+detect+EOF+based+on+de-serialized+records
> .
>
> This FLIP aims to address the use-case where users need to stop a Flink job
> gracefully based on the content of de-serialized records observed in the
> KafkaSource. This feature is needed by users who currently depend on
> KafkaDeserializationSchema::isEndOfStream() to migrate their Flink job from
> FlinkKafkaConsumer to KafkaSource.
>
> Could you help review this FLIP when you get time? Your comments are
> appreciated!
>
> Cheers,
> Dong
>