好的 那我尝试下通过KafkaDynamicTableFactory来实现


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

回复