Hi Jason,
You actually should not be adding the flink-dist jar as a dependency in your
application.
It seems like you are not using a build tool for your application, but adding
dependencies manually.
In general, I would recommend build management tools like Maven / Gradle for
building Java app
Thanks. That resolved it. Also had to pull in the kafka 10 and 9 versions of
the connector jars. Once the base jar is in the mvn repository, this won't be
as problematic.
On Friday, January 12, 2018, 9:46:22 AM EST, Tzu-Li (Gordon) Tai
wrote:
Hi Jason,
The KeyedDeserializationSchema
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-
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
