Flink CDC里为什么这里又要重新定义一遍options呀？
https://github.com/ververica/flink-cdc-connectors/blob/master/flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-doris/src/main/java/com/ververica/cdc/connectors/doris/sink/DorisDataSinkOptions.java
Flink CDC里为什么这里又要重新定义一遍options呀？doris官方的flink connector不是有options吗？唯一不同的是ConfigOption包名，一个来自ververica，另一个来自flink
写回答
-
在 Apache Flink CDC 中，你可能会遇到需要重新定义连接器选项的情况，这是因为不同的Flink connector可能来自不同的开发团队或项目，它们在设计和实现时可能使用了不同的配置选项接口或包。例如，Ververica（原DataArtisans，被阿里云收购后继续贡献Flink）可能为Flink CDC提供了一套特定的连接器，并使用了来自
com.ververica.cdc.connectors.mydatabase.MyDatabaseOptions之类的包中的ConfigOption。而Doris官方或者社区提供的Flink connector可能有不同的实现方式，因此其配置选项可能位于
org.apache.flink.connector.doris.options.DorisOptions等这样的包中。尽管两者都是为了连接到数据源并配置相关参数，但由于这些connector是独立开发的组件，其内部使用的配置API和结构并不相同。这意味着当你要切换或同时使用不同来源的connector时，必须按照对应connector文档提供的指南来设置相应的配置选项。
所以，即使目标都是Doris，但基于Flink CDC的不同connector实现版本，用户可能需要根据所选用的connector重新定义相关的options配置。这有助于确保正确解析和应用配置信息到对应的connector实例上。
2024-02-21 16:43:25赞同 展开评论 打赏
版权声明：本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
实时计算Flink版是阿里云提供的全托管Serverless Flink云服务，基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎，提高作业开发运维效率。
热门讨论
热门文章
相关文章
相关电子书
更多
