Missing this class?
Mavern
<dependency><groupId>org.apache.flinkgroupId><artifactId>flink-connector-kafka-0.9_2.10artifactId><version>1.0.3-hadoop1version>dependency>