flink cdc 2.2.1目前可以处理kafka嵌套json吗?-问答-阿里云开发者社区-阿里云

开发者社区> 问答> 正文
阿里云
为了无法计算的价值
打开APP
阿里云APP内打开

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

来自:阿里云实时计算Flink 2022-09-28 08:49:42 111 1

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

取消 提交回答
全部回答(1)
  • 游客tk3vic2jx2lk4
    2022-09-28 09:20:49

    看看format文档就知道了..(此答案整理自Flink CDC 社区)

    0 0
相关问答

0

回答

求助:flink cdc 从oracle或者mysql 同步到kafka,但是最近一个update操

2022-08-24 16:58:49 170浏览量 回答数 0

0

回答

flink cdc 消费mongodb变更发到kafka用哪种格式合适?

2022-08-22 10:05:31 189浏览量 回答数 0

0

回答

有遇到flink读取kafka乱码的吗,如何解决?

2022-08-17 17:44:52 146浏览量 回答数 0

1

回答

flink消费kafka里cdc同步的数据,消费时怎么可以保证顺序

2022-08-15 10:48:11 146浏览量 回答数 1

1

回答

Flink kafka Producer的容错是什么?

2021-12-07 20:20:18 127浏览量 回答数 1

1

回答

Flink kafka Producer的Producer 分区是什么?

2021-12-07 20:19:12 240浏览量 回答数 1

1

回答

flink创建Kafka流表的方法是什么?

2021-12-07 20:26:01 198浏览量 回答数 1

1

回答

flink中Kafka流表关联HBase维度表的计算逻辑是什么呢?

2021-12-07 20:28:06 328浏览量 回答数 1

1

回答

Flink中Kafka源连接器的构造函数有哪些呢?

2021-12-07 21:57:51 120浏览量 回答数 1

1

回答

flink不清理state,从checkpoint恢复任务能重置kafka的offset讨论

2021-12-07 22:02:10 600浏览量 回答数 1
文章
问答
来源圈子
更多
实时计算 Flink 版(Alibaba Cloud Realtime Compute for Apache Flink,Powered by Ververica)是阿里云基于 Apache Flink 构建的企业级、高性能实时大数据处理系统,由 Apache Flink 创始团队官方出品,拥有全球统一商业化品牌,完全兼容开源 Flink API,提供丰富的企业级增值功能。
+ 订阅
相关文档: 实时计算(流计算)
问答排行榜
最热
最新
相关电子书
更多
《基于 Flink 的全新 Pulsar Connector 的设计、开发和使用》
立即下载
Flink SQL in 2020
立即下载
Flink CDC:新一代数据集成框架
立即下载