ClassCastException: kafka.cluster.BrokerEndPoint不能强制转换为kafka.cluster

Question

首先，我的kafka的gav是org.apache.kafka || kafka_2.11 || 0.9.0.0，我的spark-streaming的gav是org.apache.spark || spark-streaming-kafka-0-8_2.11 || 2.2.0

我遇到这个错误的伙伴的官方网站的指南，我搜索了一些关于这个error.that的答案告诉我是版本的情况，所以我把我的Kafka的版本改为0.8.2.0，问题是solved.So我不能理解是，为什么我遇到这个问题的指南从办公室website.Is办公室网站错误？

请帮我个忙。

Answer 1

我已经解决了我的问题。我的scala-library版本是2.10.x，但是spark-streaming-kafka-0-8_2.11依赖于2.11.x，所以我把spark-streaming-kafka-0-8_2.11改成了spark-streaming-kafka-0-8_2.10，问题解决了。