是的,或者自己可以 cherry-pick 这个 MR,然后编译把。
在 2020-11-18 16:47:59,"赵一旦" <[email protected]> 写道: >这个问题现在应该还是无解的吧。那个topic-pattern看了下文档也不存在还,1.11不支持对吗? > >hailongwang <[email protected]> 于2020年10月26日周一 下午8:37写道: > >> 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/ >>
