Flink 读取kafka数据写入Pulsar(含报错The implementation of the RichSinkFunction is not serializable)_the implementation of the richflatmapfunction is n-CSDN博客

网站介绍:文章浏览阅读5.2k次。@羲凡——只为了更好的活着Flink 读取kafka数据写入Pulsar(含报错The implementation of the RichSinkFunction is not serializable)开始之前务必检查自己kafka、pulsar和flink的版本,在pom中添加正确依赖本人kafka(0.11)、pulsar(2.4.1)和flink(1.7.2),切记版本不一样,代码..._the implementation of the richflatmapfunction is not serializable. the objec