Flink 0.10.2 and Kafka 0.8.1

Posted by Robert Schmidtke on
URL: http://deprecated-apache-flink-user-mailing-list-archive.369.s1.nabble.com/Flink-0-10-2-and-Kafka-0-8-1-tp6154.html

Hi everyone,

I have a Kafka cluster running on version 0.8.1, hence I'm using the FlinkKafkaConsumer081. When running my program, I saw a NoClassDefFoundError for org.apache.kafka.common.Node. So I packaged my binaries according to https://ci.apache.org/projects/flink/flink-docs-release-0.10/apis/cluster_execution.html#linking-with-modules-not-contained-in-the-binary-distribution, however I'm still seeing the error.

I played around a bit and it turns out I have to package kafka-clients v. 0.8.2.0 instead of kafka_2.10 v. 0.8.1 with my program. Is there an error in the documentation or have I not figured out something properly?

Thanks!

Robert

--