flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Robert Schmidtke <ro.schmid...@gmail.com>
Subject Flink 0.10.2 and Kafka 0.8.1
Date Sun, 17 Apr 2016 21:49:56 GMT
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

-- 
My GPG Key ID: 336E2680

Mime
View raw message