现在就可以使用,刚查了一下,你可以参考下ShengKai的 The config option `topic` and `topic-pattern` specifies the topics or topic pattern to consume for source. The config option `topic` can accept topic list using semicolon separator like 'topic-1;topic-2'.
------------------------------------------------------------------ 发件人:奔跑的小飞袁 <[email protected]> 发送时间:2020年10月26日(星期一) 14:31 收件人:user-zh <[email protected]> 主 题:Re: 回复:回复:flinksql指定kafka多topic 好的 那我尝试下通过KafkaDynamicTableFactory来实现 -- Sent from: http://apache-flink.147419.n8.nabble.com/
