flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Paolo Cristofanelli <cristofanelli.pa...@gmail.com>
Subject Kafka Connectors
Date Wed, 05 Jul 2017 16:04:41 GMT
I am following the basic steps to implement a consumer and a producer with
Kafka for Flink. My Flink version is 1.2.0, the Kafka's one is, so
in my pom.xml I will add the :


The problem is that if I run the program with maven or in my IDE it works.
When I upload the jar on flink I get : java.lang.ClassNotFoundException:

I googled a bit and I found out that usually these problems are caused by a
version problem but I cannot understand where the error is.


View raw message