问题原因一般有两种:
- 确实没有这个jar包导致
- Flink版本和connector版本不一致导致
我的问题是Flink版本和Connector版本不一致导致的,其实Flink服务端用的版本是1.9.0,而kafka Connector版本没有和服务端版本保持一致。
修改方式:Flink版本用1.9.0,则kafka-connector版本也用1.9.0.
参考文章:https://juejin.im/post/5d844d11e51d4561e0516bbd
问题原因一般有两种:
本文标题:Flink报错NoSuchMetchod的错误
本文链接:https://www.haomeiwen.com/subject/wqgxvctx.html
网友评论