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

canal 输出到kafka的json结构,各个字段的含义能说明一下吗

canal 输出到kafka的json结构,各个字段的含义能说明一下吗 原提问者GitHub用户chaixiaoxue

问答 2023-02-14 来自:开发者社区

kafka的数据通过flinksQL建立出来了,但是怎么去除kafka中的嵌套json?

kafka的数据通过flinksQL建立出来了,但是怎么去除kafka中的嵌套json?就是kafka中的after是一个嵌套的jsoN

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

flinksql可以解析kafka中嵌套json解析成多个流,写入多张表吗?

flinksql可以解析kafka中嵌套json解析成多个流,写入多张表吗?

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

请教各位大佬,flinksql可以解析kafka中嵌套json解析成多个流,写入多张表吗?

请教各位大佬,flinksql可以解析kafka中嵌套json解析成多个流,写入多张表吗?

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

pyflink 连接kafka 不定字段的json反序列化,有没有比较好的写法?

pyflink 连接kafka 不定字段的json反序列化,有没有比较好的写法?

问答 2023-01-15 来自:开发者社区

对于Flink CDC,具体的说是kafka传输的ogg json。怎么用时间窗口进行聚合啊?

对于Flink CDC,changelog 数据,具体的说是kafka传输的ogg json。怎么用时间窗口进行聚合啊。直接使用报错:StreamPhysicalWindowAggregate doesn't support consuming update and delete changes which is produced by node TableSourceScan

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

这个Kafka中的json数据有些复杂,并且有的字段key存在多个,而且key的命名也不是很规范,例

这个Kafka中的json数据有些复杂,并且有的字段key存在多个,而且key的命名也不是很规范,例如有的key前面是个“$”,这样的我可以直接映射成Flink 表吗,或者说我这个映射的对不对? 

文章 2022-11-05 来自:开发者社区

使用Flink 读取kafka Catalog 源表数据展开json写入下游hologres表示例操作

本文主要介绍如何使用Flink  读取kafka Catalog 源表数据写入下游hologres存储,并演示'json.infer-schema.flatten-nested-columns.enable参数,递归的展开JSON中的嵌套列的效果。一 准备工作本文测试使用 阿里云消息队列Kafka版进行演示,依据Flink集群的网络环境(VPC),构建相关上下游数据源,并做好白明单访问....

使用Flink 读取kafka Catalog 源表数据展开json写入下游hologres表示例操作
问答 2022-09-28 来自:开发者社区

flink cdc 2.2.1目前可以处理kafka嵌套json吗?

是要定义json-schema还是 使用'format' = 'raw'?

问答 2022-08-25 来自:开发者社区

请问下Flink 用Map类型接收Kafka中的嵌套json,MySQL 用json类型接收,使用s

请问下Flink 用Map类型接收Kafka中的嵌套json,MySQL 用json类型接收,使用sql方式怎么写?

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

产品推荐

消息队列

消息队列是构建分布式互联网应用的基础设施,通过消息队列实现的松耦合架构设计可以提高系统可用性以及可扩展性,是适用于现代应用的优秀设计方案。

+关注
AI助理

你好,我是AI助理

可以解答问题、推荐解决方案等

登录插画

登录以查看您的控制台资源

管理云资源
状态一览
快捷访问