subject:"CustomKafkaDeserializationSchema is abstrct"

Re:Re: CustomKafkaDeserializationSchema is abstrct

2021-09-13 文章赢峰

FlinkKafkaConsumer> consumer = new FlinkKafkaConsumer<>( topic, new CustomKafkaDeserializationSchema(), props ); public class CustomKafkaDeserializationSchema implements KafkaDeserializationSchema> { @Override public boolean isEndOfStream(ConsumerRecor

Re: CustomKafkaDeserializationSchema is abstrct

2021-09-13 文章 Caizhi Weng

Hi！邮件里看不到图片，请检查一下。从标题来看，是不是写了一个自己的 kafka deserialization schema，然后这个类是 abstract class，不能直接 new？赢峰于2021年9月13日周一下午8:57写道： > 报错如下： > > > 代码如下： > > > > 签名由网易邮箱大师定制 > >

CustomKafkaDeserializationSchema is abstrct

2021-09-13 文章赢峰

报错如下：代码如下：签名由网易邮箱大师定制