问答 2023-07-26 来自:开发者社区

flink cdc 支持kafka ogg json 格式吗?

flink cdc 支持kafka ogg json 格式吗?

问答 2023-07-26 来自:开发者社区

Flink CDC中目前kafka到hudi这个提示这个json无解析,什么原因?

Flink CDC中mysql-kafka-hudi,目前kafka到hudi这个提示这个json无法解析,用kafka tool查看数据是正常的json呢?

问答 2023-07-24 来自:开发者社区

Flink CDC中debezium采集的原始json数据能自定义吗?

问题1:Flink CDC中debezium采集的原始json数据能自定义吗?比如新增一个uuid字段而不是去修改数据表结构。问题2:这个不是反序列化嘛,现在是想在原数据里头加个字段呢。举个例子,一个request请求做的crud动作,我需要在flinkcdc读取数据时加上这次请求的context信息。但是又不能去修改数据库。

问答 2023-07-19 来自:开发者社区

请问 flink cdc中这里作为json入参,咋都被搞了啊?

请问 flink cdc中这里作为json入参,咋都被搞了啊?

问答 2023-07-13 来自:开发者社区

Flink CDC中怎么改呢,我debezium-json数据只有三个 一个是before:{},?

Flink CDC中怎么改呢,我debezium-json数据只有三个 一个是before:{},一个是after:{},最后一个是op?我这些都没有,只有before,after,op

问答 2023-07-13 来自:开发者社区

Flink CDC中怎么拿到kafka以debezium-json格式 op字段数据?

问题1:Flink CDC中怎么拿到kafka以debezium-json格式 op字段数据?问题2:不能用debezium-json格式拿op字段数据吗

问答 2023-06-29 来自:开发者社区

Flink CDC中话说debezium json中能够获取表的主键吗?

Flink CDC中话说debezium json中能够获取表的主键吗? canal json中很明确

问答 2023-06-29 来自:开发者社区

Flink CDC中mysql-cdc默认序列化反序列化binlog为debezium json吗?

Flink CDC中mysql-cdc默认序列化反序列化binlog为debezium json吗,可以支持canal json吗?暂时没有接paimon,我是需要从json中获取表的主键以便后续操作,canal json中有pkNames字段,debezuim json中我没发现代码主键的字段,不知道是没有还是我没找到

问答 2023-06-18 来自:开发者社区

大佬们,Flink CDC中用kafka 的ogg-json模式,读出来怎么都是空的呢?

大佬们,Flink CDC中用kafka 的ogg-json模式,读出来怎么都是空的呢?

问答 2023-06-18 来自:开发者社区

大家有没有遇到过Flink CDC 这种情况 date类型的时候 转换成json变成了数字?

大家有没有遇到过Flink CDC 这种情况 date类型的时候 转换成json变成了数字?

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

产品推荐

阿里云实时计算Flink

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

+关注