Hello, I am just getting started with Flink and am attempting to use the kafka connector. In particular I am attempting to use the jar flink-connector-kafka-0.11_2.11-1.4.0.jar downloaded from:
https://repo1.maven.org/maven2/org/apache/flink/flink-connector-kafka-0.11_2.11/1.4.0/ with the latest flink-dist_2.11-1.4.0.jar that was downloaded from the main Flink site. I attempted to use the constructor: public FlinkKafkaConsumer011(String topic, KeyedDeserializationSchema<T> deserializer, Properties props) but the IDE indicated that the KeyedDeserializationSchema interface was not defined. I see that it should be defined as it is contained in the directory: https://github.com/apache/flink/tree/release-1.4/flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/util/serialization and the flink-dist_2.11-1.4.0.jar does contain that path but only contains the classes: I am guessing I have a mismatch of some sort, but the versions match so I am not sure what to check. Is the flink connector class in the maven repo old or is there a different location from which it should be retrieved? Any other suggestions? Thanks, Jason
