Hi Jason, The KeyedDeserializationSchema is located in the flink-connector-kafka-base module, so you'll need to include the jar for that too [1].
Cheers, Gordon [1] https://repo1.maven.org/maven2/org/apache/flink/flink-connector-kafka-base_2.11/1.4.0/ -- Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/
