I had fought with 0.8.0.2 kafka and flink 0.10.2 scala version 2.11, was never able to get it working confounded with noclassdeffounderror, moved to flink 1.0.0 with kafka 0.8.0.2 scala version 2.11 things worked for me, if moving to flink 1.0.0 is an option for you do so.
balaji On Mon, Apr 18, 2016 at 3:19 AM, Robert Schmidtke <ro.schmid...@gmail.com> wrote: > 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 >
