问题已解决

需要在FLink home的lib中引入kafka connector jar包



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

回复