目前应该没有直接可以使用的方式,但是可以通过重写KafkaDynamicTableFactory来实现你要的结果,不知道社区在之后有没有考虑加上topic-separator


------------------------------------------------------------------
发件人:奔跑的小飞袁 <[email protected]>
发送时间:2020年10月26日(星期一) 14:23
收件人:user-zh <[email protected]>
主 题:Re: 回复:flinksql指定kafka多topic

有没有一种更加友好的方式  使用topic-pattern的话在提供给非开发人员使用成本太高



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

回复