kafka.cluster.BrokerEndPoint cannot be cast to kafka.cluster.Broker

Question

版本与课程的都一致，运行就报错kafka.cluster.BrokerEndPoint cannot be cast to kafka.cluster.Broker

Answer 1

进击的大黄鸭 2017-12-21 10:29:09

<dependency>

            <groupId>org.apache.kafka</groupId>

            <artifactId>kafka_2.11</artifactId>

            <version>${kafka.version}</version>

        </dependency>

把这段注释掉

• Chuansssss #1

  多谢多谢~！

• hwbaker #2

  如果把这段注释掉，那不就没有kafka的依赖了啊？

• 忘川了凡 #3

  话说这是为啥 去除掉kafka的依赖pom里面就没有了啊

Answer 2

qq_神奇逸_0 2017-12-03 10:51:53

kafka.version 0.9.0.0 不兼容  用0.8.2.1

Answer 3

Michael_PK 2017-12-02 10:21:59

你的版本和上课的一致不

• 提问者 jsonhou #1

  版本跟课程应该都是一致的，都比对过，没什么差异。

• TeMiO #2

  把引入kafka的jar注释掉

• 慕斯5147022 #3

  他这个不是版本不一致，他应该在pom文件中重复添加了如下两个
  spark-streaming_2.11
  kafka_2.11

点开查看后面1条评论