美文网首页
解决: Exception in thread "main" j

解决: Exception in thread "main" j

作者: Sam_L | 来源:发表于2019-02-01 14:38 被阅读0次
问题背景:

在进行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~

相关文章

网友评论

      本文标题:解决: Exception in thread "main" j

      本文链接:https://www.haomeiwen.com/subject/jvhdsqtx.html