开发者社区 > 大数据与机器学习 > 实时计算 Flink > 正文

Flink CDC这个问题怎么解决?

Flink CDC这个问题怎么解决?Caused by: org.apache.kafka.connect.errors.DataException: Invalid Java object for schema type STRING: class java.lang.Long for field: "null"
at org.apache.kafka.connect.data.ConnectSchema.validateValue(ConnectSchema.java:240)
at org.apache.kafka.connect.data.ConnectSchema.validateValue(ConnectSchema.java:213)
at org.apache.kafka.connect.data.SchemaBuilder.defaultValue(SchemaBuilder.java:129)
... 29 common frames omitted
image.png
image.png
版本是这样的jdk8

展开
收起
真的很搞笑 2023-11-07 19:39:16 99 0
1 条回答
写回答
取消 提交回答
  • 这个错误提示表明你正在尝试将一个Java对象转换为Kafka Connect的STRING类型的Schema,但是该对象实际上是一个Java Long对象。这通常发生在当你从Kafka读取数据并将其转换为其他类型时。

    解决这个问题的方法是,确保你在转换过程中使用的Schema是正确的。例如,如果你的Kafka topic中的数据是字符串类型,那么你应该使用STRING类型的Schema来读取这些数据。如果数据是Long类型,那么你应该使用LONG类型的Schema。

    此外,你也可以检查一下你的代码中是否有任何地方可能意外地将Long类型的对象转换为String类型。如果有这样的地方,你可能需要修改你的代码以避免这种转换。

    2023-11-10 10:30:43
    赞同 1 展开评论 打赏

实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。

相关产品

  • 实时计算 Flink版
  • 热门讨论

    热门文章

    相关电子书

    更多
    Flink CDC Meetup PPT - 龚中强 立即下载
    Flink CDC Meetup PPT - 王赫 立即下载
    Flink CDC Meetup PPT - 覃立辉 立即下载