Hi s_hongliang, 目前的 Master 分支(1.12) 版本支持一个 source 指定消费多个 topics。 相关issue见：https://issues.apache.org/jira/browse/FLINK-18449
目前你可以拆成多个 Source 消费。 Best, Hailong Wang 在 2020-10-26 13:54:40，"奔跑的小飞袁" <[email protected]> 写道： >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/
