支持,但是有版本限制,你需要找ververica-connector-clickhouse的连接,此回答整理自钉群“Flink CDC 社区”
Flink CDC 可以将数据写入 ClickHouse 数据库中,但需要注意一些事项。
Flink CDC确实支持将数据写入ClickHouse。要实现这一操作,可以通过自定义JdbcRowConverter对源代码进行改造,以支持JDBC的方式把实时数据写入ClickHouse集群。此外,Flink也提供了专门的JDBC Upsert Table Sink对象,可以用于创建JDBC Upsert Table Sink对象。
同时,Flink还提供了Flink SQL方式将Flink中的数据写入云数据库ClickHouse。使用这种方式的前提条件包括已在云数据库ClickHouse中创建表、在云数据库ClickHouse中设置白名单以及已开通Flink全托管。需要注意的是,只有Flink计算引擎VVR 3.0.2及以上版本才支持使用Flink SQL写入云数据库ClickHouse。
版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。
实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。