??????????INDEX??????????????????????INDEX++ 
??????????value????????????????????????????array????????????????????????????????????????????????
CREATE TABLE KafkaTable (
&nbsp; datas array<row<filed_1 STRING,filed_2 INT&gt;&gt;
) WITH (
&nbsp; 'connector' = 'kafka',
&nbsp; 'topic' = 'user_behavior',
&nbsp; 'properties.bootstrap.servers' = 'localhost:9092',
&nbsp; 'properties.group.id' = 'testGroup',
&nbsp; 'scan.startup.mode' = 'earliest-offset',
&nbsp; 'format' = 'json'
);

SELECT datas&nbsp;,datas&nbsp;[1].filed_1, datas&nbsp;[1].filed_2&nbsp; from 
KafkaTable;

回复