请教一下,flinkcdc同步推送到kafka报错,是什么原因?·Caused by: java.i

请教一下,flinkcdc同步推送到kafka报错,是什么原因?·Caused by: java.io.InvalidClassException: org.apache.flink.streaming.connectors.kafka.internals.KafkaSerializationSchemaWrapper; local class incompatible: stream classdesc serialVersionUID = -6939505643300195736, local class serialVersionUID = -2852600975509513916

展开
收起
真的很搞笑 2023-04-26 15:59:10 195 分享 版权
1 条回答
写回答
取消 提交回答
  • 你是不是java代码做的,自定义了序列化办法image.png 你有做这个吗?,此回答整理自钉群“Flink CDC 社区”

    2023-04-27 16:12:39
    赞同 展开评论

大数据领域前沿技术分享与交流,这里不止有技术干货、学习心得、企业实践、社区活动,还有未来。

还有其他疑问?
咨询AI助理