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

收起

后端老大 2023-02-12 17:25:02 646 发布于北京版权

2 条回答

写回答

取消提交回答

认真学习的heart

可以使用Flink SQL的CREATE TABLE语句来定义表，然后使用INSERT INTO语句将数据写入表中。

2023-02-13 11:39:32 举报

赞同评论

评论
全部评论 (0)
登录后可评论
解决问题123

参考DataStream的侧输出，FlinkSQL 怎么处理就不知道了。 https://nightlies.apache.org/flink/flink-docs-release-1.16/zh/docs/dev/datastream/side_output/

此答案来自钉钉群“【2】Apache Flink China 社区”

2023-02-12 18:10:40 举报

赞同评论

评论
全部评论 (0)
登录后可评论

问答分类：

消息中间件 JSON Kafka 数据格式云消息队列 Kafka 版实时计算 Flink版云解析DNS

问答标签：

JSON解析 JSON嵌套云解析DNS嵌套云解析DNS json 云消息队列 Kafka 版json

问答地址：

开发者社区 > 大数据与机器学习 > 实时计算 Flink > 问答

相关问答

实时计算 Flink版

flink sql输出到upsert kafka 下游再消费一般是upsert 还是 json呀？

flink kafka debezium-json读取更新的数据，没有op 怎么获取op为u的数据？

239

flinkcdcSQL处理Kafka数据，json数据是数组的，建表结构该怎么写？[{},{}]。？

kafka写入的数据如果是json数组，可以批量写入到tablestore吗？

Flink CDC配置true以后下游kafka的canal-json内容里没有包怎么办？

大数据计算MaxCompute这边有没有解析嵌套json数组的案例？

有大佬知道这是怎么回事么 flink读不到kafka数据

1153

请问下当flink集群重启之后 kafka消息还是重复有什么办法解决吗 kafka sink 已设

1135

麻烦问一下，我们现在的架构是希望数据统一从 Kafka 中出，但是又想用 Flink CDC，请问

1088

各位, 请问: flink cdc, 用 flink sql 的方式 sink 到 kafka 可以

1363

大数据与机器学习

实时计算 Flink

实时计算Flink版是阿里云提供的全托管Serverless Flink云服务，基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎，提高作业开发运维效率。

我要提问

收录在圈子:

阿里云实时计算Flink

199212

+ 订阅

实时计算 Flink 版（Alibaba Cloud Realtime Compute for Apache Flink，Powered by Ververica）是阿里云基于 Apache Flink 构建的企业级、高性能实时大数据处理系统，由 Apache Flink 创始团队官方出品，拥有全球统一商业化品牌，完全兼容开源 Flink API，提供丰富的企业级增值功能。

利用HTTP POST协议实现简单的RPC协议：WireShark抓包分析

《从线性到二维：CSS Grid与Flex的布局范式革命与差异解析》

MCP协议深度解析：原理、应用与物联网时代的机遇-优雅草卓伊凡

通信协议：数字世界的隐形语言——从基础认知到工程实践-优雅草卓伊凡

在K8s中，“deployment”的角色和功能