开发者社区> 问答> 正文

请问Flink1.10怎么样定义kafka中消息为json数组对象的情况呀?

网上有非常多的资料显示Flink SQL怎样定义嵌套的json属性以及json中某个属性为json数组的示例, 但是对于整个消息为一个数组(json array)的应该怎么处理? json示例如下: [ { "a": "1", "b": 2 } ]*来自志愿者整理的FLINK邮件归档

展开
收起
又出bug了-- 2021-12-03 17:36:15 855 0
1 条回答
写回答
取消 提交回答
  • 这个功能暂时还没有,FLIP-124[1] 之后应该是可以的。

    [1] https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=148645988*来自志愿者整理的FLINK邮件归档

    2021-12-03 18:08:39
    赞同 展开评论 打赏
问答排行榜
最热
最新

相关电子书

更多
Java Spring Boot开发实战系列课程【第16讲】:Spring Boot 2.0 实战Apache Kafka百万级高并发消息中间件与原理解析 立即下载
MaxCompute技术公开课第四季 之 如何将Kafka数据同步至MaxCompute 立即下载
消息队列kafka介绍 立即下载