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
however I'm still seeing the error.

I played around a bit and it turns out I have to package kafka-clients v. 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?


My GPG Key ID: 336E2680

View raw message