Thank you for your reply! 您所说的kafka connector 是* flink-connector-kafka_2.11* 这个依赖吗？这个是Datastream所用的依赖，我在pom中已经引入了 *flink-sql-connector-kafka_2.11*依赖了。 我试了引入* flink-connector-kafka_2.11*，但还是会报错的。
----- Thanks! Jacob -- Sent from: http://apache-flink.147419.n8.nabble.com/
