Hi everyone,
I would like to start a discussion on FLINK-25132: KafkaSource cannot work
with object-reusing DeserializationSchema.
The implementation of FLINK-25132 moves the deserialization of kafka
records from SplitFetcher thread to thread that runs KafkaRecordEmitter,
namely flink's main task
+1
Leonard Xu 于2023年3月21日周二 11:35写道：
>
> +1(binding)
>
> minor: The first SQL piece of the FLIP is incorrect as the column name
> current_time is a system built-in function.
>
> Best,
> Leonard
>
> > On Mar 21, 2023, at 9:38 AM, yuxia wrote:
> >
> > +1 (binding_
> > Thanks Kui for driving it.
>
>
> +1 for this idea, we have enabled kafka dynamic partition discovery in all
> jobs.
>
>
