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

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

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

问答 2022-02-15 来自:开发者社区

请问在 flink sql 中建立的多张表应当怎样分辨接收 kafka 传来的 canal-json

这是我在 flink sql 中建立的两张表: create table base ( id int, location varchar(20) )WITH ( 'connector' = 'kafka', 'topic' = 'example', 'properties.group.id' = 'testGroup', 'scan.startup.mode' = 'latest-offset'....

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

开发与运维

集结各类场景实战经验,助你开发运维畅行无忧

+关注