再确认下Flink CDC中, 解析100个库的binlog的账号密码,需要哪些权限,只读行不行?
Flink CDC是一个功能强大的工具,可以从MySQL、PostgreSQL等数据库直接读取全量数据Flink CDC是一个功能强大的工具,可以从MySQL、PostgreSQL等数据库直接读取全量数据和增量变更数据。解析100个库的binlog,你需要具有足够的权限来访问这些库,并且能够读取binlog。
对于MySQL,你需要账号具有REPLICATION SLAVE
权限。这个权限允许用户从复制中读取二进制日志文件。此外,你还需要确保你的MySQL服务器已开启binlog。
在Flink CDC中,MySQL CDC连接器在处理时会准确读取数据,即使在任务出现故障的情况下也是如此。如果你在解析Binlog数据中的timestamp字段时遇到时区问题,可以在CDC作业中配置server-time-zone参数,确保它与你的MySQL服务器时区一致。
至于只读权限是否足够,这取决于具体的数据库设置和Flink CDC的配置。如果只是进行数据同步和迁移,只读权限通常是足够的。但是,如果你需要进行更复杂的操作,如更新或删除数据,那么你可能需要更高的权限。
官方网站写的很清楚 https://ververica.github.io/flink-cdc-connectors/master/ ,此回答整理自钉群“Flink CDC 社区”
版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。
实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。