这个不是很懂，（1）flink-connector-kafka_2.11-1.11.2.jar+flink-connector-kafka-base_2.11-1.11.2.jar+kafka-clients-0.11.0.3.jar 和（2）flink-sql-connector-kafka**.jar是啥区别呢？
使用（1）可以不？因为我的kafka-clients部分是调整了源码的。 Leonard Xu <xbjt...@gmail.com> 于2020年9月28日周一 下午4:36写道： > Hi > benchao的回复是的对的， > 你用SQL client 时， 不需要datastream connector的jar包，直接用SQL connector 对应的jar包 > flink-*sql*-connector-kafka***.jar就行了，把你添加的其他jar包都删掉。 > > > > 相关lib包： > > flink-connector-kafka_2.12-1.10.2.jar > > kafka-clients-0.11.0.3.jar > > 祝好 > Leonard
