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

来源:10-9 -Direct方式整合之Spark Streaming应用开发及本地环境测试

jsonhou

2017-12-02

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

http://img.mukewang.com/szimg/5a220358000146df18650854.jpg

写回答

3回答

进击的大黄鸭

2017-12-21

<dependency>

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

            <artifactId>kafka_2.11</artifactId>

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

        </dependency>

把这段注释掉

2
3
忘川了凡
话说这是为啥 去除掉kafka的依赖pom里面就没有了啊
2018-11-11
共3条回复

qq_神奇逸_0

2017-12-03

kafka.version 0.9.0.0 不兼容  用0.8.2.1

1
0

Michael_PK

2017-12-02

你的版本和上课的一致不

0
4
ABC简简简简
回复
慕斯5147022
赞,正解,包冲突了
2020-09-02
共4条回复

Spark Streaming实时流处理项目实战

Flume+Kafka+Spark Streaming 构建通用实时流处理平台

1404 学习 · 571 问题

查看课程