ClassCastException：kafka.cluster.BrokerEndPoint无法强制转换为kafka.cluster

Posted 2021-04-26

首先，我的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

我遇到了这个错误的官方网站的指南，我搜索了一些关于这个错误的答案。告诉我是版本案例，所以我将我的Kafka的版本改为0.8.2.0，问题解决了。所以我不能忍受是的，为什么我在办公室网站的指南下遇到这个问题。这是办公室网站错误吗？

请帮我一个忙。

答案

我已经解决了我的问题。我的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。问题解决了。