请问下Flink CDC中tidb cdc 支持动态加表吗,类似mysql cdc 的scanNewlyAddedTableEnabled?
目前,Flink CDC 中 TiDB CDC 还不支持动态加表。
动态加表是指,在 Flink 作业运行时,可以动态添加或者删除 TiDB 表。这样可以让 Flink 作业更灵活,能够适应数据库的变化。
但是,目前 Flink CDC 中 TiDB CDC 的实现是基于 TiDB 的 Binlog 协议,而 TiDB 的 Binlog 协议不支持动态加表。
因此,目前 Flink CDC 中 TiDB CDC 不支持动态加表。
但是,Flink CDC 的社区正在开发对 TiDB CDC 动态加表的支持。预计在未来的版本中,Flink CDC 中 TiDB CDC 将支持动态加表。
可以关注 Flink CDC 的官方文档:https://ci.apache.org/projects/flink/flink-docs/release-1.13/zh/dev/table/connectors/table_sources/tidb_cdc.html,了解最新的动态加表支持情况。
版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。
实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。