阿里云文档 2024-06-28

社区CDC

本文为您介绍如何在阿里云实时计算Flink版中使用社区版CDC(Change Data Capture)连接器,以及更改连接器名称。

问答 2024-04-02 来自:开发者社区

Flink CDC里mysql中字段类型为json,这该怎么解决?

Flink CDC里mysql中字段类型为json,但经过source后print的字段中内容被转义了,是需要自定义deserializer才能解决吗?

问答 2024-03-11 来自:开发者社区

Flink CDC 里mysql的cdc出来的json op字段有哪几种值?是 c r u d 吗?

Flink CDC 里mysql的cdc出来的json op字段有哪几种值?是 c r u d 吗?

问答 2024-01-24 来自:开发者社区

Flink CDC里flink-sql 中json_array 类型 怎么转成 array类型?

Flink CDC里flink-sql 中 json_array 类型 怎么转成 array 类型?

问答 2024-01-18 来自:开发者社区

Flink CDC里这个入参json为什么会变成这样?

Flink CDC里这个入参json为什么会变成这样?代码是这样的,拿到json就是乱七八糟,不知道为什么?

问答 2024-01-09 来自:开发者社区

Flink CDC这里传json,双引号会被去掉,怎么办?

Flink CDC这里传json,双引号会被去掉,怎么办?用这个拿参数:ParameterTool parameterTool = ParameterTool.fromArgs(args);

问答 2024-01-09 来自:开发者社区

请问一下Flink CDC这个参数不能用json格式吗?

请问一下Flink CDC这个参数不能用json格式吗?

问答 2023-12-31 来自:开发者社区

Flink CDC中with需要什么特殊参数吗,还是直接用json函数去取值?

Flink CDC中with需要什么特殊参数吗,还是直接用json函数去取值?

问答 2023-12-20 来自:开发者社区

Flink CDC使用的是kafka canal json作为数据变更源,cdc3.0未来会支持么?

Flink CDC使用的是kafka canal json作为数据变更源,cdc 3.0未来会支持么?

问答 2023-12-04 来自:开发者社区

Flink CDC中debezium-json消息消费能直接开多并行度不?

Flink CDC中debezium-json消息消费能直接开多并行度不?有没有同学基于这个格式,只保存after的数据呀

本页面内关键词为智能算法引擎基于机器学习所生成,如有任何问题,可在页面下方点击"联系我们"与我们沟通。

产品推荐

阿里云实时计算Flink

一套基于Apache Flink构建的一站式、高性能实时大数据处理平台,广泛适用于流式数据处理、离线数据处理、DataLake计算等场景。

+关注