问题背景:
在进行Spark Streaming对接Kafka,采用Direct方式的时候。
运行IDEA报错:
Exception in thread "main" java.lang.ClassCastException: kafka.cluster.BrokerEndPoint cannot be cast to kafka.cluster.Broker
解决:
注释掉kafka依赖
<!--<dependency>-->
<!--<groupId>org.apache.kafka</groupId>-->
<!--<artifactId>kafka_2.11</artifactId>-->
<!--<version>${kafka.version}</version>-->
<!--</dependency>-->
大概是因为kafka版本冲突,因为pom中我还添加的这个
<dependency>
<groupId>org.apache.spark</groupId>
<artifactId>spark-streaming-kafka-0-8_2.11</artifactId>
<version>${spark.version}</version>
</dependency>
解决啦OK~
网友评论