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

请大家帮我看看下列问题怎么办?

"import com.ververica.cdc.connectors.shaded.org.apache.kafka.connect.source和import org.apache.kafka.connect.source.SourceRecord

有遇到读取优先级的问题异常? 实际我要第二个 但是读了第一个"

展开
收起
JWRRR 2023-04-03 14:38:00 164 0
2 条回答
写回答
取消 提交回答
  • 解决办法是把maven插件改成shade此回答整理自钉群“【③群】Apache Flink China社区”

    2023-04-03 16:45:27
    赞同 展开评论 打赏
  • 存在即是合理

    这似乎是一个关于Java代码中导入问题的问题。如果遇到了这样的错误,请尝试以下几个步骤:

    确认是否已经正确地安装了所需的依赖项,包括kafka connect和相应的库。可以通过阅读文档或参考其他示例代码来了解正确的依赖关系。

    检查导入语句是否正确。在这个例子中,它似乎有两个不同的导入语句,其中一个包含了一个 "shaded" 子目录。这可能是因为代码中使用了一个“阴影”版本的库,这意味着需要使用不同的导入语句。确保导入语句与使用的库相匹配。

    如果仍然遇到问题,请检查代码中是否有其他错误。可能需要仔细检查代码,查看是否有任何其他语法或逻辑错误,这些错误可能会导致导入语句无法正常工作。

    如果您仍然无法解决问题,请考虑向社区寻求帮助,寻求其他开发人员的建议和支持。您可以通过查看论坛、问答网站或社交媒体上的相关主题来找到这样的社区。

    2023-04-03 14:56:15
    赞同 展开评论 打赏

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

相关电子书

更多
低代码开发师(初级)实战教程 立即下载
冬季实战营第三期:MySQL数据库进阶实战 立即下载
阿里巴巴DevOps 最佳实践手册 立即下载