with (
    'connector'='kafka',
  
'topic'='cloud_behavior;cloud_behavior_other;cloud_behavior_qxb;cloud_behavior_cc;cloud_behavior_cs',
    'properties.bootstrap.servers'='',
    'properties.group.id'='flink_2_hive_and_imei_ncrypy_test',
    'format'='avro',
    'scan.startup.mode'='group-offsets'
);

这是我的配置,但是在执行的时候失败了,我想知道目前支持的flinksql版本是哪个



--
Sent from: http://apache-flink.147419.n8.nabble.com/

回复