OceanBase数据库有flink-oceanbase-connector吗？
OceanBase数据库有flink-oceanbase-connector吗？
版权声明：本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
-
是的，Flink-OceanBase-Connector 是一个用于将 Flink 集成 OceanBase 数据库的连接器。您可以使用此连接器在 Flink 应用程序中读取和写入 OceanBase 数据库的数据。当前，Flink 适配 OceanBase 的 connector 版本为5.1。
您可以通过使用OceanBase Connector/J使得Java程序与OceanBase分布式数据库集群建立连接。此外，当OceanBase数据库没有部署OceanBase数据库代理（OBProxy）时，连接器会使用OCJ（OceanBase Connector Java）来连接OceanBase数据库。
2024-01-03 10:31:36赞同 展开评论 -
面对过去，不要迷离；面对未来，不必彷徨；活在今天，你只要把自己完全展示给别人看。
是的，OceanBase数据库可以使用flink-oceanbase-connector。Flink CDC (CDC Connectors for Apache Flink) 是 Apache Flink 的一组 Source 连接器，它支持从大多数据库中实时地读取存量历史数据和增量变更数据。这个连接器也包括对OceanBase的支持。通过Flink的JDBC connector，可以将数据写入到兼容MySQL协议的数据库，如OceanBase。
当没有部署OceanBase数据库代理（OBProxy）时，连接器会使用OCJ（OceanBase Connector Java）来连接OceanBase数据库，该模式需要用到config url，要求OceanBase数据库已部署OceanBase云平台。
请注意，使用此连接器之前，您需要确保已正确配置并安装了所有必要的依赖项，并且您的OceanBase数据库正在运行。
2024-01-02 22:28:47赞同 展开评论 -
https://ask.oceanbase.com/t/topic/35602487可以参考这个来。建议都使用最新版本。https://github.com/oceanbase/flink-connector-oceanbase ，此回答整理自钉群“[社区]技术答疑群OceanBase”
2024-01-02 21:47:57赞同 展开评论
