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

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

hwbaker

2018-02-08

4-5 Kafka单节点单broker的部署及使用章节中 Kafka的建议版本是0.9.0.0，

10-9 Direct方式整合之Spark Streaming应用开发及本地环境测试章节中事件报错如下：

Exception in thread "main" java.lang.ClassCastException: kafka.cluster.BrokerEndPoint cannot be cast to kafka.cluster.Broker

写回答

4回答

weixin_慕妹8043461

2020-04-05

优秀的解答

hwbaker

提问者

2018-02-19

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

<artifactId>kafka_2.11</artifactId>

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

</dependency>

把这段注释掉

注释掉就好了，不太明白为什么

慕尼黑5219940

你太厉害了，这都给你找到原因了，你还别说，真的是这个包引起的，我觉得可能是两个包都用StringDecoder, 它先用了版本不对的上面的那个依赖的kafka的jar包，注释掉就引用版本相符的了

2019-03-04

共1条回复

hwbaker

提问者

2018-02-08

1、重新下载 kafka_2.11-0.8.2.1.tgz，版本0.8.2.1，更改环境变量:

export KAFKA_HOME=/opt/kafka_2.11-0.8.2.1

export PATH=$KAFKA_HOME/bin:$PATH

2、修改IDEA中pom.xml

<kafka.version>0.9.0.0</kafka.version> 改为 <kafka.version>0.8.2.1</kafka.version>

Michael_PK

2018-02-08

这个问题你百度下或者找下问答区的，以前有这个问题，解决过的

Spark Streaming实时流处理项目实战

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

1404 学习 · 571 问题

查看课程

相似问题

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

回答 3

kafka JAR 包冲突

回答 4

Unable to start SinkRunner: { policy:org.apache.flume.sink.DefaultSinkProcessor

回答 1

报错信息

回答 1

Will not attempt to authenticate using SASL (unknown error)

回答 2

打开慕课网App查看更多内容