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
